RabbitTemplate: 经纪人不支持通过'amq.rabbitmq.reply-to'快速回复。

Question

我正在使用Spring boot（版本2.2.7.RELEASE，因此是spring rabbit 2.2.6）和RabbitMQ 3.3.5。RabbitTemplate 不能用直接回复吗，有什么配置与经纪人吗？

spring rabbit配置。

@Configuration
@EnableRabbit
public class RabbitConfig {

    private String host = "localhost";

    private int port = 5672;

    private String username = "admin";

    private String password = "admin";

    private String exchangeName = "xxx";

    private String queueName = "qqq";


    @Bean
    public ConnectionFactory connectionFactory(){
        CachingConnectionFactory factory = new CachingConnectionFactory();
        factory.setHost(this.host);
        factory.setPort(this.port);
        factory.setUsername(this.username);
        factory.setPassword(this.password);
        return factory;
    }

    @Bean
    public RabbitAdmin rabbitAdmin(ConnectionFactory factory){
        RabbitAdmin admin = new RabbitAdmin(factory);
        return admin;
    }

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

    @Bean
    public Exchange exchange(){
        return new DirectExchange(this.exchangeName, true, false);
    }

    @Bean
    public Binding binding(Queue queue, Exchange exchange){
        return BindingBuilder.bind(queue).to(exchange).with(queue.getName()).noargs();
    }

    @Bean
    public RabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory cFactory){
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(cFactory);
        factory.setMessageConverter(messageConverter());
        factory.setAcknowledgeMode(AcknowledgeMode.AUTO);
        return factory;
    }

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory factory){
        RabbitTemplate rabbitTemplate = new RabbitTemplate(factory);
        rabbitTemplate.setMessageConverter(messageConverter());
        return rabbitTemplate;
    }

    @Bean
    public MessageConverter messageConverter(){
        //return new Converter();

        Jackson2JsonMessageConverter jackson2JsonMessageConverter = new Jackson2JsonMessageConverter();
        jackson2JsonMessageConverter.getJavaTypeMapper().addTrustedPackages("com.mhr.xp.amqp", "java.lang");

        return jackson2JsonMessageConverter;
    }


}

在这里我使用RabbitTemplate:

Object o = rabbitTemplate.convertSendAndReceive("xxx", "qqq", new Dto("ggg"));

我得到以下warnning。

2020-05-15 23:06:59.188 WARN 15681 --- [main] o.s.amqp.rabbit.core.RabbitTemplate : Broker不支持通过'amq.rabbitmq.reply-to'快速回复，将使用临时队列：通道错误；协议方法。#method(reply-code=404, reply-text=NOT_FOUND - no queue 'amq.rabbitmq.reply-to' in vhost '', class-id=50, method-id=10)。

Answer 1

RabbitMQ在3.4版本中加入了直接回复到。

目前的版本是3.8.3。

https:/www.rabbitmq.comdownload.html

https:/docs.spring.iospring-amqpdocs2.2.6.RELEASEreferencehtml#直接回复到

从 3.4.0 版本开始，RabbitMQ 服务器支持直接回复到。这消除了使用固定回复队列的主要原因（以避免需要为每个请求创建临时队列）。从Spring AMQP 1.4.1版本开始，默认使用直接回复到（如果服务器支持）......