使用Spring Boot启动多个Rabbitmq队列

  • Z时代
  • 2024-01-10
  • 分类：问答

从Spring Boot" title="Spring Boot">Spring Boot教程开始：https :

//spring.io/guides/gs/messaging-

rabbitmq/

他们给出了仅创建1个队列和1个队列的示例，但是，如果我希望能够创建多于1个队列，该怎么办？怎么可能呢？

显然，我不能两次创建相同的bean：

@Bean
Queue queue() {
    return new Queue(queueNameAAA, false);
}
@Bean
Queue queue() {
    return new Queue(queueNameBBB, false);
}

您不能两次创建相同的bean，它将使模棱两可。

回答：

为bean定义工厂方法指定不同的名称。通常，按照约定，您将它们命名为与队列相同的名称，但这不是必需的…

@Bean
Queue queue1() {
    return new Queue(queueNameAAA, false);
}
@Bean
Queue queue2() {
    return new Queue(queueNameBBB, false); 
}

方法名称是bean名称。

在绑定bean中使用队列时，有两种选择：

@Bean
Binding binding1(@Qualifier("queue1") Queue queue, TopicExchange exchange) {
    return BindingBuilder.bind(queue).to(exchange).with(queueNameAAA);
}
@Bean
Binding binding2(@Qualifier("queue2") Queue queue, TopicExchange exchange) {
    return BindingBuilder.bind(queue).to(exchange).with(queueNameBBB);
}

要么

@Bean
Binding binding1(TopicExchange exchange) {
    return BindingBuilder.bind(queue1()).to(exchange).with(queueNameAAA);
}
@Bean
Binding binding2(TopicExchange exchange) {
    return BindingBuilder.bind(queue2()).to(exchange).with(queueNameBBB);
}

甚至更好…

@Bean
Binding binding1(TopicExchange exchange) {
    return BindingBuilder.bind(queue1()).to(exchange).with(queue1().getName());
}
@Bean
Binding binding2(TopicExchange exchange) {
    return BindingBuilder.bind(queue2()).to(exchange).with(queue2().getName());
}

以上是 使用Spring Boot启动多个Rabbitmq队列 的全部内容， 来源链接： utcz.com/qa/412844.html

回到顶部