我在webman中自定义进程使用rabbitmq 的消费者阻塞消费导致进程busy问题

tanhongbin 2024-09-11

我在webman中自定义进程使用rabbitmq 的消费者阻塞消费导致进程busy问题是否有啥好办法解决，如果没有，那这个busy是否对系统会有影响？

消费端代码

$this->channel->basic_consume(
$queue,
'',
false,
false,
false,
false,
$callback
);

register_shutdown_function(function(){
$this->close();
});

$this->channel->consume();//这家伙会阻塞内部有while代码导致的

我使用 status 查看进程一直是busy状态监控不到内存等信息 N/A 不知道是否会有影响？

 186  1 0

six 2024-09-11

感觉stop的时候有影响，死循环stop的时候是被强制kill掉的，业务可能处理一半被kill掉。
while循环改成定时器感觉可行

tanhongbin 2024-09-11

改成定时器会报错而且这种改成定时器主动去取 rabbitmq 强烈不建议这么做我觉得如果没啥影响应该可以用我监控cpu 和内存非常低基本忽略不计压力测试也没发现任何问题
tanhongbin 2024-09-11

stop 的时候 kill掉正常现在增加了这段代码 stop的时候不报错了 pcntl_signal(SIGINT, function(){
Worker::stopAll();
});
six 2024-09-11

就是stop的时候进程可能被kill掉，业务执行一半，其它感觉没影响。
看到 workerman 有rabbitmq客户端啊
https://www.workerman.net/doc/workerman/components/workerman-rabbitmq.html
tanhongbin 2024-09-11

这个没用过我用的 php-amqplib/php-amqplib 做的入队和消费，消费肯定是长连接入队也是都实现了就是现在进程busy别的都OK了