swoole进程间通信之消息队列

2020-12-07 15:32:12 浏览数 (1)

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 临时修改

命令行执行如下命令

代码语言：javascript复制
sysctl -w kernel.msgmax=1024

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

2.2 持久修改

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

代码语言：javascript复制
kernel.msgmnb = 65536
kernel.msgmax = 8192

运行如下命令使配置生效

代码语言：javascript复制
/sbin/sysctl -p

3.几点说明

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

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

代码语言：javascript复制
PHP Warning:  swoole_process::push(): msgsnd() failed. Error: Invalid argument[22]
3.2消息总量超过kernel.msgmnb的情况
  • 默认模式下（阻塞模式）时，push方法会阻塞等待。
  • 非阻塞模式下，push方法会立即返回false。 注意，这里说的是队列总体大小，如果你的机器上有多个队列，总体大小是指所有队列所占空间的总和。
3.3如何在进程重启后延用之前的队列
  1. 进程启动后使用ipcs -q查看队列的key
代码语言：javascript复制
ipcs -q

------ Message Queues --------
key        msqid      owner      perms      used-bytes   messages    
0x0010e9e7 360448     ballqiu    666        1832         2
  1. 重启前修改代码，将useQueue()的第一个参数填写上面的key值。
代码语言：javascript复制
$process = new swoole_process('callback_function', false, false);
$process->useQueue(0x0010e9e7);

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

kernel 消息队列CMQ版 kafka 编程算法

0 人点赞