SpringBoot-RabbitMQ05-交换器【fanout】介绍

迈不过友情╰ 2022-01-27 22:11 209阅读 0赞

# 交换器介绍 #

RabbitMQ中有三种主要的交互器分别如下

<table> 
 <thead> 
  <tr> 
   <th>交换器</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>direct</td> 
   <td align="left">发布与订阅 完全匹配</td> 
  </tr> 
  <tr> 
   <td>fanout</td> 
   <td align="left">广播</td> 
  </tr> 
  <tr> 
   <td>topic</td> 
   <td align="left">主体，规则匹配</td> 
  </tr> 
 </tbody> 
</table>

# Fanout #

FanoutExchange 的数据交换策略是把所有到达 FanoutExchang 的消息转发给所有与它绑定的Queue ，在这种策略中， routingkey 将不起任何作用.

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 1]

## 1.创建消费者 ##

**项目结构**

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 2]

**配置文件**

spring.application.name=springcloud-mq
    spring.rabbitmq.host=192.168.88.150
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=dpb
    spring.rabbitmq.password=123
    
    mq.config.exchange=order.fanout
    #短信服务队列名称
    mq.config.queue.sms=order.sms
    #push 服务队列名称
    mq.config.queue.push=order.push

**两个消费者**

@Component
    @RabbitListener(
    bindings=@QueueBinding(
            value=@Queue(value="${mq.config.queue.sms}",autoDelete="true"),
                    exchange=@Exchange(value="${mq.config.exchange}",type= ExchangeTypes.FANOUT)
            )
    )
    public class SmsReciver { 
        /** * 接收消息的方法。采用消息队列监听机制 * @param msg */
        @RabbitHandler
        public void process(String msg){ 
             System.out.println("Sms........receiver: "+msg);
        }
    }

@Component
    @RabbitListener(
    bindings=@QueueBinding(
            value=@Queue(value="${mq.config.queue.push}",autoDelete="true"),
                    exchange=@Exchange(value="${mq.config.exchange}",type= ExchangeTypes.FANOUT)
            )
    )
    public class PushReciver { 
        /** * 接收消息的方法。采用消息队列监听机制 * @param msg */
        @RabbitHandler
        public void process(String msg){ 
             System.out.println("Push........receiver: "+msg);
        }
    }

启动后等待接收消息即可~

## 2.创建订单服务 ##

**项目结构**

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 3]

**配置文件**

**服务提供者**

/** * @program: rabbitmq-direct-provider * @description: 发送者 * @author: 波波烤鸭 * @create: 2019-05-22 15:51 */
    @Component
    public class Sender { 
        @Autowired
        private AmqpTemplate rabbitAmqpTemplate;
        //exchange 交换器名称
        @Value("${mq.config.exchange}")
        private String exchange;
        /* * 发送消息的方法 */
        public void send(String msg){ 
            //向消息队列发送消息
            //参数一：交换器名称。
            //参数二：路由键
            //参数三：消息
            this.rabbitAmqpTemplate.convertAndSend(this.exchange,"", msg);
        }
    }

**单元测试**

@RunWith(SpringRunner.class)
    @SpringBootTest(classes = RabbitmqDirectProviderApplication.class)
    public class RabbitmqDirectProviderApplicationTests { 
    
        @Autowired
        private Sender sender;
    
        @Test
        public void contextLoads() throws Exception{ 
            sender.send("hello .... ");
        }
    }

启动后查看消费者的控制台

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 4]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70]: /images/20220128/5804969562cc49a780740485cb96f9b6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 1]: /images/20220128/3194e484eb0c4efd855fa020bf23f0b1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 2]: /images/20220128/47c6f953b5704888bcf9231a00d37f48.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 3]: /images/20220128/f2ae8683a2184f1287c07c261653653e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 4]: /images/20220128/bb21471364ed49baa5b935061f7e1a1b.png