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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

ActiveMQArtemis的安裝解壓縮后，需要?jiǎng)?chuàng)建一個(gè)代理服務(wù)器，以Windows10為例，具體步驟如下：（1）以管理員身份運(yùn)行cmd，進(jìn)入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）輸入默認(rèn)用戶名和密碼（admin），并輸入y允許匿名訪問(wèn)。代理服務(wù)器創(chuàng)建成功后，cmd信息顯示如圖9.2所示?！禨pringBoot從入門到實(shí)戰(zhàn)（第2版·微課視頻版）》陳恒

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

ActiveMQArtemis的安裝《SpringBoot從入門到實(shí)戰(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命令啟動(dòng)ApacheActiveMQArtemis服務(wù)（也可以在系統(tǒng)服務(wù)中啟動(dòng)）?！禨pringBoot從入門到實(shí)戰(zhàn)（第2版·微課視頻版）》陳恒

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

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

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

使用JMS的實(shí)現(xiàn)ActiveMQArtemis進(jìn)行兩個(gè)應(yīng)用系統(tǒng)間的點(diǎn)對(duì)點(diǎn)式通信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，該類需要實(shí)現(xiàn)MessageCreator接口，并重寫接口方法createMessage進(jìn)行消息定義。publicMessagecreateMessage(Sessionsession)throwsJMSException{

MapMessagemapm=session.createMapMessage();

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

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

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

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

4．發(fā)送消息在應(yīng)用ch9_1Sender的主類Ch91SenderApplication中，實(shí)現(xiàn)SpringBoot的CommandLineRunner接口，并重寫run方法，用于程序啟動(dòng)后執(zhí)行的代碼。在該run方法中，使用JmsTemplate的send方法向目的地mydestination發(fā)送MyMessage的消息，也相當(dāng)于在消息代理上定義了一個(gè)目的地叫mydestination。使用JMS的實(shí)現(xiàn)ActiveMQArtemis進(jìn)行兩個(gè)應(yīng)用系統(tǒng)間的點(diǎn)對(duì)點(diǎn)式通信《SpringBoot從入門到實(shí)戰(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)聽(tīng)器接收消息在應(yīng)用ch9_1Receive的com.ch.ch9_1receive包中，創(chuàng)建消息監(jiān)聽(tīng)器類ReceiverMsg。在該類中使用@JmsListener注解不停地監(jiān)聽(tīng)目的地mydestination是否有消息發(fā)送過(guò)來(lái)，如果有就獲取消息。使用JMS的實(shí)現(xiàn)ActiveMQArtemis進(jìn)行兩個(gè)應(yīng)用系統(tǒng)間的點(diǎn)對(duì)點(diǎn)式通信《SpringBoot從入門到實(shí)戰(zhàn)（第2版·微課視頻版）》陳恒

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

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

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

從圖9.5可以看出目的地mydestination有一個(gè)消費(fèi)者，正在等待接收消息。此時(shí)，我們啟動(dòng)消息發(fā)送者ch9_1Sender應(yīng)用后，可在接收者ch9_1Receive應(yīng)用的控制臺(tái)上看到有消息打印，如圖9.6所示。我們?cè)偃ニ⑿聢D9.5可看到如圖9.7所示的界面。使用JMS的實(shí)現(xiàn)ActiveMQArtemis進(jìn)行兩個(gè)應(yīng)用系統(tǒng)間的點(diǎn)對(duì)點(diǎn)式通信從圖9.7可以看出目的地mydestination的Messagesadded有數(shù)據(jù)增加（表示發(fā)送成功），同時(shí)Messagesacknowledged有數(shù)據(jù)增加（表示接收成功）?！禨pringBoot從入門到實(shí)戰(zhàn)（第2版·微課視頻版）》陳恒

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

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

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

RabbitMQ安裝運(yùn)行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從入門到實(shí)戰(zhàn)（第2版·微課視頻版）》陳恒

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

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

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

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

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

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

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

使用RabbitMQ實(shí)現(xiàn)發(fā)布/訂閱式異步消息通信（天氣預(yù)報(bào)發(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實(shí)體類?！禨pringBoot從入門到實(shí)戰(zhàn)（第2版·微課視頻版）》陳恒

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

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

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

使用RabbitMQ實(shí)現(xiàn)發(fā)布/訂閱式異步消息通信（天氣預(yù)報(bào)發(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