onReceive
最后更新于：2022-04-02 06:24:04
# 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`。
';