springboot如何实现对RabbitMQ整合-创新互联

本篇文章为大家展示了spring boot如何实现对RabbitMQ整合，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

在浮山等地区，都构建了全面的区域性战略布局，加强发展的系统性、市场前瞻性、产品创新能力，以专注、极致的服务理念，为客户提供网站建设、成都做网站网站设计制作按需网站建设,公司网站建设,企业网站建设,高端网站设计,网络营销推广,外贸网站建设,浮山网站建设费用合理。

1.Fanout Exchange介绍

Fanout Exchange 消息广播的模式，不管路由键或者是路由模式，会把消息发给绑定给它的全部队列，如果配置了routing_key会被忽略。

spring boot如何实现对RabbitMQ整合

如上图所示，即当使用fanout交换器时，他会将消息广播到与该交换器绑定的所有队列上，这有利于你对单条消息做不同的反应。

例如存在以下场景：一个web服务要在用户完善信息时，获得积分奖励，这样你就可以创建两个对列，一个用来处理用户信息的请求，另一个对列获取这条消息是来完成积分奖励的任务。

2.代码示例

1）.Queue配置类

FanoutRabbitConfig.java类：

package com.example.rabbitmqfanout;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class FanoutRabbitConfig {
  //创建队列
  @Bean
  public Queue AMessage() {
    return new Queue("fanout.A");
  }
  //创建队列
  @Bean
  public Queue BMessage() {
    return new Queue("fanout.B");
  }
  //创建队列
  @Bean
  public Queue CMessage() {
    return new Queue("fanout.C");
  }
  //创建Fanout交换器
  @Bean
  FanoutExchange fanoutExchange() {
    return new FanoutExchange("fanoutExchange");
  }
  //将对列绑定到Fanout交换器
  @Bean
  Binding bindingExchangeA(Queue AMessage,FanoutExchange fanoutExchange) {
    return BindingBuilder.bind(AMessage).to(fanoutExchange);
  }
  //将对列绑定到Fanout交换器
  @Bean
  Binding bindingExchangeB(Queue BMessage, FanoutExchange fanoutExchange) {
    return BindingBuilder.bind(BMessage).to(fanoutExchange);
  }
  //将对列绑定到Fanout交换器
  @Bean
  Binding bindingExchangeC(Queue CMessage, FanoutExchange fanoutExchange) {
    return BindingBuilder.bind(CMessage).to(fanoutExchange);
  }  
}

名称栏目：springboot如何实现对RabbitMQ整合-创新互联
分享网址：http://scyanting.com/article/dhcdei.html

springboot如何实现对RabbitMQ整合-创新互联

其他资讯