在 Spring Boot 中使用路由密钥和交换使用 DirectExchange 消息

Question

我正在尝试使用 退出队列 中的消息，该队列属于 Direct Exchange 类型（在交换和路由密钥的帮助下创建）。我只有 交换名称 和 路由键 而 没有队列名称。有对纯 Java 的支持，但我找不到用于 Spring 启动的地方。

@RabbitListener
    @RabbitHandler
    public void consumeMessage(Object message) {
        LOGGER.debug("Message Consumed.... : {}", message.toString());
    }

如何使用路由键和交换名称而不是队列名称作为@RabbitListener 要求queue 使用消息。

Answer 1

消费者从队列而不是交换中消费。您必须使用路由键将队列绑定到交换器。

编辑

有几种方法可以在代理上自动声明队列。

    @RabbitListener(bindings = 
        @QueueBinding(exchange = @Exchange("myExchange"), 
            key = "myRk", value = @Queue("")))
    public void listen(String in) {
        System.out.println(in);
    }

这将绑定一个匿名队列（自动删除），该队列将在应用程序停止时被删除。

    @RabbitListener(bindings = 
        @QueueBinding(exchange = @Exchange("myExchange"), 
            key = "myRk", value = @Queue("foo")))
    public void listen(String in) {
        System.out.println(in);
    }

将永久队列foo 绑定到带有路由键的交换器。

您也可以简单地为队列、交换和绑定声明#Bean。

见Configuring the broker。