ThinkChat2.0新版上线,更智能更精彩,支持会话、画图、阅读、搜索等,送10W Token,即刻开启你的AI之旅 广告
# onReceive [TOC] 接收到数据时回调此函数,发生在worker进程中。函数原型: ~~~ function onReceive(swoole_server $server, int $fd, int $reactor_id, string $data); ~~~ * `$server`,`Server`对象 * `$fd`,`TCP`客户端连接的唯一标识符 * `$reactor_id`,`TCP`连接所在的`Reactor`线程`ID` * `$data`,收到的数据内容,可能是文本或者二进制内容 > 关于`$fd`和`$reactor_id`[详细的解释](回调函数中的reactor_id和fd.md) > 未开启自动协议选项,`onReceive`单次收到的数据最大为`64K` > 开启了自动协议处理选项,`onReceive`将收到完整的数据包,最大不超过[package\_max\_length](package\_max\_length.md) > 支持二进制格式,`$data`可能是二进制数据 ## 关于TCP协议下包完整性 * 使用底层提供的`open_eof_check`/`open_length_check`/`open_http_protocol`,可以保证数据包的完整性 * 不使用底层的协议处理,在`onReceive`后`PHP`代码中自行对数据分析,合并/拆分数据包。 例如:代码中可以增加一个`$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`。