WebSocket Server

1.框架提供原始的 FastD\Servitization\Server，实现代码如下：

  1. <?php
  3. class WebSocketServer extends WebSocket
  4. {
  5.     use OnWorkerStart;
  7.     /**
  8.      * @param swoole_server          $server
  9.      * @param swoole_websocket_frame $frame
  10.      *
  11.      * @return int|mixed
  12.      *
  13.      * @throws \Exception
  14.      * @throws \FastD\Packet\Exceptions\PacketException
  15.      */
  16.     public function doMessage(swoole_server $server, swoole_websocket_frame $frame)
  17.     {
  18.         $data = $frame->data;
  19.         $data = Json::decode($data);
  20.         $request = new ServerRequest($data['method'], $data['path']);
  21.         if (isset($data['args'])) {
  22.             if ('GET' === $request->getMethod()) {
  23.                 $request->withQueryParams($data['args']);
  24.             } else {
  25.                 $request->withParsedBody($data['args']);
  26.             }
  27.         }
  28.         $response = app()->handleRequest($request);
  29.         $fd = null !== ($fd = $response->getFileDescriptor()) ? $fd : $frame->fd;
  30.         if (false === $server->connection_info($fd)) {
  31.             return -1;
  32.         }
  33.         $server->push($fd, (string) $response->getBody());
  34.         app()->shutdown($request, $response);
  36.         return 0;
  37.     }
  38. }
  40. 配置文件 
  41. return [
  42.     'host' => 'ws://127.0.0.1:9527',
  43.     'class' => \FastD\Servitization\Server\WebSocketServer::class,
  44.     'options' => [
  45.         'pid_file' => __DIR__.'/../runtime/pid/'.app()->getName().'.pid',
  46.         'log_file' => __DIR__.'/../runtime/logs/'.date('Ymd').'/'.app()->getName().'.log',
  47.         'worker_num' => 8,
  48.         'task_worker_num' => 8,
  49.         'user' => 'www',
  50.         'group' => 'www',
  51.     ],
  52. ];

主要核心接受 json 格式数据，由 FastD\Packet\Json 对象进行处理。因此 TCPServer 接受需要接受 json 格式的数据，例如:

  1. {
  2.     "method":"POST",
  3.     "path": "/",
  4.     "args": [
  5.       "foo":"bar"
  6.     ]
  7. }

客户端示例代码：

  1. var ws = new WebSocket("ws://127.0.0.1:9527"); 
  2. ws.onopen = function(evt) {  
  3.     console.log("Connection open ...");  
  4.     var data = {
  5.       "method":"POST",
  6.       "path":"/",
  7.       "args":{
  8.         "foo":"bar"
  9.       }
  10.     };
  11.     data = JSON.stringify(data);
  12.     ws.send(data);  
  13. };  
  14. ws.onmessage = function(evt) {  
  15.     console.log("Received Message: " + evt.data);  
  16.     ws.close();  
  17. };  
  18. ws.onclose = function(evt) {  
  19.     console.log("Connection closed.");  
  20. };

如上示例会被分发到POST路由 "/" 下，参数foo值为bar

2.如果你想自定义WebSocket 只需要修改配置为

  1. return [
  2.     'host' => 'ws://127.0.0.1:9527',
  3.     'class' => \Server\CustomizeSocketServer::class,
  4.     'options' => [
  5.         'pid_file' => __DIR__.'/../runtime/pid/'.app()->getName().'.pid',
  6.         'log_file' => __DIR__.'/../runtime/logs/'.date('Ymd').'/'.app()->getName().'.log',
  7.         'worker_num' => 8,
  8.         'task_worker_num' => 8,
  9.         'user' => 'www',
  10.         'group' => 'www',
  11.     ],
  12. ];

并增加目录和文件：项目目录/app/src/Server/CustomizeSocketServer.php 大致内容如下：

  1. <?php
  3. namespace Server;
  5. use FastD\Servitization\OnWorkerStart;
  6. use FastD\Swoole\Server\WebSocket;
  7. use swoole_server;
  8. use swoole_websocket_frame;
  10. /**
  11.  * Class WebSocketServer.
  12.  */
  13. class CustomizeSocketServer extends WebSocket
  14. {
  15.     use OnWorkerStart;
  17.     /**
  18.      * @param swoole_server          $server
  19.      * @param swoole_websocket_frame $frame
  20.      *
  21.      * @return int|mixed
  22.      *
  23.      * @throws \Exception
  24.      * @throws \FastD\Packet\Exceptions\PacketException
  25.      */
  26.     public function doMessage(swoole_server $server, swoole_websocket_frame $frame)
  27.     {   
  28.         //接收客户端的数据 $frame-data
  29.         //客户链接标识： $frame->fd
  30.         //在这里实现你的代码逻辑
  31.         //如想直接响应客户端(如果响应的数据为二进制数据需要增加第三个参数为 WEBSOCKET_OPCODE_BINARY )
  32.         $server->push($frame->fd, "hello!");
  33.     }
  35.     public function doClose(swoole_server $server, $fd, $fromId){
  36.         //客户端断开事件
  37.     }
  39.     //还有其他事件请看 WebSocket 类
  40. }

启动服务 :cd到项目目录执行 php bin/server start 如需挂为守护进程增加 -d 参数