Storm使用Spring AMQP从RabbitMq读取消息

Question

我想使用rabbitMq队列中Storm喷口中的消息。

现在，我们使用Spring AMQP异步发送和接收来自RabbitMq的消息。

Spring AMQP提供了从队列读取消息的机制（创建监听器或使用注释@RabbitListner）。

问题是我可以让一个侦听器从队列中读取消息。但是，我如何将此消息发送到Storm群上运行的Storm喷口？

拓扑将启动一个集群，但在我的spout的nextTuple（）方法中，我需要从这个队列中读取消息。这里可以使用Spring AMQP吗？

我有一个配置为从队列中读取消息的侦听器：

@RabbitListener(queues = "queueName")
public void processMessage(QueueMessage message) {

} 

如何将侦听器收到的上述消息发送到运行在集群上的spout。

或者，spout的nextTuple（）方法中如何包含此方法？有可能吗

我在这里使用Java作为一种语言。

Answer 1

您可以使用RabbitTemboard接收或接收AndConversion方法之一按需读取消息（而不是消息驱动）。

默认情况下，如果队列中没有消息，它们将返回null。

编辑：

如果您设置了接收超时（在1.5或更高版本中可用），接收方法将在该时间阻塞（它在内部使用异步消费者并且不轮询）。

但它仍然没有侦听器那么有效，因为每个方法都会创建一个新的消费者；要使用侦听器，您需要使用nextTuple（）中的一些内部阻塞机制（例如，阻塞队列）来等待消息。