转自与https://blog.csdn.net/qmhball/article/details/53888197
1. 相关函数
kernel.msgmnb = 4203520,消息队列的最大字节数
kernel.msgmni = 64,最多允许创建多少个消息队列
kernel.msgmax = 8192,消息队列单条数据最大的长度
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.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()取得。