Spring Jms 模塊案例講解
在現(xiàn)代分布式系統(tǒng)中，消息隊列（Message Queue，MQ）扮演著至關重要的角色，它不僅能夠解耦系統(tǒng)各個模塊，還能提升系統(tǒng)的可擴展性和可靠性。JMS（Java Message Service）作為 Java EE 規(guī)范中的一部分，為 Java 應用提供了一套標準的消息通信 API。然而，JMS 原生 API 相對復雜，涉及較多底層操作，而 Spring-JMS 模塊的出現(xiàn)極大地簡化了 JMS 在 Spring 應用中的使用，使得消息的發(fā)送與接收更加直觀且易于維護。
本篇文章將深入解析 Spring-JMS 模塊，介紹其核心功能，并通過 ActiveMQ 作為消息代理，提供一個 基于 XML 配置的完整示例，幫助開發(fā)者快速掌握 Spring-JMS 的使用方式。
1、Spring-Jms 模塊介紹
1.1、Spring-Jms 模塊概述
Spring JMS 模塊，是為了簡化在 Spring 應用中使用消息傳遞服務而設計的模塊。它提供了對 JMS（Java Message Service）規(guī)范的支持，使得開發(fā)者能夠方便地發(fā)送和接收消息，與消息代理（如 ActiveMQ、RabbitMQ 等）進行交互。
Spring JMS 模塊簡化了消息生產(chǎn)者和消費者端點的配置，同時也集成了 Spring 的事務管理機制，使得消息驅(qū)動的架構變得更加易于實現(xiàn)和管理。
1.2、Spring-Jms 模塊依賴
Spring-Tx 模塊的依賴有四個，分別是 Spring-Beans 模塊、Spring-Core 模塊、Spring-Tx 模塊以及 Spring-Messaging 模塊。
其中 Spring Beans 模塊是對 Spring Bean 進行定義，實現(xiàn) IOC 基礎功能的模塊。Spring-Core 是 Spring 中的基礎模塊，它提供了框架運行所必需的核心功能。而 Spring Tx 模塊，是 Spring 中處理事務管理的模塊。
pring Messaging 模塊主要關注于消息的抽象處理，支持多種消息傳遞協(xié)議，并且特別強化了對反應式編程模型的支持，使得開發(fā)者能更方便地創(chuàng)建高性能、可擴展的分布式系統(tǒng)。
1.3、Spring-Jms 模塊作用
Spring-JMS 的核心作用：
- 簡化 JMS API 操作：Spring-JMS 提供了一套模板化工具（如
JmsTemplate），封裝了連接、會話管理等細節(jié)，使得發(fā)送和接收消息更加便捷。 - 支持消息驅(qū)動（Message-Driven）：提供
@JmsListener注解，可以將方法聲明為 JMS 消息監(jiān)聽器，接收消息時自動觸發(fā)。 - 支持事務管理：與 Spring 的事務管理集成，支持聲明式事務，確保消息在消費時的 一致性和可靠性。
- 與 Spring IoC 容器集成：允許使用 Spring 配置管理 JMS 連接工廠（ConnectionFactory）、目的地（Queue/Topic）、消息監(jiān)聽容器等組件。
- 支持消息轉(zhuǎn)換（Message Conversion）：提供
MessageConverter機制，支持將對象自動轉(zhuǎn)換為 JMS 消息格式（如 JSON、XML）。 - 支持多種 JMS 提供者： 可與 ActiveMQ、Artemis、RabbitMQ（通過 JMS 兼容接口） 等消息中間件集成。
2、Spring-JMS 案例
本案例演示如何在 Spring目中使用 Spring-JMS 進行消息傳遞，基于 ActiveMQ 作為消息代理。
2.1、添加依賴
在 pom.xml 中添加 Spring-JMS 和 ActiveMQ 相關依賴：
<dependencies>
<!-- Spring Core 依賴 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.3.39</version>
</dependency>
<!-- Spring JMS 依賴 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>5.3.39</version>
</dependency>
<!-- ActiveMQ 依賴 -->
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-spring-boot-starter</artifactId>
<version>2.0.1</version>
</dependency>
<!-- JMS API 依賴 -->
<dependency>
<groupId>javax.jms</groupId>
<artifactId>javax.jms-api</artifactId>
<version>2.0.1</version>
</dependency>
</dependencies>2.2、 配置 Spring XML（spring-jms-config.xml）
使用 XML 配置文件 定義 連接工廠、JmsTemplate、監(jiān)聽器 等：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:jms="http://www.springframework.org/schema/jms"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms.xsd">
<!-- 配置 ActiveMQ 連接工廠 -->
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<constructor-arg value="tcp://localhost:61616"/> <!-- ActiveMQ 服務器地址 -->
</bean>
<!-- 配置 JMS 模板 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"/>
</bean>
<!-- 配置消息監(jiān)聽器容器 -->
<bean id="jmsListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="destinationName" value="test.queue"/>
<property name="messageListener" ref="messageReceiver"/>
</bean>
<!-- 消息消費者（監(jiān)聽器） -->
<bean id="messageReceiver" class="com.example.jms.MessageReceiver"/>
</beans>2.3、創(chuàng)建消息生產(chǎn)者（Producer）
使用 JmsTemplate 發(fā)送消息：
package com.example.jms;
import org.springframework.jms.core.JmsTemplate;
import javax.jms.Queue;
public class MessageSender {
private JmsTemplate jmsTemplate;
private Queue queue;
// 構造方法注入
public MessageSender(JmsTemplate jmsTemplate, Queue queue) {
this.jmsTemplate = jmsTemplate;
this.queue = queue;
}
public void sendMessage(String message) {
System.out.println("發(fā)送消息：" + message);
jmsTemplate.convertAndSend(queue, message);
}
}2.4、創(chuàng)建消息消費者（Consumer）
實現(xiàn) MessageListener 接口 來監(jiān)聽消息：
package com.example.jms;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
public class MessageReceiver implements MessageListener {
@Override
public void onMessage(Message message) {
try {
if (message instanceof TextMessage) {
String text = ((TextMessage) message).getText();
System.out.println("收到消息：" + text);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}2.5、啟動 Spring 上下文并發(fā)送消息
package com.example.jms;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import javax.jms.Queue;
public class JmsApp {
public static void main(String[] args) {
// 加載 Spring XML 配置
ApplicationContext context = new ClassPathXmlApplicationContext("spring-jms-config.xml");
// 獲取 JmsTemplate 和隊列
JmsTemplate jmsTemplate = (JmsTemplate) context.getBean("jmsTemplate");
Queue queue = (Queue) context.getBean("testQueue");
// 發(fā)送消息
MessageSender sender = new MessageSender(jmsTemplate, queue);
sender.sendMessage("Hello, Spring-JMS!");
System.out.println("消息已發(fā)送！");
}
}2.6、啟動 ActiveMQ
確保 ActiveMQ 已啟動：
activemq start
默認 Web 控制臺地址（可查看隊列消息）：
http://localhost:8161/admin
默認用戶名/密碼：
admin / admin
2.7、運行流程
- 先啟動 ActiveMQ 服務器。
- 運行
JmsApp發(fā)送消息。 MessageReceiver監(jiān)聽到消息并打印到控制臺。
X、后記
在本篇文章中，我們詳細介紹了 Spring-JMS 模塊的作用、依賴結構以及如何在非 Spring Boot 環(huán)境下集成 ActiveMQ，實現(xiàn)消息的發(fā)送與消費。通過使用 Spring-JMS，開發(fā)者可以更加高效地管理消息通信，并與 Spring 生態(tài)系統(tǒng)無縫集成，如結合事務管理、消息轉(zhuǎn)換等特性，進一步提升系統(tǒng)的健壯性和可維護性。
在實際項目中，我們可以基于 Spring-JMS 結合其他 MQ 組件（如 RabbitMQ、Kafka）構建更加高效的異步消息處理系統(tǒng)。如果你對 Spring 消息驅(qū)動架構 感興趣，可以進一步學習 Spring Cloud Stream，以便在微服務架構下實現(xiàn)更加靈活的事件驅(qū)動模式。希望本篇文章能夠幫助你更好地理解 Spring-JMS，并在項目中靈活運用！
到此這篇關于 Spring Jms 模塊案例講解的文章就介紹到這了,更多相關Spring Jms 模塊內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
Sa-Token是一款輕量級Java權限認證框架,它簡化了權限管理,提高了開發(fā)效率,本文通過實例介紹了Sa-Token的基本概念、與其他框架的比較、基本語法和高級用法,并探討了其核心原理和實際應用場景,感興趣的朋友一起看看吧2024-09-09
Lambda表達式是Java8引入的一種簡潔寫法,用于實現(xiàn)函數(shù)式接口,可以簡化匿名函數(shù)的代碼,本文給大家介紹Java8中的Lambda表達式理解與使用示例,感興趣的朋友一起看看吧2024-11-11
這篇文章主要介紹了Springboot中集成Swagger2框架的方法，非常不錯，具有參考借鑒價值,需要的朋友可以參考下2017-12-12
詳解為什么阿里巴巴禁止使用BigDecimal的equals方法做等值比較
這篇文章主要介紹了詳解為什么阿里巴巴禁止使用BigDecimal的equals方法做等值比較，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-09-09
SpringBoot 是一個非常流行的 Java 開發(fā)框架,它提供了一個簡單而強大的方式來創(chuàng)建基于 Servlet 容器的 Web 應用程序,本文將介紹 SpringBoot 中如何使用 Servlet 容器,需要的朋友可以參考下2024-12-12
SpringBoot結合Tess4J實現(xiàn)拍圖識字的示例代碼
圖片中的文字提取已經(jīng)越來越多地應用于數(shù)據(jù)輸入和自動化處理過程,本文主要介紹了SpringBoot結合Tess4J實現(xiàn)拍圖識字的示例代碼,具有一定的參考價值,感興趣的可以了解一下2024-06-06
Pattern類的作用在于編譯正則表達式后創(chuàng)建一個匹配模式,下面這篇文章主要給大家介紹了關于Java正則表達式之Pattern類的相關資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2022-01-01
Java中的反射（Reflection）和使用new關鍵字創(chuàng)建對象是兩種不同的對象創(chuàng)建方式,各有優(yōu)缺點和適用場景,本文小編給大家詳細介紹了Java中的反射與new創(chuàng)建對象,感興趣的小伙伴跟著小編一起來看看吧2024-07-07
Spring security 如何開放 Swagger 訪問權限
這篇文章主要介紹了Spring security 如何開放 Swagger 訪問權限操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-09-09
SpringBoot集成Druid實現(xiàn)監(jiān)控功能的示例代碼
這篇文章主要介紹了SpringBoot集成Druid實現(xiàn)監(jiān)控功能,Druid是阿里巴巴開發(fā)的號稱為監(jiān)控而生的數(shù)據(jù)庫連接池,可以很好的監(jiān)控DB池連接和SQL的執(zhí)行情況,天生就是針對監(jiān)控而生的DB連接池,文中通過代碼示例講解非常詳細,需要的朋友可以參考下2024-02-02