1

如何对 php-enqueue 消费者进行健康检查以检查活动性和准备情况?

消费者是一个长期运行的进程,并开始于:

php ./bin/console enqueue:consume --setup-broker

通常当进程停止时,它会被 k8s 或任何其他主管重新启动。但是有些情况下,消费者似乎被卡住了,但流程没有关闭。

队列的问题在于它是异步的。
我可以向队列发送消息,但如何检查消息是否被正确使用?
有什么机制吗?

我目前的想法是让消费者在消费健康检查事件时再次将事件发送到另一个队列。另一个队列由运行状况检查命令使用,如果正确使用,运行状况检查返回 true。
这有意义吗?

4

0 回答 0