008_Queue消息模式发送映射消息

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消息模式发送映射消息相关推荐

006_Topic消息模式发送对象消息
1. 新建一个名为JMSActiveMQObjectMessage的Java项目, 同时拷入相关jar包 2. 编辑User.java package com.jms.activemq.tom;imp ...
005_Queue消息模式发送字节消息
1. 新建一个名为JMSActiveMQBytesMessage的Java项目, 同时拷入相关jar包 2. 编辑QueueBytesMessageProducer.java package com. ...
004_Queue消息模式发送文本消息
1. 新建一个名为JMSActiveMQTextMessage的Java项目, 同时拷入相关jar包 2. 相关jar包可以在apache-activemq-5.16.1\lib目录下找到 3. 编辑 ...
微信服务号模版消息重复发送或消息接收不到的解决方案
微信服务号模版消息重复发送或消息接收不到的解决方案问题描述解决思路问题描述前段时间开发的服务号,有一个功能是主动向用户推送消息,经查看文档后,发现模版消息可以实现,于是按照文档向微信申请消息模 ...
SpringBoot高级-消息-RabbitTemplate发送接受消息序列化机制
引入了spring-boot-starter-amqp模块,他引入了spring-messaging模块,包括引入了spring-rabbit模块,怎么配置使用呢,<dependency> ...
微信公众平台开发-消息管理-发送模板消息
一.模板说明模板消息是在特定服务场景中向粉丝发送的消息,例如:信用卡刷卡通知,商品购买成功通知.不同的模板有不同的风格,某些字段可以由你来填充自己的内容(同时设定颜色),从而形成自己的消息.微信公众 ...
微信公众号开发-----微信模板消息接口-----发送模板消息
发送模板消息接口调用请求说明 http请求方式: POST https://api.weixin.qq.com/cgi-bin/message/template/send?access_token= ...
java 发送qq消息_php发送qq消息
function fcontents($url,$cookie){ $ch = curl_init(); curl_setopt ($ch, CURLOPT_URL, $url); curl_seto ...
非模态对话框的销毁及消息的发送顺序
非模态对话框的销毁( 2010-12-28 19:21:33| 分类: vc | 标签: |字号大中小订阅 void CTestDlg::OnCancel() { DestroyWindow() ...

008_Queue消息模式发送映射消息

008_Queue消息模式发送映射消息相关推荐

最新文章

热门文章