JMS是Java平臺的消息通信API標(biāo)準(zhǔn)，支持點(diǎn)對點(diǎn)和發(fā)布/訂閱模型，ActiveMQ是其實(shí)現(xiàn)的消息中間件；1. 啟動ActiveMQ服務(wù)並監(jiān)聽默認(rèn)端口；2. 在Maven項(xiàng)目中添加activemq-client依賴；3. 創(chuàng)建生產(chǎn)者通過ConnectionFactory發(fā)送消息到隊(duì)列；4. 創(chuàng)建消費(fèi)者通過MessageListener異步接收消息；該組合實(shí)現(xiàn)系統(tǒng)解耦、流量削峰、可靠傳遞和異步處理，適用於傳統(tǒng)Java企業(yè)應(yīng)用，儘管有更現(xiàn)代替代方案，但仍具學(xué)習(xí)與使用價(jià)值。

在現(xiàn)代分佈式系統(tǒng)中，異步通信是提升系統(tǒng)解耦、可擴(kuò)展性和響應(yīng)能力的關(guān)鍵手段。 Java Message Service（JMS）結(jié)合ActiveMQ 是實(shí)現(xiàn)異步消息傳遞的經(jīng)典組合，尤其適用於企業(yè)級Java 應(yīng)用。

什麼是JMS 和ActiveMQ？

JMS 是Java 平臺中用於發(fā)送和接收消息的API 標(biāo)準(zhǔn)，支持兩種消息模型：

• 點(diǎn)對點(diǎn)（Queue） ：消息被發(fā)送到隊(duì)列，一個消費(fèi)者處理一條消息。
• 發(fā)布/訂閱（Topic） ：消息發(fā)佈到主題，多個訂閱者可以接收相同的消息。

ActiveMQ 是一個開源的、基於JMS 規(guī)範(fàn)的消息中間件（消息代理），由Apache 開發(fā)。它支持多種協(xié)議（如OpenWire、STOMP、MQTT），並能跨平臺運(yùn)行，非常適合用於構(gòu)建松耦合的異步系統(tǒng)。

如何使用JMS ActiveMQ 實(shí)現(xiàn)異步通信？

要使用JMS 與ActiveMQ 進(jìn)行異步通信，通常包括以下幾個步驟：

1. 啟動ActiveMQ 服務(wù)

首先，從Apache ActiveMQ 官網(wǎng)下載並啟動服務(wù)：

 bin/activemq start

默認(rèn)情況下，ActiveMQ 監(jiān)聽tcp://localhost:61616 ，並提供Web 控制臺http://localhost:8161 。

2. 添加Maven 依賴

在你的Java 項(xiàng)目中（如使用Maven），添加以下依賴：

 <dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-client</artifactId>
    <version>5.17.3</version>
</dependency>

3. 創(chuàng)建消息生產(chǎn)者（Producer）

生產(chǎn)者將消息發(fā)送到隊(duì)列或主題：

 import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;

public class MessageProducer {
    private static final String BROKER_URL = "tcp://localhost:61616";
    private static final String QUEUE_NAME = "example.queue";

    public static void main(String[] args) throws JMSException {
        ConnectionFactory factory = new ActiveMQConnectionFactory(BROKER_URL);
        Connection connection = factory.createConnection();
        connection.start();

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue(QUEUE_NAME);
        MessageProducer producer = session.createProducer(destination);

        TextMessage message = session.createTextMessage("Hello from JMS Producer!");
        producer.send(message);
        System.out.println("Sent message: " message.getText());

        producer.close();
        session.close();
        connection.close();
    }
}

4. 創(chuàng)建消息消費(fèi)者（Consumer）

消費(fèi)者異步接收消息，通常使用MessageListener實(shí)現(xiàn)：

 import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;

public class MessageConsumer {
    public static void main(String[] args) throws JMSException {
        ConnectionFactory factory = new ActiveMQConnectionFactory(BROKER_URL);
        Connection connection = factory.createConnection();
        connection.start();

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue(QUEUE_NAME);
        MessageConsumer consumer = session.createConsumer(destination);

        consumer.setMessageListener(new MessageListener() {
            @Override
            public void onMessage(Message message) {
                if (message instanceof TextMessage) {
                    try {
                        System.out.println("Received: " ((TextMessage) message).getText());
                    } catch (JMSException e) {
                        e.printStackTrace();
                    }
                }
            }
        });

        // 保持程序運(yùn)行，等待消息（實(shí)際應(yīng)用中可能用更優(yōu)雅的方式）
        System.out.println("Waiting for messages...");
    }
}

注意：消費(fèi)者使用setMessageListener後，消息處理是異步的，不會阻塞主線程。

使用場景與優(yōu)勢

• 系統(tǒng)解耦：生產(chǎn)者無需知道消費(fèi)者的存在。
• 流量削峰：在高並發(fā)場景下，消息隊(duì)列可緩衝請求。
• 可靠傳遞：ActiveMQ 支持持久化消息，確保消息不丟失。
• 異步處理：如發(fā)送郵件、日誌處理等耗時操作可放入隊(duì)列異步執(zhí)行。

注意事項(xiàng)

• 連接管理：生產(chǎn)環(huán)境建議使用連接池（如PooledConnectionFactory ）。
• 事務(wù)與確認(rèn)模式：根據(jù)可靠性需求選擇Session.SESSION_TRANSACTED或手動確認(rèn)。
• 異常處理：網(wǎng)絡(luò)中斷或消費(fèi)者崩潰時，需合理配置重連和重試機(jī)制。
• 持久化訂閱：對於Topic 模型，若消費(fèi)者離線，可通過持久訂閱接收錯過的消息。

基本上就這些。 JMS ActiveMQ 雖然不是最新的技術(shù)（如今有Kafka、RabbitMQ 等更現(xiàn)代的選擇），但在傳統(tǒng)Java EE 或Spring 項(xiàng)目中仍廣泛使用，尤其適合需要標(biāo)準(zhǔn)JMS 支持的場景。掌握它，對理解消息中間件原理非常有幫助。

以上是java消息服務(wù)（JMS）帶有ActiveMQ用於異步通信的詳細(xì)內(nèi)容。更多資訊請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！