如何使用包bschmitt/Laravel amqp使用RabbitMq Laravel中的消息

Question

我使用Laravel包https://github.com/bschmitt/laravel-amqp/在基于微服务的应用程序中使用RabbitMQ发布和使用消息。我在服务中发布消息，并试图在另一个服务中使用相同的消息。

留档在使用队列中已发布消息的代码上非常清楚。然而，在传统的Laravel队列过程中，我们将描述要在句柄（）方法中执行的过程。并调用php artisan队列： work命令来执行队列。

但是在留档中，使用消息的代码是清晰的，但是如何使用消息并使用工匠命令执行消息是令人困惑的。

我在哪里写代码下面的代码在Laravel应用程序和听它在正式服：

Amqp:：consume（'queue-name'，函数（$message，$resolver）{

变量转储（$message）-

$resolver-

});

目前，我正在使用AppServiceProvider中队列中的消息。php file boot（）方法。但不确定这是否是正确的方法。

Answer 1

使用消息的方法是创建一个自定义artisan命令来侦听队列。我们需要自己运行命令并处理keep-alive，因为包没有提供任何相同的样板。通过在配置中将参数Persistent设置为true，可以使连接保持活动状态。