RabbitMQ - 将数据发送给另一个消费者答案

【问题标题】：RabbitMQ - Send Data to another consumerRabbitMQ - 将数据发送给另一个消费者
【发布时间】：2017-04-26 09:31:29
【问题描述】：

我是使用 RabbitMQ 的新手。我想知道是否可以将数据从消费者发送到另一个消费者。

让我解释一下，

我想在我的应用程序中实现Pipeline pattern 以管道类执行。

例子：

// payload = 20 (at the entrance)
$pipeline = (new Pipeline)
    ->pipe(function ($payload) {
        return $payload * 10;
    })
    ->pipe(function ($payload) {
        return $payload + 10;
    })
    ->pipe(function ($payload) {
        return $payload - 5;
    })
;
// payload = 205 (at the end)

我想要做的是在消费者中执行第一个回调，当它完成后将计算数据发送给另一个消费者，依此类推。最终将205 作为$payload 的值。

我只是想知道是否可以使用 RabbitMQ 做到这一点？

非常感谢您的回复，:)

【问题讨论】：

我目前正在阅读this。如果我有答案，我会在这里分享！ :)

标签： php rabbitmq

【解决方案1】：

当然可以。一个 rabbitmq 客户端将同时是消费者和发布者，其中每个“功能”将位于两个独立的线程中，并且每个线程都使用自己的通道。

另外请注意，您永远不会直接将消息发送给消费者，而是发送给将消息（以某些方式）路由到绑定到它的队列的交换。消费者将自己“附加”到队列并从中消费。

【讨论】：