如何使用弹簧靴在兔子mq中创建动态队列？

queue java rabbitmq amqp spring

2022-09-03 13:38:06

我需要一些帮助。

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

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

RabbotMQ Config

@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);

    }
}

答案 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);

我在这里找到了解决方案

答案 2

不确定您使用的是哪个版本的RabbitMQ，但是，您的原始代码很接近。这也行得通。

@Bean
Queue fanoutQueue() {
    // empty name, durable false, exclusive false, autoDelete false
    return new Queue("", false, false, true);
}

@Bean
FanoutExchange fanoutExchange() {
    return new FanoutExchange("fanout-exchange", true, false);
}

@Bean
Binding fanoutBinding(Queue fanoutQueue, FanoutExchange fanoutExchange) {
    return BindingBuilder.bind(fanoutQueue).to(fanoutExchange);
}