Spring boot RabbitMQ Listener创建重复队列

Question

我有两个独立的应用程序，一个是生产者，一个是具有交换类型默认（DIRECT）的消费者。

下面是带有死信队列设置的Rabbit MQ Producer的配置。

    @Bean
    Queue dlq() {
        return QueueBuilder.durable(dlqQueueName).build();
    }

    @Bean
    Queue queue() {
        return QueueBuilder
                .durable(queueName)
                .withArgument("x-dead-letter-exchange", dlqExchange)
                .withArgument("x-dead-letter-routing-key", deadLetterRoutingKey)
                .withArgument("x-message-ttl",messageTTL)
                .build();
    }

    @Bean
    Binding binding() {
        return BindingBuilder.bind(queue()).to(exchange()).with(routingkey);
    }

    @Bean
    Binding dlqBinding() {
        return BindingBuilder.bind(dlq()).to(deadLetterExchange()).with(deadLetterRoutingKey);
    }

现在，这里是单独应用程序中Rabbit MQ listener的代码。

  @Component
    public class RabbitMqConsumer implements MessageListener {
 
    
        @RabbitListener(bindings = @QueueBinding(value = @Queue(value = "${queuename}", durable = "true"),
                exchange = @Exchange(value = "exchange"),key = "routingkey"))
        public void message(MyClass o) {
                //save to db
        }
  @Override
    public void onMessage(Message message) {
        // TODO Auto-generated method stub

    }

现在，当我运行消费者服务时，它会创建一个同名的重复队列。如下图所示

Rabbit MQ GUI

我也在消费者中尝试了以下设置，但结果相同

@Bean
    public Queue queue() {
        return QueueBuilder
                .durable(env.getProperty("queue"))
                 .ttl(ttl)
                 .deadLetterExchange(ddlE)
                 .deadLetterRoutingKey(env.getProperty("dle.routingkey"))
                .build();
    }

注意：当我在生产者中添加死信队列设置时，这个问题开始发生，在此设置之前，我在消费者和生产者的配置类中都有这个（下面提到）bean方法，它工作正常。

 @Bean
        public Queue queue() {
            return new Queue(queueName,true);
        }

上面的配置有什么问题吗？为什么它会复制队列，我想不通，只是它们的功能不同

Spring boot版本：<代码>

Answer 1

您尚未共享属性文件！

属性文件中写入的队列名称末尾必须有一些隐藏字符或空格。

匹配消费者和生产者属性文件中的两个名称。其中一个应用程序（使用者或生产者）正在创建带有空格或隐藏字符的队列，作为队列名称的一部分！