spring-amqp具有不同routingKey的多个队列

Question

我最近开始学习Spring和spring-amqp，所以这个问题可能看起来很基本，所以请原谅我。

ApplicationContext context = new AnnotationConfigApplicationContext(MyQueueConfiguration.class);
AmqpTemplate amqpTemplate  = context.getBean(AmqpTemplate.class);
amqpTemplate.convertAndSend("Hello World!!");

null

ApplicationContext context = new AnnotationConfigApplicationContext(HelloWorldConfiguration.class);

或者有一种方法可以Spring加载所有我的队列配置类，然后只使用如下所示的对象：

    // calling code when I get a POST request
MyQueueConfigurationClass.publishMessage(payload, queueName);

// The implementation code
public boolean publishMessage(String payload, String queueName){

    // Get Bean for the **queueName** somehow
    AmqpTemplate amqpTemplate = context.getBean(AmqpTemplate.class);
    // Use the bean to send the message
    amqpTemplate.convertAndSend(payload);

}

1. 那么，如何在不执行新的AnnotationConfigApplicationContext()每次的情况下获取确切队列的amqpTemplate呢？
2. 每次请求到达我的服务时都做新的AnnotationConfigApplicationContext有什么害处？[我想为每个请求创建一个新对象不是一个好主意]

Answer 1

您不应该每次都创建一个新的上下文；那是非常浪费的。

您可以将多个连接工厂（每个rabbit主机一个）添加到根（或web）上下文中，然后将路由连接工厂与SendConnectionFactorySelectoreXPression一起使用，根据发送的消息选择合适的主机。

或者，您可以简单地为每个服务器连接不同的rabbittemplate。

try {
    SimpleResourceHolder.bind(routingCF, keyForThisMessage);
    rabbitTemplate.convertAndSend(message);
}
finally {
    SimpleResourceHolder.unbind(routingCF);
}

<rabbit:template id="routingTemplate"
    connection-factory="rcf"
    send-connection-factory-selector-expression="messageProperties.headers['cfKey']" />

<bean id="rcf" class="org.springframework.amqp.rabbit.connection.SimpleRoutingConnectionFactory">
    <property name="targetConnectionFactories">
        <map>
            <entry key="foo" value-ref="cf1"/>
            <entry key="bar" value-ref="cf2"/>
        </map>
    </property>
    <property name="defaultTargetConnectionFactory" ref="defaultCF"/>
</bean>

...然后...

this.routingTemplate.convertAndSend("exchange", "routingKey", "xyz", new MessagePostProcessor() {

    @Override
    public Message postProcessMessage(Message message) throws AmqpException {
        message.getMessageProperties().setHeader("cfKey", "foo");
        return message;
    }

});

这里有一个完整的测试用例。