您现在的位置：程式碼之家 >> 編程語言 > >> Java 程式設計 >> Java 相關知識

Java 消息服務 (JMS) 核心基礎與企業級應用實戰

編輯：Java 相關知識

在異構系統集成中，數據交換格式不一、同步阻塞、緊耦合是常見痛點。Java Message Service (JMS) 作為 J2EE 標準消息中間件 API，提供統一的發送/接收接口，支持異步通信、鬆耦合集成，是構建跨平台企業級應用的關鍵基礎設施。

兩大消息模型：點對點 vs 發布/訂閱

JMS 定義兩種消息傳遞模式，開發者需根據業務場景選擇：

特性	Point-to-Point (P2P)	Publish/Subscribe (Pub/Sub)
通信模式	一對一，隊列	一對多，主題
消息保證	每條消息必達，唯一消費者	允許一定丟失，多訂閱者
適用場景	訂單處理、任務分發、需確保處理的業務	廣播通知、股價推送、日誌收集
持久訂閱	不適用	支持：離線訂閱者上線後收到消息

// 創建持久訂閱者
TopicSubscriber subscriber = topicSession.createDurableSubscriber(topic, "subName");

核心對象模型與連接管理

ConnectionFactory：通過 JNDI 查找，創建連接的工廠。分 QueueConnectionFactory (P2P) 和 TopicConnectionFactory (Pub/Sub)。
Connection：代表到消息服務器的活躍連接，需調用 start() 啟動消息投遞，stop() 暫停。
Session：單線程上下文，生產/消費消息的工廠，定義事務性與確認模式。

消息確認機制

非事務 Session 提供三種確認模式：

AUTO_ACKNOWLEDGE：自動確認（默認，最常用）
CLIENT_ACKNOWLEDGE：客戶端手動調用 message.acknowledge()
DUPS_OK_ACKNOWLEDGE：懶惰確認，允許重複，僅用於容忍重複的場景

消息持久化與優先級

持久化：PERSISTENT 消息經存儲轉發，服務器宕機不丟失；NON_PERSISTENT 最多投遞一次，性能更高但可能丟失。
優先級：0-9 級，0-4 普通，5-9 加急。JMS 要求加急消息優先投遞。
生存時間 (TTL)：毫秒制，0 表示永不過期。適用於時效性業務（如實時報價）。

// 發送持久、優先級8、TTL 10秒的消息
topicPublisher.publish(message, DeliveryMode.PERSISTENT, 8, 10000); // Pub/Sub
queueSender.send(message, DeliveryMode.PERSISTENT, 8, 10000);      // P2P

五大標準消息類型

類型	載荷結構	典型用途
StreamMessage	Java 基本類型流	結構化數據流
MapMessage	名值對集合	鍵值對傳遞
TextMessage	String 對象	XML、JSON、純文本
ObjectMessage	序列化 Java 對象	對象傳遞
BytesMessage	原始字節流	二進制數據、自定義編碼

異步消費：MessageListener 與 MDB

實現 javax.jms.MessageListener 接口，重寫 onMessage(Message)，註冊到 MessageConsumer，實現事件驅動消費。

public class OrderListener implements MessageListener {
    public void onMessage(Message msg) {
        TextMessage txt = (TextMessage) msg;
        // 解析 XML、業務處理...
    }
}

消息驅動 Bean (MDB) 是 EJB 容器管理的異步消費者，無 Home/Remote 接口，匿名、不可直接被客戶端調用。部署描述符聲明目標隊列/主題、事務屬性、安全身份。

<message-driven>
  <ejb-name>OrderMDB</ejb-name>
  <ejb-class>com.example.OrderMDB</ejb-class>
  <transaction-type>Container</transaction-type>
  <message-driven-destination>
    <jms-destination-type>javax.jms.Queue</jms-destination-type>
  </message-driven-destination>
</message-driven>