Rabbitmq---消息隊列

一 . MQ:message queue

　　消息隊列的做用: 　　1 通訊解耦 　　2 高峯限流

原理分析:

一開始,認證系統是強耦合的,A系統傳遞認證系統消息接收計算結果的過程當中

　　1 傳給認證系統

　　2 認證系統計算

　　3 返回計算結果

　　4 讀取A系統邏輯

只要當前計算沒有完成,對於認證系統來說消耗線程資源.並存在強耦合現象

有了消息隊列,每一次鏈接無論是生成消息仍是消費消息,都有各自的邏輯與其餘邏輯無關--通訊解耦

 

　　通訊強耦合的狀況下高峯訪問拒絕,達到了高峯限流的效果

二 . Rabbitmq

　　1 rabbitmq的結構(組件)

 　　　外部: 生產者和消費者

　　　　生產者:對於消息來說,生成消息客戶端是生產者

　　　　消費者:消費消息執行消費後的邏輯的客戶端是消費者

　　客戶端可使用各類其餘技術或者語言 都不是rabbitmq自身的技術

　　2 rabbitmq內部組件

　　connection:基於底層通訊邏輯的長鏈接

　　channel:基於長鏈接建立的;能夠在一次長鏈接的基礎上屢次頻繁的建立和銷燬,佔用資源很是少

　　交換機Exchange   優勢:併發能力高 併發穩定

　　　　客戶端鏈接發送消息,多種狀況都須要併發的發送,若是從客戶端執行併發的發送邏輯,rabbitmq的併發能力就限制在了客戶端

　　　　exchange基於erlang語言開發的(併發,可控制線程)

　　queue:rabbitmq中的隊列,根據不一樣的狀況隊列能夠完成不一樣的工做

　　使用場景:在項目中，將一些無需即時返回且耗時的操做提取出來，進行了異步處理，而這種異步處理的方式大大的節省了服務器的請求響應時間，從而提升了系統的吞吐量。

三 . rabbitmq的五種工做模式

　　1 簡單模式

　　

　　1 )一個生產者將消息交給默認的交換機(AMQP default)

　　2 )交換機獲取消息後交給綁定的這個生產者的隊列(其中關係是經過隊列名稱完成的)

　　3 )監聽當前隊列的消費者獲取消息,執行消費邏輯

　　　　應用場景:短信聊天

　　2 工做模式(資源爭搶)

　　

　　1 )生產者將消息交給交換機

　　2 )交換機交給綁定的隊列

　　3 )隊列由多個消費者同時監聽,只有其中一個能獲取者一條消息,造成了資源的爭搶,誰的資源空閒大,爭搶到的可能越大

　　3 發佈訂閱(publish/fanout)

　　1 )生產者扔給交換機消息
　　2 )交換機根據自身的類型(fanout)將會把全部消息複製同步到全部與其綁定的隊列
　　3 )每一個隊列能夠有一個消費者,接收消息進行消費邏輯

　　4 路由模式(routing/dircet)

　　

　　1 )生產者仍是將消息發送給交換機,消息攜帶具體的路由key(routingKey)

　　2 )交換機類型direct,將接受到消息中的routingKey與之綁定隊列的routingKey比對

　　3 )消費者監聽一個隊列,獲取消息,執行消費邏輯.

　　5 topic主題模式

　　

　　1 )生產端發送消息,消息攜帶具體的路由key
　　2 )交換機的類型topic 
　　3 )隊列綁定交換機不在使用具體的路由key而是一個範圍值

　與路由模式的區別:路由模式中的queue綁定攜帶的具體的key值,路由細化劃分,topic主題模式queue攜帶的key是一個範圍的匹配,某一類消息的獲取

 　　

四 . rabbitmq的安裝及虛擬機和用戶名的建立

　　https://www.cnblogs.com/nanlinghan/p/9960361.html

五 . springboot整合rabbitmq

 　整合思路:1 )配置信息 2 )配置類 (明確初始化對象,初始化一個工廠,就從工廠獲取鏈接;生產端邏輯實現簡單;) 3 )二次封裝

　　springboot
    　　自動配置:掃描同名,下級包
           根據依賴的文件自動配置須要的內容(一旦依賴了jdbc,不配置datasource就報錯)
   　　 springboot就會根據依賴的amqp自動建立鏈接消息隊列的內部connection,封裝一個對外調用的對象rabbitTemplate模板對象;作生產邏輯
    　　利用底層鏈接,實現異步非阻塞監聽,只須要在方法上使用註解,就能夠將監聽內容傳遞給方法的參數;

           歡迎工做一到五年的Java工程師朋友們加入Java架構交流圈：874811168 圈內提供免費的Java架構學習資料（裏面有高可用、高併發、高性能及分佈式、Jvm性能調優、Spring源碼，MyBatis，Netty,Redis,Kafka,Mysql,Zookeeper,Tomcat,Docker,Dubbo,Nginx等多個知識點的架構資料）合理利用本身每一分每一秒的時間來學習提高本身，不要再用"沒有時間「來掩飾本身思想上的懶惰！趁年輕，使勁拼，給將來的本身一個交代！

1 添加依賴
    <starter-amqp>簡化依賴
    　　groupId在maven庫是一個具備結構的文件夾
   　　 artifactId是一整個文件夾
   　　 version是一個文件夾
    　　 org\springframework\boot\spring-boot-starter-amqp
    　<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

2 配置文件(application.properties)

　　    spring.rabbitmq.host=10.9.100.26
   　　 spring.rabbitmq.port=5672
    　　spring.rabbitmq.username=easymall
    　　spring.rabbitmq.password=123456
　　　spring.rabbitmq.virtualHost=/easymall

3 配置文件中聲明對象

　　    內部完成各類鏈接channel等的封裝
   　　 聲明須要的隊列和交換機
   　　配置類中完成這種聲明,而且交換機,隊列的對象由框架維護,什麼時候調用由業務邏輯決定;

1 package com.jt.config;
 2 import org.springframework.amqp.core.Binding;
 3 import org.springframework.amqp.core.BindingBuilder;
 4 import org.springframework.amqp.core.DirectExchange;
 5 import org.springframework.amqp.core.Queue;
 6 import org.springframework.context.annotation.Bean;
 7 import org.springframework.context.annotation.Configuration;
 8 @Configuration
 9 public class RabbitmqConfig {
10     //路由模式作案例
11     //準備2個queue,1個路由交換機
12     //聲明2個隊列
13     @Bean 
14     public Queue queue01(){
15         //org.springframework.amqp.core.
16         return new Queue("springboot-q1", false);
17     }  
18     @Bean 
19     public Queue queue02(){
20         //org.springframework.amqp.core.
21         return new Queue("springboot-q2", false);
22     } 
23     @Bean//聲明交換機
24     public DirectExchange ex(){
25         return new DirectExchange("springboot-ex");
26     }
27     //聲明綁定關係
28     @Bean
29     public Binding bind01(){
30         return BindingBuilder.
31                 bind(queue01()).to(ex()).with("item.add");
32     }
33     @Bean
34     public Binding bind02(){
35         return BindingBuilder.
36                 bind(queue02()).to(ex()).with("item.update");}}

4 編寫生成者代碼

　　    編寫到一個controller中,接收訪問的參數,利用參數做爲消息發送到交換機攜帶路由key

1 package com.jt.controller;
 2 
 3 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 4 import org.springframework.beans.factory.annotation.Autowired;
 5 import org.springframework.stereotype.Controller;
 6 import org.springframework.web.bind.annotation.RequestMapping;
 7 import org.springframework.web.bind.annotation.ResponseBody;
    歡迎工做一到五年的Java工程師朋友們加入Java架構交流圈：874811168
 8 
 9 @Controller
10 public class MsgController {
11     @Autowired
12     private RabbitTemplate rabbit;
13     /*
14      * 接收消息msg
15      */
16     @RequestMapping("msg")
17     @ResponseBody
18     public String sendMsg(String msg,String routingKey){
19         //注入自動配置的rabbitTemplate對象發送消息
20         rabbit.convertAndSend("springboot-ex", routingKey, msg);
21         return "success";
22     }
23 }

5 消費端

　　2個消費者,監聽2個隊列,發送的不一樣路由key會在不一樣的消費端完成消費邏輯

1 package com.jt.component;
 2 
 3 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 4 import org.springframework.stereotype.Component;
 5 @Component
 6 public class ConsumerCon {
 7     //實現消費邏輯,須要完成異步監聽
 8     //監聽註解會綁定隊列的消費者和當前的方法,一旦消費者獲取消息,會把消息內容傳遞給
 9     //自定義的方法參數msg
       //歡迎工做一到五年的Java工程師朋友們加入Java架構交流圈：874811168
10     @RabbitListener(queues="springboot-q1")
11     public void process01(String msg){
12         System.out.println("消費者1接收商品新增:"+msg);
13     }
14     
15     @RabbitListener(queues="springboot-q2")
16     public void process02(String msg){
17         System.out.println("消費者2接收到商品更新:"+msg);
18     }
19 }