拉拉维尔工匠:每一秒都听命令

Question

我有两个微服务与帮助AMQP通信。

我使用 bschmitt/laravel-amqp https://github.com/bschmitt/laravel-amqp。

我创建了一个将消息发布到队列的操作。

然后我创建了工匠命令，它使用队列中的消息。 发布者示例：

Amqp::publish('', $user->toJson() , ['queue' => 'MS:USER:CREATED']);

消费者示例：

Amqp::consume('MS:USER:CREATED', function ($message, $resolver) {
$result = json_decode($message->body);
Log::info($result);
$resolver->acknowledge($message);
$resolver->stopWhenProcessed();
});

我需要每秒收听此命令。为此，我使用主管。

管理引擎配置示例：

[program:laravel-worker]
process_name=%(program_name)s_%(process_num)02d
command=php /home/user/Projects/other/user/artisan ms:user:created
autostart=true
autorestart=true
user=user
numprocs=8
redirect_stderr=true
stdout_logfile=/home/user/Projects/other/user/worker.log

但是主管开始，几秒钟后就下来了。 这是我重新启动主管时的错误输出：

laravel-worker:laravel-worker_02: ERROR (spawn error)
laravel-worker:laravel-worker_06: ERROR (spawn error)
laravel-worker:laravel-worker_00: ERROR (spawn error)
laravel-worker:laravel-worker_01: ERROR (spawn error)
laravel-worker:laravel-worker_04: ERROR (spawn error)
laravel-worker:laravel-worker_07: ERROR (spawn error)
laravel-worker:laravel-worker_03: ERROR (spawn error)
laravel-worker:laravel-worker_05: ERROR (spawn error)

然后为了获得消息，我需要每次重新启动主管。

我也知道另一种方法：

Wrap Amqp：：consume 并使用 crontab 为此。

例：

while (true) {
Amqp::consume('MS:USER:CREATED', function ($message, $resolver) {
//some part of code
});
sleep(1);
}

这种方法有效，但我认为这不是一个好主意。

也许在与主管接触时，我对这种情况的配置错误。

我将不胜感激任何帮助

Answer 1

您可以通过在Supervisor 配置命令的 Bash 中使用 while 循环来做到这一点

[program:ms-user-created]
process_name=%(program_name)s_%(process_num)02d
command=/bin/sh -c "while [ true ]; do (php /home/user/Projects/other/user/artisan ms:user:created &); sleep 1; done"
autostart=true
autorestart=true
numprocs=2
user=www-data
redirect_stderr=true