2019獨角獸企業重金招聘Python工程師標準>>>

一：傳統RPC中間件的缺點：corba、dcom、RMI

同步通訊：客戶發出請求后，必須等待服務對象完成處理并返回結果后才能執行。

客戶和服務對象的生命周期緊密耦合：客戶進程和服務對象進程都必須正常運行；如果由于服務器對象崩潰或者網絡故障導致客戶的請求不可達，客戶會接到異常。

點對點通訊：客戶的一次調用只發送給服務器某個單獨的目標對象。

二：面向消息的中間件Message Oriented Middleware ，MOM介紹

較好的解決了傳統RPC的不足，發送者將消息發送給消息服務器，消息服務器將消息存放在若干隊列中，在合適的時候再將消息轉發給接受者。這種模式下，發送和接受都是異步的，發送者無需等待，二者的生命周期必須相同。發送消息時接受者不一定運行，接受消息的時候發送者也不一定運行。

一對多通訊：對于一個消息可以有多個接受者。

三：JMS簡介

java消息服務(JMS)定義了Java中訪問消息中間件的接口。也就是說JMS知識接口，并沒有給與實現。實現JMS接口的消息中間件稱為JMS Provider，Apatche的ActiveMQ就是屬于MOM中間件的一種，JMS接口的實現。

JMS術語：JMS實現了JMS接口的消息中間件。Provider(Message provider)-生產者；Consumer(Message Comsumer)-消費者；PTP(point to point)-點對點的消息模型；Pub/Sub(Publish/Subscribe)-即發布/訂閱的消息模型；Queue-隊列目標；Topic-主題目標；ConnectionFactory-連接工廠，JMS用它創建連接；Connection-JMS客戶端到JMS Provider的連接點；Destination-消息的目的地；Session-會話，一個發送或接受消息的線程；Message接口-消費者和生產者之間產生的對象。該對象包括三部分組成：1.消息頭(必須)：識別和為消息尋找漏由的操作設置。2.一組消息屬性(可選)：包含額外屬性，支持其他提供者和用戶兼容。可以創建定制的字段和過濾器(消息選擇器)。3.一個消息體(可選)：允許用戶創建5種類型的消息(StreamMessage-java原始值的數據流，MapMessage-名稱-值對，TextMessage-一串字符串對象，ObjectMessage-一個序列化的java對象，BytesMessage-一個未解析的字節數據流)

四：activeMQ介紹

向中間件中添加數據：

public class Sender {public static void main(String[] args) throws Exception {// 1創建連接工廠ConnectionFactory connectionFactory = new org.apache.activemq.ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_USER, ActiveMQConnectionFactory.DEFAULT_PASSWORD,ActiveMQConnectionFactory.DEFAULT_BROKER_URL);// 2通過連接工廠創建連接,并開啟連接Connection connection = connectionFactory.createConnection();connection.start();// 3創建session回話1.是否啟動事物，2.簽收模式Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);// 4創建目標對象在p2p模式中目的地被稱為Queue,pb模式下被稱為TopicDestination destination = session.createQueue("queue1");// 5通過session創建生產者或消費者Messageproducer/MessageConsumerMessageProducer messageProvider = session.createProducer(destination);// 6設置持久化存儲特性，是否持久化存儲或者臨時存儲messageProvider.setDeliveryMode(DeliveryMode.NON_PERSISTENT);// 非持久化// 7創建數據對象，messageProvider發送該數據，供消費者使用for (int i = 0; i < 5; i++) {TextMessage textMessage = session.createTextMessage();textMessage.setText("我是消息內容," + i);// 發送消息messageProvider.send(textMessage);}if (connection != null) {connection.close();}}

獲取中間件中存放的數據：

public class Sender {public static void main(String[] args) throws Exception {// 1創建連接工廠ConnectionFactory connectionFactory = new org.apache.activemq.ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_USER, ActiveMQConnectionFactory.DEFAULT_PASSWORD,ActiveMQConnectionFactory.DEFAULT_BROKER_URL);// 2通過連接工廠創建連接,并開啟連接Connection connection = connectionFactory.createConnection();connection.start();// 3創建session回話1.是否啟動事物，2.簽收模式Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);// 4創建目標對象在p2p模式中目的地被稱為Queue,pb模式下被稱為TopicDestination destination = session.createQueue("queue1");// 5通過session創建生產者或消費者Messageproducer/MessageConsumerMessageProducer messageProvider = session.createProducer(destination);// 6設置持久化存儲特性，是否持久化存儲或者臨時存儲messageProvider.setDeliveryMode(DeliveryMode.NON_PERSISTENT);// 非持久化// 7創建數據對象，messageProvider發送該數據，供消費者使用for (int i = 0; i < 5; i++) {TextMessage textMessage = session.createTextMessage();textMessage.setText("我是消息內容," + i);// 發送消息messageProvider.send(textMessage);}if (connection != null) {connection.close();}}

?

?

轉載于:https://my.oschina.net/2286252881/blog/854005

總結

以上是生活随笔為你收集整理的ActiveMQ(一)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。