2019獨(dú)角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

一：傳統(tǒng)RPC中間件的缺點(diǎn)：corba、dcom、RMI

同步通訊：客戶發(fā)出請(qǐng)求后，必須等待服務(wù)對(duì)象完成處理并返回結(jié)果后才能執(zhí)行。

客戶和服務(wù)對(duì)象的生命周期緊密耦合：客戶進(jìn)程和服務(wù)對(duì)象進(jìn)程都必須正常運(yùn)行；如果由于服務(wù)器對(duì)象崩潰或者網(wǎng)絡(luò)故障導(dǎo)致客戶的請(qǐng)求不可達(dá)，客戶會(huì)接到異常。

點(diǎn)對(duì)點(diǎn)通訊：客戶的一次調(diào)用只發(fā)送給服務(wù)器某個(gè)單獨(dú)的目標(biāo)對(duì)象。

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

較好的解決了傳統(tǒng)RPC的不足，發(fā)送者將消息發(fā)送給消息服務(wù)器，消息服務(wù)器將消息存放在若干隊(duì)列中，在合適的時(shí)候再將消息轉(zhuǎn)發(fā)給接受者。這種模式下，發(fā)送和接受都是異步的，發(fā)送者無需等待，二者的生命周期必須相同。發(fā)送消息時(shí)接受者不一定運(yùn)行，接受消息的時(shí)候發(fā)送者也不一定運(yùn)行。

一對(duì)多通訊：對(duì)于一個(gè)消息可以有多個(gè)接受者。

三：JMS簡介

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

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

四：activeMQ介紹

向中間件中添加數(shù)據(jù)：

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

獲取中間件中存放的數(shù)據(jù)：

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

?

?

轉(zhuǎn)載于:https://my.oschina.net/2286252881/blog/854005

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。