swoole中onreceive不触发怎么办

发布时间:2021-01-21 10:34:20 作者:小新
来源:亿速云 阅读:275

这篇文章给大家分享的是有关swoole中onreceive不触发怎么办的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。

onReceive

接收到数据时回调此函数,发生在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 详细的解释

未开启自动协议选项,onReceive单次收到的数据最大为64K

开启了自动协议处理选项,onReceive将收到完整的数据包,最大不超过 package_max_length

支持二进制格式,$data可能是二进制数据

使用底层提供的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个请求

感谢各位的阅读!关于“swoole中onreceive不触发怎么办”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!

推荐阅读:
  1. PHP析构方法 __destruct() 不触发怎么办
  2. vue首次赋值不触发watch怎么办

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

swoole onreceive

上一篇:swoole监听端口的示例

下一篇:swoole如何进行错误处理

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》