java - 收听 RabbitMQ 队列并获取事件通知

Question

我目前正在开发一个使用 Spring AMQP 和 RabbitMQ 的 Java 应用程序，我想监控我的队列并在某些事件发生时得到通知，比如

• 元素已添加到队列中，
• 元素被移除，或者
• 元素再次进入队列(回滚)。

我如何才能监听此类事件，或者执行此类操作的 RabbitMQ 方式是什么？

Answer 1

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

@Component
public class MyService {

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

}

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

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