UDP命令解析

与TCP命令解析同理，直接上代码

解析器

  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.         $data = trim($rawData);
  15.         $data = explode(',',$data);
  16.         $result->setCommand(array_shift($data));
  17.         $result->setMessage(array_shift($data));
  18.     }
  19. }

命令注册

  1. namespace App\Sock;
  4. use Core\Component\Logger;
  5. use Core\Component\Socket\AbstractInterface\AbstractCommandRegister;
  6. use Core\Component\Socket\Client\UdpClient;
  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;
  12. class Register extends AbstractCommandRegister
  13. {
  15.     function register(CommandList $commandList)
  16.     {
  17.         // TODO: Implement register() method.
  18.         $commandList->addCommandHandler('hello',function (Command $request,UdpClient $client){
  19.             $message = $request->getMessage();
  20.             Logger::getInstance()->console('message is '.$message,false);
  21.             AsyncTaskManager::getInstance()->add(function ()use($client){
  22.                 sleep(2);
  23.                 Response::response($client,"this is delay message for hello\n");
  24.             });
  25.             return "response for hello\n";
  26.         });
  28.         $commandList->setDefaultHandler(function (){
  29.            return "unkown command\n";
  30.         });
  31.     }
  32. }

注意，UDP的回调客户端类型是UdpClient

事件监听

  1. use App\Sock\Parser;
  2. use App\Sock\Register;
  3. use Core\Component\Socket\Dispatcher;
  6. function beforeWorkerStart(\swoole_server $server)
  7. {
  8.     // TODO: Implement beforeWorkerStart() method.
  9.     $udp = $server->addlistener("0.0.0.0",9503,SWOOLE_UDP);
  10.     //udp 请勿用receive事件
  11.     $udp->on('packet',function(\swoole_server $server, $data,$clientInfo){
  12.            Dispatcher::getInstance(Register::class,Parser::class)->dispatchUDP($data,$clientInfo);
  13.     });
  14. }

测试代码

  1. $client = new swoole_client(SWOOLE_SOCK_UDP);
  2. if (!$client->connect('127.0.0.1', 9503, -1))
  3. {
  4.     exit("connect failed. Error: {$client->errCode}\n");
  5. }
  6. $client->send("hello\n");
  7. echo $client->recv();
  8. $client->close();