TCP控制器

协议规则与解析

假定，客户端与服务端都是明文传输。控制格式为

  1. sericeName:actionName:args

实现解析器

  1. namespace Tcp;
  3. use EasySwoole\Core\Socket\AbstractInterface\ParserInterface;
  4. use EasySwoole\Core\Socket\Common\CommandBean;
  6. class Parser implements ParserInterface
  7. {
  9.     public static function decode($raw, $client): ?CommandBean
  10.     {
  11.         // TODO: Implement decode() method.
  12.         $list = explode(":",trim($raw));
  13.         $bean = new CommandBean();
  14.         $controller = array_shift($list);
  15.         if($controller == 'test'){
  16.             $bean->setControllerClass(Test::class);
  17.         }
  18.         $bean->setAction(array_shift($list));
  19.         $bean->setArg('test',array_shift($list));
  20.         return $bean;
  21.     }
  23.     public static function encode(string $raw, $client): ?string
  24.     {
  25.         // TODO: Implement encode() method.
  26.         return $raw."\n";
  27.     }
  28. }

实现一个控制服务

  1. namespace Tcp;
  4. use EasySwoole\Core\Socket\Response;
  5. use EasySwoole\Core\Socket\AbstractInterface\TcpController;
  6. use EasySwoole\Core\Swoole\ServerManager;
  7. use EasySwoole\Core\Swoole\Task\TaskManager;
  9. class Test extends TcpController
  10. {
  11.     function actionNotFound(?string $actionName)
  12.     {
  13.         $this->response()->write("{$actionName} not found");
  14.     }
  16.     function test()
  17.     {
  18.         $this->response()->write(time());
  19.     }
  21.     function args()
  22.     {
  23.         var_dump($this->request()->getArgs());
  24.     }
  26.     function delay()
  27.     {
  28.         $client = $this->client();
  29.         TaskManager::async(function ()use($client){
  30.             sleep(1);
  31.             Response::response($client,'this is delay message at '.time());//为了保持协议一致，实际生产环境请调用Parser encoder
  32.         });
  33.     }
  35.     function close()
  36.     {
  37.         $this->response()->write('you are goging to close');
  38.         $client = $this->client();
  39.         TaskManager::async(function ()use($client){
  40.             sleep(2);
  41.             ServerManager::getInstance()->getServer()->close($client->getFd());
  42.         });
  43.     }
  45.     function who()
  46.     {
  47.         $this->response()->write('you fd is '.$this->client()->getFd());
  48.     }
  49. }

开启子服务

在EasySwooleEvent中注册。

  1.   public static function mainServerCreate(ServerManager $server,EventRegister $register): void
  2.     {
  3.         // TODO: Implement mainServerCreate() method.
  4.         $tcp = $server->addServer('tcp',9502);
  5.         EventHelper::registerDefaultOnReceive($register,\Tcp\Parser::class,function($errorType,$clientData,$client){
  6.             //第二个回调是可有可无的，当无法正确解析，或者是解析出来的控制器不在的时候会调用
  7.             TaskManager::async(function ()use($client){
  8.                 sleep(3);
  9.                 \EasySwoole\Core\Socket\Response::response($client,"Bye");
  10.                 ServerManager::getInstance()->getServer()->close($client->getFd());
  11.             });
  12.             return "{$errorType} and going to close";
  13.         });
  14.     }

测试

  1. telnet 127.0.0.1 9502
  2. Trying 127.0.0.1...
  3. Connected to localhost.
  4. Escape character is '^]'.
  5. test
  6.  not found
  7. test:test
  8. 1518078988
  9. test:args
  11. test:delay
  13. this is delay message at 1518079006
  14. TARGET_CONTROLLER_NOT_FOUND and going to close
  15. ByeConnection closed by foreign host.

HTTP往TCP推送

HTTP控制器

  2. namespace App\HttpController;
  5. use EasySwoole\Core\Http\AbstractInterface\Controller;
  6. use EasySwoole\Core\Swoole\ServerManager;
  8. class Tcp extends Controller
  9. {
  11.     function index()
  12.     {
  13.         // TODO: Implement index() method.
  14.         $this->actionNotFound(null);
  15.     }
  17.     /*
  18.      * 请调用who，获取fd
  19.      * http://ip:9501/tpc/push/index.html?fd=xxxx
  20.      */
  21.     function push()
  22.     {
  23.         $fd = intval($this->request()->getRequestParam('fd'));
  24.         $info = ServerManager::getInstance()->getServer()->connection_info($fd);
  25.         if(is_array($info)){
  26.             ServerManager::getInstance()->getServer()->send($fd,'push in http at '.time());
  27.         }else{
  28.             $this->response()->write("fd {$fd} not exist");
  29.         }
  30.     }
  31. }

实际生产中，一般是用户TCP连接上来后，做验证，然后以userName=>fd的格式，存在redis中，需要http，或者是其他地方，
比如定时器往某个连接推送的时候，就是以userName去redis中取得对应的fd，再send。注意，通过addServer形式创建的子服务器，
以再完全注册自己的网络事件，你可以注册onclose事件，然后在连接断开的时候，删除userName=>fd对应。