《 Spring Boot從入門到實戰(zhàn)（第2版·微課視頻版）》 課件 第9章 異步消息

第9章異步消息學(xué)習(xí)目的與要求本章主要講解了企業(yè)級消息代理JMS和AMQP。通過本章的學(xué)習(xí)，理解異步消息通信原理，掌握異步消息通信技術(shù)?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

目錄9.1消息模型9.2企業(yè)級消息代理9.3SpringBoot的支持9.4異步消息通信實例《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

9.1消息模型異步消息主要目的是為了解決跨系統(tǒng)的通信。所謂異步消息即消息發(fā)送者無須等待消息接收者的處理及返回，甚至無須關(guān)心消息是否發(fā)送與接收成功。在異步消息中有兩個極其重要的概念，即消息代理和目的地。當消息發(fā)送者發(fā)送消息后，消息將由消息代理管理，消息代理保證消息傳遞到目的地。異步消息的目的地主要有兩種形式，即隊列和主題。隊列用于點對點式的消息通信，即端到端通信（單接收者）；主題用于發(fā)布/訂閱式的消息通信，即廣播通信（多接收者）?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

9.1.1點對點式在點對點式的消息通信中，消息代理獲得發(fā)送者發(fā)送的消息后，將消息存入一個隊列里，當有消息接收者接收消息時，將從隊列里取出消息傳遞給接收者，這時隊列中清除該消息。在點對點式的消息通信中，確保的是每一條消息只有唯一的發(fā)送者和接收者，但并不能說明只有一個接收者可以從隊列里接收消息。這是因為隊列里有多個消息，點對點式的消息通信只保證每一條消息只有唯一的發(fā)送者和接收者?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

9.1.2發(fā)布/訂閱式多接收者是消息通信中一種更加靈活的方式，而點對點式的消息通信只保證每一條消息只有唯一的接收者。這時我們可以使用發(fā)布/訂閱式的消息通信解決多接收者的問題。和點對點式不同，發(fā)布/訂閱式是消息發(fā)送者將消息發(fā)送到主題，而多個消息接收者監(jiān)聽這個主題。此時的消息發(fā)送者叫做發(fā)布者，接收者叫做訂閱者?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

目錄9.1消息模型9.2企業(yè)級消息代理9.3SpringBoot的支持9.4異步消息通信實例《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

9.2企業(yè)級消息代理異步消息傳遞技術(shù)常用的有：JMS和AMQP。JMS是面向基于Java的企業(yè)應(yīng)用的異步消息代理。AMQP是面向所有應(yīng)用的異步消息代理?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

9.2.1JMSJMS（JavaMessagingService）即Java消息服務(wù)，是Java平臺上有關(guān)面向消息中間件的技術(shù)規(guī)范，它便于消息系統(tǒng)中的Java應(yīng)用程序進行消息交換，并且通過提供標準的產(chǎn)生、發(fā)送、接收消息的接口簡化企業(yè)應(yīng)用的開發(fā)?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

1．JMS元素1）JMS消息代理實現(xiàn)開源的JMS實現(xiàn)有ApacheActiveMQArtemis、JBoss社區(qū)所研發(fā)的HornetQ、TheOpenJMSGroup的OpenJMS等等實現(xiàn)。2）JMS客戶生產(chǎn)或消費基于消息的Java應(yīng)用程序或?qū)ο蟆?）JMS生產(chǎn)者創(chuàng)建并發(fā)送消息的JMS客戶。4）JMS消費者接收消息的JMS客戶。5）JMS消息包括可以在JMS客戶之間傳遞的數(shù)據(jù)對象。6）JMS隊列一個容納那些被發(fā)送的等待閱讀的消息區(qū)域。與隊列名字所暗示的意思不同，消息的接受順序并不一定要與消息的發(fā)送順序相同。一旦一個消息被閱讀，該消息將被從隊列中移走。7）JMS主題一種支持發(fā)送消息給多個訂閱者的機制?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

2．JMS的應(yīng)用接口《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

9.2.2AMQPAMQP（AdvancedMessageQueuingProtocol）即高級消息隊列協(xié)議，是一個提供統(tǒng)一消息服務(wù)的應(yīng)用層標準高級消息隊列協(xié)議，是應(yīng)用層協(xié)議的一個開放標準，為面向消息的中間件設(shè)計?；诖藚f(xié)議的客戶端與消息中間件可傳遞消息，并不受客戶端/中間件的不同產(chǎn)品、不同開發(fā)語言等條件的限制?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

目錄9.1消息模型9.2企業(yè)級消息代理9.3SpringBoot的支持9.4異步消息通信實例《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

9.3.1JMS的自動配置SpringBoot對JMS的自動配置位于org.springframework.boot.autoconfigure.jms包下，在SpringBoot3.0中支持JMS的實現(xiàn)有ActiveMQArtemis（下一代ActiveMQ）。SpringBoot為我們定義了ArtemisConnectionFactoryFactory的bean作為連接，并通過以“spring.artemis”為前綴的屬性配置ActiveMQArtemis的連接屬性，主要包含：spring.artemis.broker-url=tcp://localhost:61616#消息代理路徑spring.artemis.user=spring.artemis.password=spring.artemis.mode=另外，SpringBoot在JmsAutoConfiguration自動配置類中為我們配置了JmsTemplate；并且在JmsAnnotationDrivenConfiguration配置類中，為我們開啟了注解式消息監(jiān)聽的支持，即自動開啟@EnableJms?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

9.3.2AMQP的自動配置SpringBoot對AMQP的自動配置位于org.springframework.boot.autoconfigure.amqp包下，RabbitMQ是AMQP的主要實現(xiàn)。在RabbitAutoConfiguration自動配置類中，為我們配置了連接的RabbitConnectionFactoryBean和RabbitTemplate，并且在RabbitAnnotationDrivenConfiguration配置類中開啟了@EnableRabbit。從RabbitProperties類中，可以看出RabbitMQ的配置可通過以“spring.rabbitmq”為前綴的屬性進行配置，主要包含：spring.rabbitmq.host=localhost#RabbitMQ服務(wù)器地址，默認為localhostspring.rabbitmq.port=5672#RabbitMQ端口，默認為5672spring.rabbitmq.username=guest#默認用戶名spring.rabbitmq.password=guest#默認密碼《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

目錄9.1消息模型9.2企業(yè)級消息代理9.3SpringBoot的支持9.4異步消息通信實例《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

9.4.1JMS實例本節(jié)我們使用JMS的一種實現(xiàn)ActiveMQArtemis講解JMS實例。因此，需要事先安裝ActiveMQArtemis（注意需要安裝Java11+）。讀者可訪問/下載符合自己的ActiveMQArtemis。編寫本書時，作者下載了apache-artemis-2.27.1-bin.zip。該版本的ActiveMQArtemis，解壓縮即可完成安裝?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

ActiveMQArtemis的安裝解壓縮后，需要創(chuàng)建一個代理服務(wù)器，以Windows10為例，具體步驟如下：（1）以管理員身份運行cmd，進入ActiveMQArtemis解壓后的bin目錄，例如執(zhí)行“D:\>cdD:\soft\JavaEE\apache-artemis-2.27.1\bin”。（2）執(zhí)行“artemis.cmdcreate代理所在目錄”命令，例如執(zhí)行“D:\soft\JavaEE\apache-artemis-2.27.1\bin>artemis.cmdcreateD:\soft\ActiveMQArtemis”。（3）輸入默認用戶名和密碼（admin），并輸入y允許匿名訪問。代理服務(wù)器創(chuàng)建成功后，cmd信息顯示如圖9.2所示?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

ActiveMQArtemis的安裝《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

ActiveMQArtemis的安裝代理服務(wù)器創(chuàng)建成功后，繼續(xù)執(zhí)行“D:\soft\ActiveMQArtemis\bin\artemis-service.exe”install命令安裝ApacheActiveMQArtemis服務(wù)，最后執(zhí)行"D:\soft\ActiveMQArtemis\bin\artemis-service.exe"start命令啟動ApacheActiveMQArtemis服務(wù)（也可以在系統(tǒng)服務(wù)中啟動）?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

ActiveMQArtemis的安裝然后，通過“http://localhost:8161”運行ActiveMQArtemis的管理界面，管理員賬號和密碼默認為admin/admin，如圖9.4所示?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

使用JMS的實現(xiàn)ActiveMQArtemis進行兩個應(yīng)用系統(tǒng)間的點對點式通信1．創(chuàng)建基于SpringforApacheActiveMQArtemis的SpringBoot應(yīng)用ch9_1Sender（消息發(fā)送者）2．配置ActiveMQArtemis的消息代理地址在應(yīng)用ch9_1Sender的配置文件perties中，配置ActiveMQArtemis的消息代理地址：spring.artemis.broker-url=tcp://localhost:616163．定義消息在應(yīng)用ch9_1Sender的com.ch.ch9_1sender包下，創(chuàng)建消息定義類MyMessage，該類需要實現(xiàn)MessageCreator接口，并重寫接口方法createMessage進行消息定義。publicMessagecreateMessage(Sessionsession)throwsJMSException{

MapMessagemapm=session.createMapMessage();

ArrayList<String>arrayList=newArrayList<String>(); arrayList.add("陳恒1"); arrayList.add("陳恒2"); mapm.setString("mesg1",arrayList.toString());//只能存Java的基本對象

mapm.setString("mesg2","測試消息2");

returnmapm;}《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

4．發(fā)送消息在應(yīng)用ch9_1Sender的主類Ch91SenderApplication中，實現(xiàn)SpringBoot的CommandLineRunner接口，并重寫run方法，用于程序啟動后執(zhí)行的代碼。在該run方法中，使用JmsTemplate的send方法向目的地mydestination發(fā)送MyMessage的消息，也相當于在消息代理上定義了一個目的地叫mydestination。使用JMS的實現(xiàn)ActiveMQArtemis進行兩個應(yīng)用系統(tǒng)間的點對點式通信《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

5．創(chuàng)建消息接收者按照步驟1創(chuàng)建SpringBoot應(yīng)用ch9_1Receive，該應(yīng)用作為消息接收者。并按照步驟2配置ch9_1Receive的ActiveMQArtemis的消息代理地址。6．定義消息監(jiān)聽器接收消息在應(yīng)用ch9_1Receive的com.ch.ch9_1receive包中，創(chuàng)建消息監(jiān)聽器類ReceiverMsg。在該類中使用@JmsListener注解不停地監(jiān)聽目的地mydestination是否有消息發(fā)送過來，如果有就獲取消息。使用JMS的實現(xiàn)ActiveMQArtemis進行兩個應(yīng)用系統(tǒng)間的點對點式通信《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

7．運行測試我們先啟動消息接收者ch9_1Receive應(yīng)用，啟動ch9_1Receive應(yīng)用后，單擊圖9.4中的JMX，可看到如圖9.5所示的界面。使用JMS的實現(xiàn)ActiveMQArtemis進行兩個應(yīng)用系統(tǒng)間的點對點式通信《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

從圖9.5可以看出目的地mydestination有一個消費者，正在等待接收消息。此時，我們啟動消息發(fā)送者ch9_1Sender應(yīng)用后，可在接收者ch9_1Receive應(yīng)用的控制臺上看到有消息打印，如圖9.6所示。我們再去刷新圖9.5可看到如圖9.7所示的界面。使用JMS的實現(xiàn)ActiveMQArtemis進行兩個應(yīng)用系統(tǒng)間的點對點式通信從圖9.7可以看出目的地mydestination的Messagesadded有數(shù)據(jù)增加（表示發(fā)送成功），同時Messagesacknowledged有數(shù)據(jù)增加（表示接收成功）。《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

9.4.2AMQP實例本節(jié)我們使用AMQP的主要實現(xiàn)RabbitMQ講解AMQP實例，因此需要事先安裝RabbitMQ。又因為RabbitMQ是基于erlang語言開發(fā)的，所以安裝RabbitMQ之前，先下載安裝erlang。erlang語言的下載地址為/downloads；RabbitMQ的下載地址為/download.html。編寫本書時，下載的erlang語言版本是“otp_win64_25.2.2.exe”，下載的RabbitMQ版本是“rabbitmq-server-3.11.8.exe”。運行erlang語言安裝包“otp_win64_25.2.2.exe”，一直next即可完成安裝erlang。安裝erlang后需要配置環(huán)境變量ERLANG_HOME以及path中新增%ERLANG_HOME%\bin。《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

RabbitMQ安裝運行RabbitMQ安裝包“rabbitmq-server-3.11.8.exe”，一直next即可完成安裝RabbitMQ。安裝RabbitMQ后需要配置環(huán)境變量RABBITMQ_SERVER=安裝目錄\RabbitMQServer\rabbitmq_server-3.11.8以及path中新增%RABBITMQ_SERVER%\sbin《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

RabbitMQ安裝在cmd命令行窗口，進入到RabbitMQ的sbin目錄下，運行rabbitmq-plugins.batenablerabbitmq_management命令，打開RabbitMQ的管理組件。《SpringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

RabbitMQ安裝以管理員方式打開cmd命令，運行netstartRabbitMQ命令，提示RabbitMQ服務(wù)已經(jīng)啟動?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

RabbitMQ安裝在瀏覽器地址欄中，輸入“http://localhost:15672”，賬號和密碼默認為guest/guest，進入RabbitMQ的管理界面（進不去界面時，請重啟計算機服務(wù)中的RabbitMQ）?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

使用RabbitMQ實現(xiàn)發(fā)布/訂閱式異步消息通信（天氣預(yù)報發(fā)布與接收）1．創(chuàng)建發(fā)布者應(yīng)用ch9_2Sender創(chuàng)建發(fā)布者應(yīng)用ch9_2Sender，包括以下步驟。1）創(chuàng)建基于Lombok、SpringforRabbitMQ的SpringBoot應(yīng)用ch9_2Sender。2）在ch9_2Sender應(yīng)用的pom.xml中添加spring-boot-starter-json依賴，代碼如下：<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-json</artifactId></dependency>3）在ch9_2Sender應(yīng)用中創(chuàng)建名為com.ch.ch9_2sender.entity的包，并在該包中創(chuàng)建Weather實體類?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

使用RabbitMQ實現(xiàn)發(fā)布/訂閱式異步消息通信（天氣預(yù)報發(fā)布與接收）4）在應(yīng)用ch9_2Sender的主類Ch92SenderApplication中，實現(xiàn)SpringBoot的CommandLineRunner接口，并重寫run方法，用于程序啟動后執(zhí)行的代碼。在該run方法中，使用RabbitTemplate的convertAndSend方法將特定的路由“weather.message”發(fā)送Weather消息對象到指定的交換機“weather-exchange”。在發(fā)布消息前，需要使用ObjectMapper將Weather對象轉(zhuǎn)換成byte[]類型的JSON數(shù)據(jù)?！禨pringBoot從入門到實戰(zhàn)（第2版·微課視頻版）》陳恒

主編，清華大學(xué)出版社，2024

使用RabbitMQ實現(xiàn)發(fā)布/訂閱式異步消息通信（天氣預(yù)報發(fā)布與接收）2．創(chuàng)建訂閱者應(yīng)用ch9_2Receiver-1創(chuàng)建訂閱者應(yīng)用ch9_2Receiver-1，包括以下步驟。1）創(chuàng)建基于Lombok、SpringforRabbitMQ的SpringBoot應(yīng)用ch9_2Receiver-1。2）在ch9_2Receiver-1應(yīng)用的pom.xml中添加spring-boot-starter-js