$route
$route : \Imi\Server\WebSocket\Route\WSRoute
$route : \Imi\Server\WebSocket\Route\WSRoute
process(\Imi\Server\WebSocket\Message\IFrame $frame, \Imi\Server\WebSocket\IMessageHandler $handler) : void
处理方法
| \Imi\Server\WebSocket\Message\IFrame | $frame | |
| \Imi\Server\WebSocket\IMessageHandler | $handler |
<?php
namespace Imi\Server\WebSocket\Middleware;
use Imi\App;
use Imi\RequestContext;
use Imi\Bean\Annotation\Bean;
use Imi\Server\Annotation\ServerInject;
use Imi\Server\WebSocket\Message\IFrame;
use Imi\Server\WebSocket\MessageHandler;
use Imi\Server\WebSocket\IMessageHandler;
/**
* @Bean("WebSocketRouteMiddleware")
*/
class RouteMiddleware implements IMiddleware
{
/**
* @ServerInject("WSRoute")
*
* @var \Imi\Server\WebSocket\Route\WSRoute
*/
protected $route;
/**
* @ServerInject("WSRouteNotFoundHandler")
*
* @var \Imi\Server\Http\Error\IWSRouteNotFoundHandler
*/
protected $notFoundHandler;
/**
* 处理方法
*
* @param IFrame $frame
* @param IMessageHandler $handler
* @return void
*/
public function process(IFrame $frame, IMessageHandler $handler)
{
// 路由解析
$result = $this->route->parse($frame->getFormatData());
if(null === $result || !is_callable($result->callable))
{
// 未匹配到路由
$result = $this->notFoundHandler->handle($frame, $handler);
}
else
{
RequestContext::set('routeResult', $result);
$result = $handler->handle($frame);
}
return $result;
}
}