RabbitMQ详解

MQ常用概念

快速入门使用

• 推荐查看 <<SpringBoot集成Rabbit使用TopicRabbit指定发送集合>>

目录

• 交换机(Exchange)
  • 1.Direct Exchange 根据route key 直接找到队列
  • 2.Topic Exchange 根据route key 匹配队列
  • 3.Topic Exchange 不处理route key 全网发送，所有绑定的队列都发送

交换机(Exchange)

1. Direct Exchange

Direct Exchange是RabbitMQ默认的交换机模式，也是最简单的模式，根据key全文匹配去寻找队列。

Q1 绑定了一个 binding key 名字为 orange；

Q2 就有 2 个 binding key，名字为black和 green。

当消息中的 路由键 和 这个 binding key 对应上的时候，那么就知道了该消息去到哪一个队列中。

• 代码演示 A

  
      
  
       
  
        
  
         
  
        
        
  
         
      @Bean
         
        
       
  
        
  
         
  
        
        
  
         
      public Queue helloQueue() {
         
        
       
  
        
  
         
  
        
        
  
         
          return new Queue("retry_payment");
         
        
       
  
        
  
         
  
        
        
  
         
  
              }
         
        
       
  
        
  
         
  
        
        
  
         
      @Bean
         
        
       
  
        
  
         
  
        
        
  
         
  
              DirectExchange exchange() {
         
        
       
  
        
  
         
  
        
        
  
         
          return new DirectExchange("retry_payment");
         
        
       
  
        
  
         
  
        
        
  
         
  
              }
         
        
       
  
        
  
         
  
        
        
  
         
      //绑定一个key，当消息匹配到就会放到这个队列中
         
        
       
  
        
  
         
  
        
        
  
         
      @Bean
         
        
       
  
        
  
         
  
        
        
  
         
  
              Binding bindingExchangeMessage(Queue queueMessage, DirectExchange exchange) {
         
        
       
  
        
  
         
  
        
        
  
         
          return BindingBuilder.bind(queueMessage).to(exchange).with("retry_payment");
         
        
       
  
        
  
         
  
        
        
  
         
  
              }
         
        
      
     
  

  
      
  
       
  
        
  
         
  
        
        
  
         
  
          //向指定routingKey中推送，推送到指定队列
         
        
       
  
        
  
         
  
        
        
  
         
  
          rabbitTemplate.convertAndSend(exchange:"retry_payment", routingKey:"retry_payment", message:message);
         
        
      
     
  

• 代码演示 B

  

   

    

     

    
    

     

      Channel channel = connection.createChannel();  
     
    
   

    

     

    
    

     

      channel.exchangeDeclare("retry_payment", "direct");  //声明一个交换机,direct 可以换位topic或者是fannout
     
    
   

    

     

    
    

     

      channel.queueDeclare("retry_payment");  //声明一个队列
     
    
   

    

     

    
    

     

      channel.queueBind("queueName", "exchangeName", "routingKey");  //绑定路由键
     
    
   

    

     

    
    

     
  
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      //需要绑定路由键,发送消息
     
    
   

    

     

    
    

     

      byte[] messageBodyBytes = "hello world".getBytes(); 
     
    
   

    

     

    
    

     

      channel.basicPublish("exchangeName", "routingKey", MessageProperties.PERSISTENT_TEXT_PLAIN, messageBodyBytes);  
     
    
  
 

2.Topic Exchange

Topic Exchange 转发消息主要是根据通配符。 在这种交换机下，队列和交换机的绑定会定义一种路由模式，那么，通配符就要在这种路由模式和路由键之间匹配后交换机才能转发消息。

在这种交换机模式下：

• 路由键必须是一串字符，用句号（.） 隔开，比如说 agreements.us，或者 agreements.eu.stockholm 等。
• 路由模式必须包含一个 星号（*），主要用于匹配路由键指定位置的一个单词，比如说，一个路由模式是这样子：agreements..b.*，那么就只能匹配路由键是这样子的：第一个单词是 agreements，第四个单词是 b。 井号（#）就表示相当于一个或者多个单词，例如一个匹配模式是agreements.eu.berlin.#，那么，以agreements.eu.berlin开头的路由键都是可以的。

具体代码发送的时候还是一样，第一个参数表示交换机，第二个参数表示routing key，第三个参数即消息。如下：

rabbitTemplate.convertAndSend("testTopicExchange","key1.a.c.key2", " this is  RabbitMQ!");

 

topic 和 direct 类似, 只是匹配上支持了"模式", 在"点分"的 routing_key 形式中, 可以使用两个通配符:

• *表示一个词.
• #表示零个或多个词.

3.Fanout Exchange

不处理路由键。你只需要简单的将队列绑定到交换机上。一个发送到交换机的消息都会被转发到与该交换机绑定的所有队列上。很像子网广播，每台子网内的主机都获得了一份复制的消息。Fanout交换机转发消息是最快的。

发送消息，只需要指定交换机，route key 可以为空

给消息设置属性值

  

   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      设置请求头或者编码
     
    
   

    

     

    
    

     

        MessageProperties messageProperties= message.getMessageProperties();
     
    
   

    

     

    
    

     
 
     
    
  
 

文章来源: springlearn.blog.csdn.net，作者：西魏陶渊明，版权归原作者所有，如需转载，请联系作者。

原文链接：springlearn.blog.csdn.net/article/details/102425325