swoole的onreceive没有触发是为什么,如何解释
Admin 2022-08-30 群英技术资讯 596 次浏览
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个请求
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:mmqy2019@163.com进行举报,并提供相关证据,查实之后,将立刻删除涉嫌侵权内容。
猜你喜欢
本篇文章给大家带来了Laravel目录结构与配置的相关知识,Laravel的目录结构相对来说在初始状态下会更丰富一些,除了传统的控制器之外,也帮我们准备好了脚本、中间件之类的代码文件的目录,基本上是可以达到上手直接使用的,希望对大家有帮助。
workerman中定时器不生效的原因是:定时器不能在【runAll】方法执行前运行,此方法执行前运行的代码全部属于主进程,主进程不能有业务代码,主进程的业务代码会被子进程继承。解决方法是:在【onWorkerStart】中运行定时器即可。
这篇文章主要介绍介绍使用TP5框架实现签到功能,对于新手学习PHP具有一定借鉴价值,感兴趣的朋友可以参考下,下面就跟随小编一起学习下吧。
PHP实现重载功能的方法有很多,这篇文章给大家分享的是用 __call方法实现重载。小编觉得挺实用的,因此分享给大家做个参考,文中示例代码介绍的非常详细,感兴趣的朋友接下来一起跟随小编看看吧。
php怎样实现文件分片上传?如果我们要上传的文件比较大,那么上传速度是比较慢的,而对文件分片上传的目的是为了实现文件更加迅速的上传。这篇文章就主要给大家分享PHP实现文件分片上传的方法及步骤,感兴趣的朋友可以参考。
成为群英会员,开启智能安全云计算之旅
立即注册Copyright © QY Network Company Ltd. All Rights Reserved. 2003-2020 群英 版权所有
增值电信经营许可证 : B1.B2-20140078 粤ICP备09006778号 域名注册商资质 粤 D3.1-20240008