监听 RabbitMQ 队列并获取事件通知答案

【问题标题】：Listen to RabbitMQ queue and get notifications on events监听 RabbitMQ 队列并获取事件通知
【发布时间】：2016-03-12 16:36:28
【问题描述】：

我目前正在使用带有 RabbitMQ 的 Spring AMQP 开发一个 Java 应用程序，并希望监视我的队列并在发生某些事件时得到通知，例如

我怎样才能收听这些事件，或者 RabbitMQ 做这些事情的方式是什么？

【问题讨论】：

“元素”是什么意思？ “消息”？
是的，我就是这个意思。
我无法理解在message removed 上获取通知的用例。请您进一步解释一下。
@Shirish 我想创建一个监控应用程序，它显示由于事务回滚，哪些消息进入队列、从队列中取出以及返回队列。因此，我想显示队列的当前状态/消息（例如在 UI 上），并且我想在队列状态发生变化时获取更新/通知。（例如，以便我可以更新 UI）。

【解决方案1】：

从队列异步接收消息是使用带注释的侦听器端点基础设施。简而言之，它允许您将托管 bean 的方法公开为 Rabbit 侦听器端点。

@Component
public class MyService {

    @RabbitListener(queues = "myQueue")
    public void processOrder(String data) {
        ...
    }

}

检查this 每当有消息推送到队列时myQueueprocessOrder 方法就会被触发。

对于您的其他要求，您还可以使用spring events 来监视对队列执行的任何操作。就在对队列执行任何操作之前，将触发相应的事件。

【讨论】：