java - 使用 Rabbit 模板读取交换消息

Question

我以这种方式使用rabbitTemplate:

<bean id="rabbitConnFactory" class="org.springframework.amqp.rabbit.connection.SingleConnectionFactory">
    <constructor-arg>
        <value>localhost</value>
    </constructor-arg>
</bean>

<!-- Spring AMQP Template -->
<bean id="rabbitTemplate" class="org.springframework.amqp.rabbit.core.RabbitTemplate">
    <property name="connectionFactory" ref="rabbitConnFactory" />
</bean>

<!-- Spring AMQP Admin -->
<bean id="rabbitAdmin" class="org.springframework.amqp.rabbit.core.RabbitAdmin">
    <constructor-arg ref="rabbitConnFactory" />
</bean>

发送至交易所:

rabbitTemplate.setExchange(exchange);
rabbitTemplate.convertAndSend(message);

从交换中读取:

rabbitTemplate.setExchange(exchange);
rabbitTemplate.setQueue(exchange);                //?
Object msg = rabbitTemplate.receiveAndConvert();
return msg;

(我需要设置交换运行时，因为我从数据库获取它)

但 msg 始终为 null。

Answer 1

根据documentation如果队列中没有任何内容，则 receiveAndConvert 方法可以返回 null。