Spring AMQP惰性队列@RabbitListener并简化直接回复配置

Question

目前，我有以下问题：外部RabbitMQ远程服务器需要我首先发送一条异步回复登录消息，然后发送一条广播队列broadcastQueue。MYUSER\u 123由此远程服务器创建。由此，我想通过@RabbitListener注释来使用，这在代码示例中可以看到。但我有一个错误，你可以看到下面。

在调试过程中，我注意到在我的代码中执行登录之前，容器启动了这个监听器，因此在连接这个广播队列时会遭到拒绝。我在如何使用@Lazy-in-spring-boot延迟加载RabbitMQ队列中找到了这篇文章？但我这边的问题是，autostart不起作用，并且为侦听器启动了容器。我做错了什么？是否可以创建惰性队列。？

另一点是：有没有一种简单的方法可以为RabbitMQ模板进行直接回复配置，我可以在其中指定回复地址？根据Spring amqp代码，似乎只有在您自己不指定回复地址的情况下才能进行直接回复连接。所以我需要创建一个自定义容器。

谢谢你的帮助。

问候斯文

@SpringBootTest
@Slf4j
class DemoAmqpApplicationTests {

    @RabbitListener(queues="broadcastQueue.MYUSER_123",autoStartup = "false")
    public void handleMessage(Object obj) {
        log.info("{}",obj);

    }

    @Test
    void contextLoads() throws InterruptedException {
        Message<User> login = login();
                

    }

配置

@Configuration
@Slf4j
@EnableRabbit
public class RabbitMqConfiguration {

    @Bean
    public RabbitAdmin amqpAdmin(RabbitTemplate rabbitTemplate) {
        return new RabbitAdmin(rabbitTemplate);
    }

    @Bean
    public RabbitTemplate rabbitTemplate(@NonNull CachingConnectionFactory connectionFactory,
                                         @NonNull MessageConverter messageConverter,
                                         @NonNull Queue inquiryResponseQueue,
                                         @NonNull RabbitTemplateConfigurer configurer) {

        RabbitTemplate rabbitTemplate = new RabbitTemplate();
        configurer.configure(rabbitTemplate, connectionFactory);

        String username = connectionFactory.getUsername();

        configurePostReceiveProcessor(rabbitTemplate);

        rabbitTemplate.setMessageConverter(messageConverter);

        configurePrepareSendingProcessor(rabbitTemplate, username, inquiryResponseQueue.getName());

        configureReply(rabbitTemplate, inquiryResponseQueue);

        return rabbitTemplate;
    }

    private void configureReply(RabbitTemplate rabbitTemplate,
                             
                                @NonNull Queue inquiryResponseQueue) {
        rabbitTemplate.setReplyAddress(inquiryResponseQueue.getName());
        rabbitTemplate.setDefaultReceiveQueue(inquiryResponseQueue.getName());
    }

    @Bean
    public SimpleMessageListenerContainer replyListenerContainer(
            @NonNull CachingConnectionFactory connectionFactory,
            @NonNull List<Queue> inquiryResponseQueue,
            @NonNull RabbitTemplate rabbitTemplate,
            @NonNull RabbitAdmin rabbitAdmin) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.setQueues(inquiryResponseQueue.get(0));
        container.setMessageListener(rabbitTemplate);
        return container;
    }

    @Bean
    public Queue privateInquiryResponseQueue(
            @NonNull CachingConnectionFactory connectionFactory) {
        return new Queue(privateInquiryResponseQueueName(connectionFactory.getUsername()),
                false,
                true,
                true);
    }

    

}

错误日志：

    at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.attemptPassiveDeclarations(BlockingQueueConsumer.java:721) ~[spring-rabbit-2.3.10.jar:2.3.10]
    ... 5 common frames omitted
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'broadcastQueue.MYUSER_123' in vhost 'app', class-id=50, method-id=10)

Answer 1

autoStartup工作正常-必须有其他东西启动容器-添加断点以查看是什么启动它-是否在应用程序上下文上调用start（）？这将启动容器。

直接回复是一种特殊的RabbitMQ模式，它使用伪队列进行回复；对于命名回复队列，需要一个侦听器容器。

https://docs.spring.io/spring-amqp/docs/current/reference/html/#direct-回复至