自定义TCP命令解析

EasySwoole支持用户进行自定义格式的命令解析与路由。以下我们将以最基础的例子作为讲解。

建立自定义命令解析类

  1. namespace App\Sock;
  4. use Core\Component\Socket\AbstractInterface\AbstractClient;
  5. use Core\Component\Socket\AbstractInterface\AbstractCommandParser;
  6. use Core\Component\Socket\Common\Command;
  8. class Parser extends AbstractCommandParser
  9. {
  11.     function parser(Command $result, AbstractClient $client, $rawData)
  12.     {
  13.         // TODO: Implement parser() method.
  14.     }
  15. }

在AbstractCommandParser的接口定义中，我们需要实现parser方法，parser的三参数分别为：

  • 解析后的命令包
  • 客户端
  • 原始数据

比如,我现在定义的规则就是（命令,数据信息）,那么我的解析规则就为：

  1. function parser(Command $result, AbstractClient $client, $rawData)
  2. {
  3.      // TODO: Implement parser() method.
  4.      $data = trim($rawData);
  5.      $data = explode(',',$data);
  6.      $result->setCommand(array_shift($data));
  7.      $result->setMessage(array_shift($data));
  8. }

定义命令注册类

  1. namespace App\Sock;
  4. use Core\Component\Socket\AbstractInterface\AbstractCommandRegister;
  5. use Core\Component\Socket\Common\CommandList;
  7. class Register extends AbstractCommandRegister
  8. {
  10.     function register(CommandList $commandList)
  11.     {
  12.         // TODO: Implement register() method.
  13.     }
  14. }

在AbstractCommandRegister接口中，我们必须实现register方法。举例，我们注册三个实验方法：

  1. namespace App\Sock;
  4. use Core\Component\Logger;
  5. use Core\Component\Socket\AbstractInterface\AbstractCommandRegister;
  6. use Core\Component\Socket\Client\TcpClient;
  7. use Core\Component\Socket\Common\Command;
  8. use Core\Component\Socket\Common\CommandList;
  9. use Core\Component\Socket\Response;
  10. use Core\Swoole\AsyncTaskManager;
  11. use Core\Swoole\Server;
  13. class Register extends AbstractCommandRegister
  14. {
  16.     function register(CommandList $commandList)
  17.     {
  18.         // TODO: Implement register() method.
  19.         $commandList->addCommandHandler('hello',function (Command $request,TcpClient $client){
  20.             $message = $request->getMessage();
  21.             Logger::getInstance()->console('message is '.$message,false);
  22.             AsyncTaskManager::getInstance()->add(function ()use($client){
  23.                 sleep(2);
  24.                 Response::response($client,"this is delay message for hello\n");
  25.             });
  26.             return "response for hello\n";
  27.         });
  29.         $commandList->addCommandHandler('close',function (Command $request,TcpClient $client){
  30.             Response::response($client,"you are going to disconnect\n");
  31.             Server::getInstance()->getServer()->close($client->getFd(),$client->getReactorId());
  32.         });
  34.         $commandList->setDefaultHandler(function (){
  35.            return "unkown command\n";
  36.         });
  37.     }
  38. }

添加事件监听

在EasySwoole的启动前事件中：

  1. use App\Sock\Parser;
  2. use App\Sock\Register;
  3. use Core\Component\Socket\Dispatcher;
  6. function beforeWorkerStart(\swoole_server $server){
  7.     $listener = $server->addlistener('0.0.0.0',9502,SWOOLE_TCP);
  8.     $listener->set(array(
  9.         "open_eof_check"=>false,
  10.         "package_max_length"=>2048,
  11.     ));
  12.     $listener->on("receive",function(\swoole_server $server,$fd,$from_id,$data){
  13.          Dispatcher::getInstance(Register::class,Parser::class)->dispatchTCP($fd,$from_id,$data);
  14.     });
  15. }

测试

启动EasySwoole，执行：

  1. telnet 127.0.0.1 9501

分别输入：

  • hello
  • hello,message
  • abc，
  • close

观察结果。