概念:两种JMS的实现方法:
Topic==>消息主题 是发布/订阅 机制 一个消息产生多个对应 1:N publish/subscribe
Queue==>消息队列 是点到点 一个消息产生一个对应 1:1 point-to-point
activeMQ 的 Queue 的生产和消费
一、生产
1. 创建链接Q服务器
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user, password, url);
Connection connection = connectionFactory.createConnection();
connection.start();
2.创建session,并设置事务和策略
Session session = connection.createSession(事务参数,策略参数);
3.定位队列
Destination destination = session.createQueue(队列名称);
4.创建产品生产对象
MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.PERSISTENT);//在Q关闭时会序列到默认或指定位置,重启后恢复
//producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
5.创建 message 并发送到Queue 中
Message message = session.createMessage("内容");
producer.send(message);
session.commit();//用于事务时
6.close
producer.close();
session.close();
connection.close();
二、消费 (需要实现MessageListener接口的onMessage(Message message)方法 )
1. 创建链接Q服务器
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user, password, url);
Connection connection = connectionFactory.createConnection();
connection.start();
2.创建session,并设置事务和策略
Session session = connection.createSession(事务参数,策略参数);
3.定位队列
Destination destination = session.createQueue(队列名称);
4.创建产品消费对象
MessageConsumer consumer = session.createConsumer(destination);
consumer.setMessageListener(this);
5.从Queue中取出消息
Message message = consumer.receive(1000);
session.commit();//用于事务时
6.close
consumer.close();
session.close();
connection.close();
分享到:
相关推荐
ActiveMQ队列消息过期时间设置和自动清除解决方案.docx
使用SpringBoot方式集成ActiveMQ ActiveMQ消息中间件的点对点模式point to point 消息队列 ...* queue中支持存在多个消费者,但是对一个消费者而言,只会有一个消费者可以消费,其他的消费者便不能消费此消息
文章目录ActiveMQ简介1、ActiveMQ简介2、ActiveMQ下载SpringBoot整合ActiveMQ1、新建SpringBoot项目2、项目结构3、相关配置信息4、ActiveMQ配置类Queue队列模式1、队列生产者2、队列消费者3、测试效果Topic模式1、...
springboot整合activemq案例,queue,topic两种模式 定时运行和controller请求运行两种方式
# Springboot-activeMQ 本项目基于Spring boot这一平台,整合流行的开源...2.队列类型queue,生产者发送队列消息,以及消费者消费相关队列消息 3.主题类型topic,创建主题,生产者发送主题消息,以及消费着消费主题消息
activemq的Java依赖包,课构建Queue/topic 生产、消费
它主要用于在生产者和消费者之间进行消息传递,生产者负责产生消息,而消费者负责接收消息。把它应用到实际的业务需求中的话我们可以在特定的时候利用生产者生成一消息,并进行发送,对应的消费者在接收到对应的消息...
点对点的消息传递中,目的地被称为队列(Queue)点对点消息传递的特点如下:(1)每个消息只能有一个消费者,类似1对1的关系,好比个人快递自己领取自己的(2)消息的生产者和消费者之间没有时间上的相关性。...
Queue queue = session.createQueue(disname); MessageConsumer consumer = null; if(threadLocal.get()!=null){ consumer = threadLocal.get(); }else{ consumer = session.createConsumer(queue); ...
1.1.5 消息生产者 2 1.1.6 消息消费者 2 1.1.7 消息 3 1.2 JMS的可靠性机制 3 1.2.1 确认 JMS消息 3 1.2.2 持久性 3 1.2.3 优先级 3 1.2.4 消息过期 3 1.2.5 临时目的地 3 1.2.6 持久订阅 3 ...
MQ-EAI 这包含与 Message Queue(ActiveMQ) 和 Mule ESB 相关的项目。 关于排队和企业集成#MQService:这是一个使用 ActiveMQ 生成和使用 Blob 数据(pdf、doc 等)的宁静服务。 #GMQ:这是一个基于 RabbitMQ 和 ...
写spring配置文件的时候, 要把MessageProducer, MessageConsumer,MessageListener,MessageListenerContainer几个地方弄清楚: ...4.每个消费者对应一个MessageListener和一个MessageListenerContainer.
Jfinal -active mq: 消费:extends JFinalQueueConsumer 生产:JFinalQueue.sendMessage(queueName, message);
一、MQ介绍 二、MQ的使用 1应用解耦 2异步处理 3流量削峰 4日志处理 5消息通讯 ...六、如何保证消息不被重复消费? 七、如何保证消息不丢失? 八、如何保证消息的顺序性? 九、消息大量积压怎么解决?
队列模式 queue 主题模式 topic 集群 ###概念 集群目的 高可用 派出单点故障引起的服务中断(一个挂掉,另一个立即顶上,消息不丢失) 负载均衡 以提升效率为更多的客户服务(压力不用集中在一个节点上) 集群方式 ...
JMS规范v1.1的官方原版,大家学习ActiveMQ的时候可以进行参考。详细介绍了包括连接、session、生产者、消费者、topic、queue等概念。深入学习的必备手册。
一、MQ相关知识介绍 1、概述 MQ(Message Queue),即消息队列。早已成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制...1.消息生产者(Producer)生产消息发送到Queue中,然后消息消费者(Consum
sto脚 “ stomp.py”是一个Python客户端库,用于使用协议( , 和 )访问消息传递服务器(例如 , 或 )。... argv [ 1 :]), destination = '/queue/test' ) conn . disconnect () 文档和资源 主