資訊專欄INFORMATION COLUMN
摘要：一隊列模式特點客戶端包括生產(chǎn)者和消費者隊列中的消息只能被一個消費者消費消費者可以隨時消費隊列中的消息二創(chuàng)建過程創(chuàng)建連接創(chuàng)建會話通過來創(chuàng)建其它的將生產(chǎn)者和消費者都會指向目標生產(chǎn)者向目標發(fā)送消息消費者設(shè)置監(jiān)聽器，監(jiān)聽消息。
前言
此處的代碼只是簡化理解，實際項目會結(jié)合Spring使用。
一、隊列模式特點客戶端包括生產(chǎn)者和消費者
隊列中的消息只能被一個消費者消費
消費者可以隨時消費隊列中的消息
二、創(chuàng)建過程1.創(chuàng)建連接Connection
2.創(chuàng)建會話Session
3.通過Session來創(chuàng)建其它的（MessageProducer、MessageConsumer、Destination、TextMessage）
4.將生產(chǎn)者 MessageProducer 和消費者 MessageConsumer 都會指向目標 Destination
5.生產(chǎn)者向目標發(fā)送TextMessage消息send()
6.消費者設(shè)置監(jiān)聽器，監(jiān)聽消息。
2. 生產(chǎn)者 AppProducer.java4.0.0 com.jms jms-test 1.0-SNAPSHOT org.apache.activemq activemq-all 5.9.0
public class AppProducer {
private static final String url = "tcp://127.0.0.1:61616";
private static final String queueName = "queue-test";
public static void main(String[] args) throws JMSException {
//1.創(chuàng)建ConnectionFactory
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
//2.創(chuàng)建Connection
Connection connection = connectionFactory.createConnection();
//3.啟動連接
connection.start();
//4.創(chuàng)建會話
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//5.創(chuàng)建一個目標
Destination destination = session.createQueue(queueName);
//6.創(chuàng)建一個生產(chǎn)者
MessageProducer producer = session.createProducer(destination);
for (int i = 0; i < 10; i++) {
//7.創(chuàng)建消息
TextMessage textMessage = session.createTextMessage("test" + i);
//8.發(fā)布消息
producer.send(textMessage);
System.out.println("發(fā)送消息"+textMessage.getText());
}
//9.關(guān)閉連接
connection.close();
}
}
3. 消費者 AppConsumer.java
消費者的連接Connection是不能關(guān)閉的，因為消息的接收是異步的，會導致消息不能被消費。
public class AppConsumer {
private static final String url = "tcp://127.0.0.1:61616";
private static final String queueName = "queue-test";
public static void main(String[] args) throws JMSException {
//1. 創(chuàng)建ConnectionFactory
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
//2. 創(chuàng)建Connection
Connection connection = connectionFactory.createConnection();
//3. 啟動連接
connection.start();
//4. 創(chuàng)建會話
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//5. 創(chuàng)建一個目標
Destination destination = session.createQueue(queueName);
//6. 創(chuàng)建一個消費者
MessageConsumer consumer = session.createConsumer(destination);
//7. 創(chuàng)建一個監(jiān)聽器
consumer.setMessageListener(new MessageListener() {
public void onMessage(Message message) {
try {
System.out.println("接收消息 = [" + ((TextMessage) message).getText() + "]");
} catch (JMSException e) {
e.printStackTrace();
}
}
});
//8.關(guān)閉連接（消費者的連接不允許關(guān)閉的，因為消息的接收是異步的，會導致消息不能被消費）
//connection.close();
}
}
四、運行查看
1. 運行生產(chǎn)者 AppProducer
運行AppProducer.java后會發(fā)現(xiàn)隊列中添加了10條消息，如下圖：
2. 開啟消費者 AppConsumer運行AppConsumer.java后會發(fā)現(xiàn)隊列中的10條消息被消費了，如下圖：
3.開啟兩個消費者后，運行生產(chǎn)者會發(fā)現(xiàn)生產(chǎn)者發(fā)送的10個消息，被兩個消費者平分了。
AppConsumer1
接收消息 = [test1] 接收消息 = [test3] 接收消息 = [test5] 接收消息 = [test7] 接收消息 = [test9]
AppConsumer2
接收消息 = [test0] 接收消息 = [test2] 接收消息 = [test4] 接收消息 = [test6] 接收消息 = [test8]五、隊列模式和主題模式的區(qū)別
是否需要提前訂閱
隊列模式：消費者不需要提前訂閱也可以消費消息
主題模式：只有提前進行訂閱的消費者才能成功消費消息
多個消費者如何分配消息
隊列模式：只能平均消費消息，被別的消費者消費的消息不能重復被其他的消費者消費
主題模式：每個訂閱者都可以消費主題模式中的每一條消息
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://www.ezyhdfw.cn/yun/69209.html
摘要：時間年月日星期六說明本文部分內(nèi)容均來自慕課網(wǎng)。這個時候，可以啟動多臺積分系統(tǒng)，來同時消費這個消息中間件里面的登錄消息，達到橫向擴展的作用。 時間：2017年07月22日星期六說明：本文部分內(nèi)容均來自慕課網(wǎng)。@慕課網(wǎng)：http://www.imooc.com教學源碼：無學習源碼：https://github.com/zccodere/s... 第一章：課程介紹 1-1 課程安排 Java...
摘要：學習消息隊列的使用之前，我們先來搞清。是操作消息的接口。消息生產(chǎn)者由創(chuàng)建，并用于將消息發(fā)送到。接收消息打印結(jié)果這是接收到的消息消費者啟動。。。。 通過上一篇文章 《消息隊列深入解析》，我們已經(jīng)消息隊列是什么、使用消息隊列的好處以及常見消息隊列的簡單介紹。 這一篇文章，主要帶大家詳細了解一下消息隊列ActiveMQ的使用。 學習消息隊列ActiveMQ的使用之前，我們先來搞清JMS。 J...
摘要：中間件的分類基于遠程過程調(diào)用的中間件?；趯ο笳埱蟠淼闹虚g件。消息傳遞指的是程序之間通過在消息中發(fā)送數(shù)據(jù)進行通信，而不是通過直接調(diào)用彼此來通信，直接調(diào)用通常是用于諸如遠程過程調(diào)用的技術(shù)。 一.中間件 1.1 什么是中間件? 由于業(yè)務、機構(gòu)和技術(shù)是不斷變化的，因此為其服務的軟件系統(tǒng)必須適應這樣的變化。在合并、添加服務或擴展可用服務之后，公司可能無力負擔重新創(chuàng)建信息系統(tǒng)所需的成本。正是在...
摘要：本文主要講述消息服務在中的使用。所以需要一個監(jiān)聽容器工廠的概念，即接口，它會引用上面創(chuàng)建好的與的連接工廠，由它來負責接收消息以及將消息分發(fā)給指定的監(jiān)聽器。為了消費消息，訂閱者必須保持運行的狀態(tài)。 JMS 在 SpringBoot 中的使用 摘要：本文屬于原創(chuàng)，歡迎轉(zhuǎn)載，轉(zhuǎn)載請保留出處：https://github.com/jasonGeng88/blog> 本文所有服務均采用doc...
摘要：安裝到官方網(wǎng)站下載最新的的安裝包，并解壓到本地目錄下，下載鏈接如下。修改消費者使用配置消費者監(jiān)聽的隊列，其中是接收到的消息收到的報文為接收到的消息重新執(zhí)行 安裝ActiveMQ 到Apache官方網(wǎng)站下載最新的ActiveMQ的安裝包，并解壓到本地目錄下，下載鏈接如下：http://activemq.apache.org/do...。showImg(https://segmentfau...
閱讀 2760·2023-04-25 18:10
閱讀 1703·2019-08-30 15:53
閱讀 2983·2019-08-30 13:10
閱讀 3319·2019-08-29 18:40
閱讀 1211·2019-08-23 18:31
閱讀 1283·2019-08-23 16:49
閱讀 3470·2019-08-23 16:07
閱讀 949·2019-08-23 15:27
