ActiveMQ持久化机制代码实例
这篇文章主要介绍了ActiveMQ持久化机制代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
用户注册成功后发短信提醒
同步http
异步mq
JMS中两种通讯模式：
发布订阅一对多topic去过消费者集群的话都会消费
消息队列点对点queue去过消费者集群的话均摊消费
场景问题：服务器断电重启，未被消费的消息是否会在重启之后消费？
两种模式：
1、非持久性，服务器断电（关闭）之后，使用非持久性模型时，没有被消费的消息不会继续消费，全部丢失。程序会报一个连接关闭异常，停止运行。继续启动服务器运行程序，不会接收任何消息。
2、持久性，服务器断电（关闭）之后，使用持久性模型时，没有被消费的消息会继续消费，程序也会报连接关闭异常，但再次启动服务器和程序后，接收方还能继续原来的消息再次接收。
packagecom.toov5.producer;
importjavax.jms.Connection;
importjavax.jms.DeliveryMode;
importjavax.jms.JMSException;
importjavax.jms.MessageProducer;
importjavax.jms.Queue;
importjavax.jms.Session;
importjavax.jms.TextMessage;
importorg.apache.activemq.ActiveMQConnectionFactory;
publicclassproducerTest{
//mq通讯地址
privatestaticStringurl="tcp://192.168.91.6:61616";
//队列名称
privatestaticStringqueueName="toov5_queue";
publicstaticvoidmain(String[]args)throwsJMSException{
//先创建连接工厂密码默认采用adminadmin
ActiveMQConnectionFactoryactiveMQConnectionFactory=newActiveMQConnectionFactory(url);
//创建连接
Connectionconnection=activeMQConnectionFactory.createConnection();
//启动连接
connection.start();
//创建会话
Sessionsession=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);//是否需要事务方式提交消费方式默认自动签收
//拿到session创建目标创建队列
Queuequeue=session.createQueue(queueName);
//创建生产者
MessageProducerproducer=session.createProducer(queue);//生产者生产的消息是放在这个queue里面的
producer.setDeliveryMode(DeliveryMode.PERSISTENT);//默认非持久化的设置持久化
for(inti=1;i<10;i++){
//拿到队列创建消息
TextMessagetextMessage=session.createTextMessage("消息内容"+i);
//发送消息
producer.send(textMessage);
}
//关闭连接
connection.close();
System.out.println("消息发送完毕");
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。