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模板對象;做生產邏輯
    　　利用底層連接,實現異步非阻塞監聽,只需要在方法上使用注解,就可以將監聽內容傳遞給方法的參數;

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等的封裝
   　　 聲明需要的隊列和交換機
   　　配置類中完成這種聲明,並且交換機,隊列的對象由框架維護,何時調用由業務邏輯決定;

package com.jt.config;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RabbitmqConfig {
    //路由模式做案例
    //准備2個queue,1個路由交換機
    //聲明2個隊列
    @Bean 
    public Queue queue01(){
        //org.springframework.amqp.core.
        return new Queue("springboot-q1", false);
    }  
    @Bean 
    public Queue queue02(){
        //org.springframework.amqp.core.
        return new Queue("springboot-q2", false);
    } 
    @Bean//聲明交換機
    public DirectExchange ex(){
        return new DirectExchange("springboot-ex");
    }
    //聲明綁定關系
    @Bean
    public Binding bind01(){
        return BindingBuilder.
                bind(queue01()).to(ex()).with("item.add");
    }
    @Bean
    public Binding bind02(){
        return BindingBuilder.
                bind(queue02()).to(ex()).with("item.update");}}

4 編寫生成者代碼

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

package com.jt.controller;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
public class MsgController {
    @Autowired
    private RabbitTemplate rabbit;
    /*
     * 接收消息msg
     */
    @RequestMapping("msg")
    @ResponseBody
    public String sendMsg(String msg,String routingKey){
        //注入自動配置的rabbitTemplate對象發送消息
        rabbit.convertAndSend("springboot-ex", routingKey, msg);
        return "success";
    }
}

5 消費端

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

package com.jt.component;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@Component
public class ConsumerCon {
    //實現消費邏輯,需要完成異步監聽
    //監聽注解會綁定隊列的消費者和當前的方法,一旦消費者獲取消息,會把消息內容傳遞給
    //自定義的方法參數msg
    @RabbitListener(queues="springboot-q1")
    public void process01(String msg){
        System.out.println("消費者1接收商品新增:"+msg);
    }
    
    @RabbitListener(queues="springboot-q2")
    public void process02(String msg){
        System.out.println("消費者2接收到商品更新:"+msg);
    }
}