ActiveMQ 基本使用

2021-09-14 04:10:43 字數 1399 閱讀 5898

原文:

activemq介紹

mq是訊息中介軟體,是一種在分布式系統中應用程式藉以傳遞訊息的媒介,常用的有activemq,rabbitmq,kafka。activemq是apache下的開源專案,完全支援jms1.1和j2ee1.4規範的jms provider實現。

特點:1、支援多種語言編寫客戶端

2、對spring的支援,很容易和spring整合

3、支援多種傳輸協議:tcp,ssl,nio,udp等

4、支援ajax

訊息形式:

1、點對點(queue)

2、一對多(topic)

pom中新增依賴:

org.apache.activemq

activemq-all

queue的傳送**:

public void testmqproducerqueue() throws exception
接受的**:

public void testmqconsumerqueue() throws exception catch (jm***ception e) }}

});//8、程式等待接收使用者訊息

system.in.read();

//9、關閉資源

consumer.close();

session.close();

connection.close();

}

topic傳送**:

public void testtopicproducer() throws exception
topic接受**:

public void testtopicconsumer() throws exception catch (jm***ception e) }}

});//8、程式等待接收使用者訊息

system.in.read();

//9、關閉資源

activemq基本介紹及使用

一 jms概念 jms即j a訊息服務 j a message service 應用程式介面,是乙個j a平台中關於面向訊息中介軟體 mom 的api,用於在兩個應用程式之間,或分布式系統中傳送訊息,進行非同步通訊。j a訊息服務是乙個與具體平台無關的api,絕大多數mom提供商都對jms提供支援。...

ActiveMQ使用總結

1 activemq支援訊息過濾設定規則和用法 selector支援下列幾種方式 1 string literals color blue 2 byte strings mybytes 0x0afc23 3 numeric values noltemsinstock 20 4 boolean lit...

activemq 使用總結

2 錯誤 channel was inactive for too long 伺服器訊息較長時間沒有訊息傳送時,客戶端會報這個錯誤 解決方法 在建立連線的uri中加入 wireformat.maxinactivityduration 0 3 採用failover方式連線導致卡死 解決方法 不採用fa...