swoole进程【转】

转自与https://blog.csdn.net/qmhball/article/details/53888197

1. 相关函数

swoole_process->useQueue

swoole_process->statQueue

swoole_process->freeQueue

swoole_process->push

swoole_process->pop

2. 与消息队列相关的内核参数

1. 参数

kernel.msgmnb = 4203520,消息队列的最大字节数

kernel.msgmni = 64,最多允许创建多少个消息队列

kernel.msgmax = 8192,消息队列单条数据最大的长度

2. 修改方法

2.1 临时修改

命令行执行如下命令

sysctl -w kernel.msgmax=1024

1

将msgmax改为1024,其它两个参数修改方法类似

2.2 持久修改

修改/etc/sysctl.conf文件,增加(修改)配置

kernel.msgmnb=65536kernel.msgmax=8192

1

2

运行如下命令使配置生效

/sbin/sysctl-p

1

3.几点说明

3.1单条消息超过kernel.msgmax的情况

此时push()返回false,php会报类似下面的错误

PHPWarning:swoole_process::push():msgsnd()failed.Error:Invalidargument[22]

1

3.2消息总量超过kernel.msgmnb的情况

默认模式下(阻塞模式)时,push方法会阻塞等待。

非阻塞模式下,push方法会立即返回false。 

注意,这里说的是队列总体大小,如果你的机器上有多个队列,总体大小是指所有队列所占空间的总和。

3.3如何在进程重启后延用之前的队列

进程启动后使用ipcs -q查看队列的key

ipcs-q------MessageQueues--------keymsqidownerpermsused-bytesmessages0x0010e9e7360448ballqiu66618322

1

2

3

4

5

重启前修改代码,将useQueue()的第一个参数填写上面的key值。

$process=newswoole_process('callback_function',false,false);$process->useQueue(0x0010e9e7);

1

2

这样,即使进程重启,依然可以延用之前的队列,队列中若有未处理完的数据可以继续通过pop()取得。

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

  • date: 2018-1-8 20:56:08title: Swoole| Swoole 中 Process 这篇...
    daydaygo阅读 10,257评论 11 21
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 137,173评论 19 139
  • 咏宾王 不羡宾王七岁鹅 怀才不遇唱反歌 宮峨銮庭空激水 鱼兴他乡逐清波
    商水阅读 341评论 0 0
  • 面向对象的三大特性: 封装继承与多态;封装是对类中的一些字段, 方法进行保护, 不被外界所访问到, 有一种权限控制...
    李小六_阅读 1,069评论 1 4

友情链接更多精彩内容