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()取得。