SpringBoot-RabbitMQ03-交换器【direct】介绍

谁借莪１个温暖的怀抱￠ 2022-01-29 15:43 255阅读 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>

## direct案例 ##

DirectExchange 路由策略是将消息队列绑定到 DirectExchange 上，当 一条消息到达DirectExchange 时会被转发到与该条消息 routing key 相同的 Queue 上，例如消息队列名为“hello-queue ”，则 routingkey 为“hello-queue ”的消息会被该消息队列接收。

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

### 1.创建消费者 ###

创建一个SpringBoot项目作为消费者项目具体如下

#### 1.1创建项目并添加依赖 ####

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

<dependencies>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
    
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
         </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-amqp</artifactId>
         </dependency>
     </dependencies>

#### 1.2参数设置 ####

在application.properties中添加如下配置信息

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=log.direct
    
    #info 队列名称
    mq.config.queue.info=log.info
    #info 路由键
    mq.config.queue.info.routing.key=log.info.routing.key
    
    #error 队列名称
    mq.config.queue.error=log.error
    #error 路由键
    mq.config.queue.error.routing.key=log.error.routing.key

#### 1.3创建消费者工具类型 ####

info信息的消费者

/** * @program: rabbitmq-direct-consumer * @description: 消息接收者 * @author: 波波烤鸭 * @create: 2019-05-22 13:59 * @RabbitListener bindings:绑定队列 * @QueueBinding value:绑定队列的名称 * exchange:配置交换器 * * @Queue value:配置队列名称 * autoDelete:是否是一个可删除的临时队列 * * @Exchange value:为交换器起个名称 * type:指定具体的交换器类型 */
    @Component
    @RabbitListener(
            bindings=@QueueBinding(
                    value=@Queue(value="${mq.config.queue.info}",autoDelete="true"),
                            exchange=@Exchange(value="${mq.config.exchange}",type= ExchangeTypes.DIRECT),
                            key="${mq.config.queue.info.routing.key}"
                    )
            )
    public class InfoReceiver { 
    
        /** * 接收消息的方法。采用消息队列监听机制 * @param msg */
        @RabbitHandler
        public void process(String msg){ 
            System.out.println("Info........receiver: "+msg);
        }
    }

error信息的消费者

/** * * @program: rabbitmq-direct-consumer * @description: 消息接收者 * @author: 波波烤鸭 * @create: 2019-05-22 13:59 * * * @RabbitListener bindings:绑定队列 * @QueueBinding value:绑定队列的名称 * exchange:配置交换器 * * @Queue value:配置队列名称 * autoDelete:是否是一个可删除的临时队列 * * @Exchange value:为交换器起个名称 * type:指定具体的交换器类型 */
    @Component
    @RabbitListener(
            bindings=@QueueBinding(
                    value=@Queue(value="${mq.config.queue.error}",autoDelete="true"),
                            exchange=@Exchange(value="${mq.config.exchange}",type= ExchangeTypes.DIRECT),
                            key="${mq.config.queue.error.routing.key}"
                    )
            )
    public class ErrorReceiver { 
    
        /** * 接收消息的方法。采用消息队列监听机制 * @param msg */
        @RabbitHandler
        public void process(String msg){ 
            System.out.println("Error........receiver: "+msg);
        }
    }

#### 1.4启动 ####

创建启动类，然后启动服务接收消息

@SpringBootApplication
    public class RabbitmqDirectConsumerApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(RabbitmqDirectConsumerApplication.class, args);
        }
    
    }

### 2.创建服务提供者 ###

#### 2.1 创建项目 ####

创建一个SpringBoot项目作为服务提供者。

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

#### 2.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=log.direct
    #info 路由键
    mq.config.queue.info.routing.key=log.info.routing.key
    #error 路由键
    mq.config.queue.error.routing.key=log.error.routing.key

#### 2.3 创建发送消息的工具类 ####

/** * @program: rabbitmq-direct-provider * @description: 消息发送者 * @author: 波波烤鸭 * @create: 2019-05-22 14:06 */
    @Component
    public class Sender { 
    
        @Autowired
        private AmqpTemplate rabbitAmqpTemplate;
    
        @Value("${mq.config.exchange}")
        private String exchange;
    
        @Value("${mq.config.queue.info.routing.key}")
        private String routingKey;
    
        public void send(String msg){ 
            // 发送消息
            this.rabbitAmqpTemplate.convertAndSend(exchange,routingKey,msg);
        }
    
    }

#### 2.4 单元测试 ####

@RunWith(SpringRunner.class)
    @SpringBootTest(classes = RabbitmqDirectProviderApplication.class)
    public class RabbitmqDirectProviderApplicationTests { 
    
        @Autowired
        private Sender sender;
    
        @Test
        public void contextLoads() throws Exception{ 
            while(true){ 
                Thread.sleep(1000);
                sender.send("direct:你好啊 "+new Date());
            }
        }
    }

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

改变发送的 routing-key

![在这里插入图片描述][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/20220129/ff3f489192e14a039f5ab63267768768.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 1]: /images/20220129/a7a6a4eee7044e61b0a3ed14f426d2b8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 2]: /images/20220129/7fd0188d867b4499b0f3346a7d274a54.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 3]: /images/20220129/f9f5979dbed94d0ebee4f1552b898834.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 4]: /images/20220129/1fe19052eb3a4761997f47016e154a66.png