1. 新建一個名為JMSActiveMQMapMessage的Java項目, 同時拷入相關jar包

2. 編輯QueueMapMessageProducer.java

package com.jms.activemq.qmm;import javax.jms.JMSException; import javax.jms.MapMessage; import javax.jms.Queue; import javax.jms.QueueConnection; import javax.jms.QueueConnectionFactory; import javax.jms.QueueSender; import javax.jms.QueueSession; import javax.jms.Session; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory;public class QueueMapMessageProducer {// 默認連接用戶名private static final String dftUsr = ActiveMQConnection.DEFAULT_USER;// 默認用戶密碼private static final String dftPwd = ActiveMQConnection.DEFAULT_PASSWORD;// 默認連接地址private static final String dftUrl = ActiveMQConnection.DEFAULT_BROKER_URL;// 隊列名稱private static final String queueName = "queueMapMsg";public static void main(String[] args) {// 1. 創建一個連接工廠QueueConnectionFactory cf = new ActiveMQConnectionFactory(dftUsr, dftPwd, dftUrl);// 連接對象QueueConnection conn = null;// 會話對象QueueSession session = null;try {// 2. 創建連接conn = cf.createQueueConnection();// 3. 啟動連接conn.start();// 4. 創建會話session = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);// 5. 創建消息目的地。如果是點對點, 那么它的實現是Queue; 如果是訂閱模式, 那它的實現是Topic。這里我們創建一個名為queueMapMsg的消息隊列。Queue queue = session.createQueue(queueName);// 6. 消息生產者QueueSender sender = session.createSender(null);// 7. 創建文本消息和發送消息for(int i = 0; i < 2; i++) {MapMessage message = session.createMapMessage();message.setLong("id", 100000000000L + i);message.setString("name", "lisi");sender.send(queue, message);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}} catch (JMSException e) {e.printStackTrace();} finally {try {if (session != null) {session.close();}} catch (JMSException e1) {e1.printStackTrace();} finally {if (conn != null) {try {conn.close();} catch (JMSException e) {e.printStackTrace();}}}}} }

3. 編輯QueueMapMessageConsumer.java

package com.jms.activemq.qmm;import javax.jms.JMSException; import javax.jms.MapMessage; import javax.jms.Queue; import javax.jms.QueueConnection; import javax.jms.QueueConnectionFactory; import javax.jms.QueueReceiver; import javax.jms.QueueSession; import javax.jms.Session; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory;public class QueueMapMessageConsumer {// 默認連接用戶名private static final String dftUsr = ActiveMQConnection.DEFAULT_USER;// 默認用戶密碼private static final String dftPwd = ActiveMQConnection.DEFAULT_PASSWORD;// 默認連接地址private static final String dftUrl = ActiveMQConnection.DEFAULT_BROKER_URL;// 隊列名稱private static final String queueName = "queueMapMsg";public static void main(String[] args) {// 1. 創建一個連接工廠QueueConnectionFactory cf = new ActiveMQConnectionFactory(dftUsr, dftPwd, dftUrl);// 連接對象QueueConnection conn = null;// 會話對象QueueSession session = null;try {// 2. 創建連接conn = cf.createQueueConnection();// 3. 創建會話session = conn.createQueueSession(false, Session.CLIENT_ACKNOWLEDGE);// 4. 創建消息目的地。如果是點對點, 那么它的實現是Queue; 如果是訂閱模式, 那它的實現是Topic。這里我們創建一個名為queueMapMsg的消息隊列。Queue queue = session.createQueue(queueName);// 5. 消息消費者QueueReceiver receiver = session.createReceiver(queue);// 6. 啟動連接, 準備開始接收消息conn.start();// 7. 接收消息MapMessage message = (MapMessage) receiver.receive(1000 * 3);System.out.println("接收: id = " + message.getLong("id") + ", name = " + message.getString("name"));MapMessage message1 = (MapMessage) receiver.receive(1000 * 3);System.out.println("接收: id = " + message1.getLong("id") + ", name = " + message1.getString("name"));// 8. 客戶端主動確認消息已成功接收。進行了一次確認, 卻確認了2條消息的消費, 因為這種確認方式是會話級別的。message.acknowledge(); System.out.println("JMSDestination = " + message.getJMSDestination() + ", JMSDeliveryMode = " + message.getJMSDeliveryMode()+ ", JMSExpiration = " + message.getJMSExpiration() + ", JMSPriority = " + message.getJMSPriority()+ ",\r\nJMSMessageID = " + message.getJMSMessageID() + ", JMSTimestamp = " + message.getJMSTimestamp()+ ", JMSCorrelationID = " + message.getJMSCorrelationID() + ",\r\nJMSReplyTo = " + message.getJMSReplyTo()+ ", JMSType = " + message.getJMSType() + ", JMSRedelivered = " + message.getJMSRedelivered());} catch (JMSException e) {e.printStackTrace();} finally {try {if (session != null) {session.close();}} catch (JMSException e1) {e1.printStackTrace();} finally {if (conn != null) {try {conn.close();} catch (JMSException e) {e.printStackTrace();}}}}} }

4. 運行QueueMapMessageProducer.java

5. 注釋掉確認消息代碼, 運行QueueMapMessageConsumer.java

6. 放開確認消息代碼, 再次運行QueueMapMessageConsumer.java

總結

以上是生活随笔為你收集整理的008_Queue消息模式发送映射消息的全部內容，希望文章能夠幫你解決所遇到的問題。

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