原文:
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...