3

我正在尝试为具有多个队列的 RabbitMQ 测试和基准 spring-amqp，因此我为每个队列创建了兔子模板并使用它来发送消息。消息发送成功，我可以看到在交换中发布的消息，但我在队列中看不到任何内容。我猜这是非常小的设置，但无法弄清楚。

这是我的 applicationContext.xml

<bean id="banchmarkConnectionFactory" class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory">
        <constructor-arg ref="benchmarkAmqpHost"/>
        <property name="username" ref="benchmarkAmqpUser"/>
        <property name="password" ref="benchmarkAmqpPass"/>
        <property name="virtualHost" ref="benchmarkAmqpVHost"/>
        <property name="channelCacheSize" value="10"/>
</bean>
<rabbit:template id="benchmarkAmqpTemplate"
        connection-factory="banchmarkConnectionFactory"
        exchange="my_exchange"
        queue="BenchmarkQueue"
        routing-key="BenchmarkQueue" />
<rabbit:admin connection-factory="banchmarkConnectionFactory"/>
<rabbit:queue name="BenchmarkQueue" auto-delete="true" durable="false" auto-declare="true"/>

这是我的代码，它使用benchmarkAmqpTemplate发布到队列。

public class publishMessage {
    @Autowired
    private RabbitTemplate benchmarkAmqpTemplate;

    protected void publish(String payload) {
        benchmarkAmqpTemplate.setQueue("BenchmarkQueue");
        benchmarkAmqpTemplate.convertAndSend("my_exchange", "BenchmarkQueue", payload);

    }
}

当我使用 HelloWorld示例时，它确实在队列中发布了一条消息，所以想知道我是否做错了什么。 更新 我能够通过direct-exchange在我的上下文 xml 中添加标签来解决这个问题。我的完整 xml 如下所示：

    <beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:rabbit="http://www.springframework.org/schema/rabbit"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsdhttp://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit.xsd">

<bean id="banchmarkConnectionFactory" class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory">
            <constructor-arg ref="benchmarkAmqpHost"/>
            <property name="username" ref="benchmarkAmqpUser"/>
            <property name="password" ref="benchmarkAmqpPass"/>
            <property name="virtualHost" ref="benchmarkAmqpVHost"/>
            <property name="channelCacheSize" value="10"/>
    </bean>
    <rabbit:template id="benchmarkAmqpTemplate"
            connection-factory="banchmarkConnectionFactory"
            exchange="my_exchange"
            queue="BenchmarkQueue"
            routing-key="BenchmarkQueue" />
    <rabbit:admin connection-factory="banchmarkConnectionFactory"/>
    <rabbit:queue name="BenchmarkQueue" auto-delete="true" durable="false" auto-declare="true"/>
    <rabbit:direct-exchange name="my_exchange">
        <rabbit:bindings>
            <rabbit:binding queue="BenchmarkQueue" key="BenchmarkQueue" />
        </rabbit:bindings>
    </rabbit:direct-exchange>
</beans>
4

1 回答 1

8

抱歉，您好像有点误解了 AMQP 协议。

消息被发布到Exchange正确的routingKey. 发布者 ( RabbitTemplate) 根本不需要了解队列。

queue是接收者的一部分，是queue.

两者之间还有一个特征 - binding。queue势在必行Exchange之下routingKey。_ 一个队列可以绑定到具有不同路由键的多个交换。默认情况下，所有队列都绑定到默认交换器 ( "")，routingKeys 等于它们name的 s。

请参阅 RabbitMQ 站点以获取更多信息。

于 2015-05-08T09:45:51.267 回答