中间件

开发者可以开发中间件类，对整个WebSocket请求和响应过程进行自定义处理。

定义中间件

  1. <?php
  2. namespace Imi\Server\WebSocket\Middleware;
  4. use Imi\RequestContext;
  5. use Imi\Bean\Annotation\Bean;
  6. use Imi\Server\WebSocket\Message\IFrame;
  7. use Imi\Server\WebSocket\MessageHandler;
  8. use Imi\Server\WebSocket\IMessageHandler;
  10. /**
  11.  * @Bean
  12.  */
  13. class RouteMiddleware implements IMiddleware
  14. {
  15.     /**
  16.      * 处理方法
  17.      *
  18.      * @param IFrame $frame
  19.      * @param IMessageHandler $handler
  20.      * @return void
  21.      */
  22.     public function process(IFrame $frame, IMessageHandler $handler)
  23.     {
  25.     }
  27. }

全局中间件

  1. return [
  2.     'beans'    =>    [
  3.         // 中间件
  4.         'WebSocketDispatcher'    =>    [
  5.             'middlewares'    =>    [
  6.                 // 中间件
  7.                 \Imi\Server\WebSocket\Middleware\RouteMiddleware::class,
  8.             ],
  9.         ],
  10.     ],
  11. ];

局部中间件

注解使用

  1. <?php
  2. namespace ImiDemo\WebSocketDemo\MainServer\WSController\Index;
  4. use Imi\ConnectContext;
  5. use Imi\Controller\WebSocketController;
  6. use Imi\Server\Route\Annotation\WebSocket\WSRoute;
  7. use Imi\Server\Route\Annotation\WebSocket\WSAction;
  8. use Imi\Server\Route\Annotation\WebSocket\WSController;
  9. use Imi\Server\Route\Annotation\WebSocket\WSMiddleware;
  11. /**
  12.  * 数据收发测试
  13.  * @WSController
  14.  */
  15. class Test extends WebSocketController
  16. {
  17.     /**
  18.      * test
  19.      * 
  20.      * @WSAction
  21.      * @WSRoute({"action"="login"})
  22.      * @WSMiddleware(XXX::class)
  23.      * @WSMiddleware({XXX::class,XXX2::class})
  24.      * @return void
  25.      */
  26.     public function test($data)
  27.     {
  28.     }
  29. }

如上代码，同时支持设置单个和多个中间件