如何使用spring boot在rabbit mq中创建动态队列？

Question

我需要帮助。

我正在开发一个 spring 启动应用程序，我希望我向rabbitMQ 发布消息。我想将它发送到一个队列，该队列在消息本身中命名。这样我想动态创建队列。我只找到了使用“静态”队列的示例。

我已经研究了一些东西，但没有找到任何东西。我是 RabbitMQ 的新手，学习了基本概念。我对春天也很陌生。

RabbotMQ 配置

@Configuration
public class RabbitMQConfig {

    @Value("amq.direct")
    String exchange;

    @Value("queue-name") // Don't want to do this
    String queueName;

    @Value("routing-key") // Or this
    String routingkey;

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

    @Bean
    DirectExchange exchange() {
        return new DirectExchange(exchange);
    }

    @Bean
    Binding binding(Queue queue, DirectExchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with(routingkey);
    }

    @Bean
    public MessageConverter jsonMessageConverter() {
        return new Jackson2JsonMessageConverter();
    }

    @Bean
    public AmqpTemplate template(ConnectionFactory connectionFactory) {
        final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setMessageConverter(jsonMessageConverter());
        return rabbitTemplate;
    }
}

消息发送者

@Service
public class RabbitMQSender {

    @Autowired
    private AmqpTemplate template;

    @Value("amq.direct")
    private String exchange;

    public void send(MessageDTO message) {
        template.convertAndSend(exchange, message);

    }
}

Answer 1

我来了一个解决方案：

您需要在您的配置中创建一个 AmqpAdmin：

@Bean
public AmqpAdmin amqpAdmin() {
    return new RabbitAdmin(connectionFactory);
}

然后将其添加到您的服务中：

@Autowired
private AmqpAdmin admin;

最后，您可以使用它来创建队列和绑定。

Queue queue = new Queue(queueName, durable, false, false);
Binding binding = new Binding(queueName, Binding.DestinationType.QUEUE, EXCHANGE, routingKey, null);
admin.declareQueue(queue);
admin.declareBinding(binding);

我在这里找到了解决方案