onReceive

接收到数据时回调此函数,发生在worker进程中。函数原型:

function onReceive(swoole_server $server, int $fd, int $reactor_id, string $data);
  • $serverServer对象
  • $fdTCP客户端连接的唯一标识符
  • $reactor_idTCP连接所在的Reactor线程ID
  • $data,收到的数据内容,可能是文本或者二进制内容

关于$fd$reactor_id 详细的解释
未开启自动协议选项,onReceive单次收到的数据最大为64K
开启了自动协议处理选项,onReceive将收到完整的数据包,最大不超过 package_max_length
支持二进制格式,$data可能是二进制数据

关于TCP协议下包完整性

  • 使用底层提供的open_eof_check/open_length_check/open_http_protocol,可以保证数据包的完整性
  • 不使用底层的协议处理,在onReceivePHP代码中自行对数据分析,合并/拆分数据包。

例如:代码中可以增加一个 $buffer = array(),使用$fd作为key,来保存上下文数据。 每次收到数据进行字符串拼接,$buffer[$fd] .= $data,然后在判断$buffer[$fd]字符串是否为一个完整的数据包。

默认情况下,同一个fd会被分配到同一个Worker中,所以数据可以拼接起来。使用dispatch_mode = 3时。
请求数据是抢占式的,同一个fd发来的数据可能会被分到不同的进程。所以无法使用上述的数据包拼接方法

关于粘包问题,如SMTP协议,客户端可能会同时发出2条指令。在Server中可能一次性收到,这时应用层需要自行拆包。SMTP是通过\r\n来分包的,所以业务代码中需要 explode("\r\n", $data)来拆分数据包。

如果是请求应答式的服务,无需考虑拆分数据的问题。原因是客户端在发起一次请求后,必须等到服务器端返回当前请求的响应数据,才会发起第二次请求,不会同时发送2个请求。

多端口监听

当主服务器设置了协议后,额外监听的端口默认会继承主服务器的设置。需要显式调用set方法来重新设置端口的协议。

$serv = new Swoole\Http\Server("127.0.0.1", 9501);
$port2 = $serv->listen('127.0.0.1', 9502, SWOOLE_SOCK_TCP);
$port2->on('receive', function (Swoole\Server $serv, $fd, $reactor_id, $data) {
    echo "[#".$serv->worker_id."]\tClient[$fd]: $data\n";
});

这里虽然调用了on方法注册了onReceive回调函数,但由于没有调用set方法覆盖主服务器的协议,新监听的9502端口依然使用Http协议。使用telnet客户端连接9502端口发送字符串时服务器不会触发onReceive



  • 青青小超子

    怎样判断$buffer[$fd]字符串是否为一个完整的数据包?

  • 秣马儿

    根据协议,有的协议是用界定符,比如\r\n这种,有的是包头里指定了包长度。

  • DjvshD

    TCP下数据包的完整性还是使用swoole本身提供的open_eof_check/open_length_check/open_http_protocol吧,感觉比较省事

  • 陈宇

    为什么我开启了open_eof_check,包数据不完整,还是能在onreceive里面获取到? 'open_eof_check'=>true, 'package_eof' => "**",

    我client发送123在onreceive里面能获取到

  • 我梦江南好

    请问:是不是在swoole_http_server和swoole_websocket_server里,屏蔽掉了Receive事件? 经测试,下面这段代码,只会触发Request事件,不会触发Receive事件。这是正常的吗?

    !/usr/bin/php71

  • 宇宙星辰

    $data出现字符串和乱码的混合

  • van23qf

    64K对纯文本来说已经很多了,又不是上传文件

  • sonly

    现在学swoole会迟么

  • 蛟十五

    我正在学