Spring AMQP 中交换器和队列的声明

Question

我正在使用 RabbitMQ 并尝试重构我当前的本机 java 实现以使用 Spring AMQP 抽象。

使用 Spring 库声明交换器、队列及其绑定是通过 AMQPAdmin 接口进行的，但我不确定何时应该进行这种配置。

我有一个使用 Rabbit 来生成消息的 Web 应用程序。另一个使用这些消息的应用程序。令人震惊:)

但是什么时候显示交换/队列的声明发生？

我是否可以将 AMQPAdmin 与 Web 应用程序一起部署，并在生产者和消费者的构造函数中进行交换/队列管理？

这些事情的声明是一次性的，破产者不需要再次了解它们，因此任何代码在后续执行中都将是 NOOP。

我是否需要创建一个单独的应用程序来管理经纪商？

目前的想法或最佳实践是什么？

Answer 1

看起来很少有人使用 Spring 的 AMQP M1 版本，所以我将用我所做的来回答我自己的问题。

在生产者的构造函数中，我声明了交换。然后在 RabbitTemplate 上设置交换。我还将 RabbitTemplate 上的路由键设置为队列名称，但这不是必需的，但它是我将使用的路由。

@Service("userService")
public class UserService {
    private final RabbitTemplate rabbitTemplate;

    @Autowired
    public UserService(final RabbitAdmin rabbitAdmin,
                       final Exchange exchange,
                       final Queue queue,
                       @Qualifier("appRabbitTemplate") final RabbitTemplate rabbitTemplate) {

        this.rabbitTemplate = rabbitTemplate;

        rabbitAdmin.declareExchange(exchange);
        rabbitTemplate.setExchange(exchange.getName());
        rabbitTemplate.setRoutingKey(queue.getName());  
    }


    public void createAccount(final UserAccount userAccount) {
        rabbitTemplate.convertAndSend("Hello message sent at " + new DateTime());
    }
}

在消费者的构造函数中，我声明队列并创建绑定。

public class Consumer implements ChannelAwareMessageListener<Message> {

    public Consumer(final RabbitAdmin rabbitAdmin, final Exchange exchange, final Queue queue) {
        rabbitAdmin.declareQueue(queue);

        rabbitAdmin.declareBinding(BindingBuilder.from(queue).to((DirectExchange) exchange).withQueueName());
    }

    @Override
    public void onMessage(Message message, Channel channel) throws Exception {

        System.out.println(new String(message.getBody()));

        channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);
    }
}

尽管构造函数可能会运行多次，但 RabbitMQ 仅声明交换、队列和绑定一次。

如果您需要这个小示例项目的完整源代码，请询问，我会将其放在某个地方为您提供。