由于项目原因,很长时间没有更新了。今天本篇主要解释一些名词,为下一步的ActiveMQ的Queue使用奠定基础
在开始演示前先引入一些概念:
Q:ActiveMQ Queue中有哪些消息交互模式(传送模式)?
A:ActiveMQ遵循JMS标准分为:
1.PERSISTENT(持久性消息)
这是 ActiveMQ 的默认传送模式,此模式保证这些消息只被传送一次和成功使用一次。对于这些消息,可靠性是优先考虑的因素。可靠性的另一个重要方面是确保持久性消息传送至目标后,消息服务在向消费者传送它们之前不会丢失这些消息。这意味着在持久性消息传送至目标时,消息服务将其放入持久性数据存储。如果消息服务由于某种原因导致失败,它可以恢复此消息并将此消息传送至相应的消费者。虽然这样增加了消息传送的开销,但却增加了可靠性。
2.NON_PERSISTENT(非持久性消息)
保证这些消息最多被传送一次。对于这些消息,可靠性并非主要的考虑因素。 此模式并不要求持久性的数据存储,也不保证消息服务由于某种原因导致失败后消息不会丢失。
Q:如何设置消息交互模式(传送模式)?
A:在ActiveMQ中有2种方法来设置,分别适用于不同的场景。我更偏向于第一种处理方式,有利于消息的封装和统计。
1.在消息生产者中直接设置模式,
producer.setDeliveryMode(int deliveryMode);
此模式的适用于单一类型的消息生产者。
2.在每条消息中设置,
void send(Destination destination, Message message, int deliveryMode, int priority,long timeToLive);
void send(Message message, int deliveryMode, int priority, longtimeToLive);
其中 deliveryMode 为传送模式,priority 为消息优先级,timeToLive 为消息过期时间。
Q:想要使用自定义的Queue来管理消息,该如何做?
A:继承ActiveMQDestination并实现Queue(javax.jms包)接口
相关推荐
一、JMS基本概念 二、activemq介绍及安装 1、消息中间件简介 2、activemq ...四、activemq整合spring运用 五、activemq常见问题 5.1 activemq 消息传递 5.2 activemq 消息确认机制 5.3 activemq 持久化机制
ACTIVEMQ实战部分翻译,只翻译了第一章到第四章的第三节
包括ActiveMQ、CPPUnit、APR、APR-iconv、APR-util四个编译ActiveMQ必须的包,省得一个一个去下载了。 开发具体例子参考下面的链接 http://blog.sina.com.cn/s/blog_a459dcf501017ooh.html 配置和简单的例子参考下面...
第一行为常规Python访问,第二行为使用Jython访问的方式,四个操作。 Python访问ActiveMQ需要使用stomp.py,见其官网。 下载官网的代码,解压,命令行进入其目录,使用pyhthon setup.py install即可安装好,然后就...
ActiveMQ_实践之路(一)ActiveMQ_实践之路(二)ActiveMQ_实践之路(三)ActiveMQ_实践之路(四)
NULL 博文链接:https://sswh.iteye.com/blog/1974156
n 四:用ActiveMQ构建应用 包括:多种启动Broker的方法、单独应用的开发、结合Spring的开发等 n 五:ActiveMQ的Transport 包括:多种传输协议的功能、配置和使用 六: ActiveMQ的消息存储 包括:队列和topic、KahaDB...
ActiveMQ 是 Apache 出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和 J2EE 1.4 规范的 JMS Provider 实现,尽管JMS 规范出台已经是很久的...下面我们将分四部分来介绍ActiveMQ 的相关内容。
# Spring-activeMQ 在业务逻辑的异步处理,系统解耦,分布式通信以及控制高并发的场景下,消息队列有着广泛的应用。本项目基于Spring这一平台,整合流行的开源消息队列中间件ActiveMQ,实现一个向ActiveMQ添加和读取...
本项目基于Spring这一平台,整合流行的开源消息队列中间件ActiveMQ,实现一个向ActiveMQ添加和读取消息的功能。并比较了两种模式:生产者-消费者模式和发布-订阅模式的区别。 包含的特性如下: 1.开启activeMQ,访问...
英文版 四个大章节 Introduction, Configuring ActiveMQ, Using ActiveMQ, Advanced ActiveMQ
ActiveMQ系列(四)--------结合 Eclipse 操作(csdn)————程序
Java Messsage Service Java消息服务 为Java应用程序提供了完整的异步消息服务机制。 JMS源于企业应用对于消息中间件的需求,使...JMS有四个组成部分:JMS服务提供者、消息管理对象、消息的生产者消费者和消息本身。
一头扎进WebService之CXF Shiro Maven Lucene ActiveMq ExcelPOI JFreeChart视频教程
四、下载与使用 下载:所有项目均提供下载,您只需在平台上注册并登录即可获取。 安装与部署:每个项目都提供了详细的安装和部署指南,帮助您快速搭建和运行项目。 定制开发:您可以根据实际需求对项目进行定制开发...
集成SSH框架的系统从职责上分为四层:表示层、业务逻辑层、数据持久层和域模块层,以帮助开发人员在短期内搭建结构清晰、可复用性好、维护方便的Web应用程序。其中使用Struts作为系统的整体基础架构,负责MVC的分离...
四、常用的 MQ ActiveMQ: RabbitMQ: RocketMQ: Kafka: 五、如何保证MQ的高可用? ActiveMQ: RabbitMQ: RocketMQ: Kafka: 六、如何保证消息不被重复消费? 七、如何保证消息不丢失? 八、如何保证消息的顺序性...
1.abbitMQ 集群采用元数据同步的方式 2.RabbitMQ 集群会始终同步四种类型的内部元数据 3.RabbitMQ 集群采用 ,你们用的 rabbitMq,你有深入了解过吗?我反问怎么才叫深入,然后他就你说下 rabbitmq 集群怎么做的,...
包含:ActiveMQ消息中间件面试专题,java后端面试题答案,JVM面试专题及答案以及MyBatis面试专题及答案等等。
目前使用较多的消息队列有ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ 二、消息队列应用场景 以下介绍消息队列在实际应用中常用的使用场景。异步处理,应用解耦,流量削锋和消息通讯四个场景。