ActiviMQ(1)

1. ActiviMQ是实现JMS接口和规范的消息中间件(Provider),

2. JMS,Java Message Service, java消息服务,是JavaEE中的一个技术

3. JMS规范:JMS定义了Java中访问消息中间件的接口,并没有给予实现,实现JMS接口的消息中间件成为JMS Provider,例如ActiveMQ

4. JMS message:JMS的消息,JMS消息由一下三部分组成:

①消息头:每个消息头字段都有相应的getter和sertter方法

消息头包含消息的识别信息和路由信息,消息头包含的一些标准的属性如下

(1)JMSDestination:由send方法设置,消息的目的地,主要指示Queue和Topic,自动分配

(2)JMSDeliveryMode:由send方法设置,传送模式。有两种:持久化模式和非持久化模式。一条持久性的消息应该被传送“一次仅仅一次”,这意味着如果JMS提供者出现故障,该消息并不会丢失,他会在服务器恢复之后再次传递。一个非持久化的消息最多会传送一次,这意味着这服务器出现故障,该消息将永远丢失。自动分配

(3)JMSExpiration:由send方法设置,消息过期时间,等于Destination的send方法中的timeToLive值加上发送时刻的GMT时间值,如果timeToLive值等于零JMSExpiration被设置为零,表示该消息永不过期。如果发送后,在消息过期时间之后消息还没有被发送到目的地,则该消息被清除,自动分配

(4)JMSPriority:由send方法设置:消息优先级,从0-9十个级别,0-4是普通消息,5-9是加急消息。JMS不要求JMS Provider严格按照这十个优先级发送消息,但必须保证加急消息要先于普通消息到达。默认是4级。自动分配

(5)JMSMessageID:由send方法设置,唯一识别每个消息的表示,有JMSProvider产生,自动分配

(6)JMSTimestamp:由客户端设置,一个JMsProvider在调用send方法时自动设置的,它的消息被发送和消费者实际接收的时间差,自动分配

(7)JMSCorrelationID:由客户端设置,用来连接到另外一个消息,典型的应用是在回复消息中链接到院消息,在大多数情况下,JMSCorrelationID用于将一条消息标记为对JMSMessageID标示的上一条消息的应答,不过JMSCorrelationID可以是任何值,不仅仅是JMSMessageID。由开发者设置

(8)JMSReplyTo:由客户端设置,提供本消息回复消息的目的地址,由开发者设置

(9)JMSType:由客户端设置,消息类型的识别符,有开发者设置

(10)JMSRedelivered:由JMS Provider设置,如果一个客户端收到一个设置了JMSRedelivered属性的消息,则表示可能客户端曾经在早些时候收到过该消息,但并没有签收(acknowledged)。如果该消息被重新传送,JMSRedelivered=true反之,JMSRedelivered=false。自动设置

②消息属性:如果需要除消息头字段以外的值,那么可以使用消息属性

包含三中类型

(1)应用程序设置和添加的属性,比如:

Message.setStringProperty("username",username);

(2)Jms定义属性

使用"JMSX"作为属性名的前缀,connection.getMetaData().getJMSXPropertyNames(),方法返回所有连接支持的JMS属性的名字。

1. JMSXUserID:发送消息的用户标识,发送时提供商设置

2. JMSAppID:发送消息的应用标识,发送时提供商设置

3. JMSXDeliveryCount:转发消息重试次数,第一次是1,第二次是2,...,发送时提供商设置

4. JMSXGroupID:消息所在消息组的标识,由客户端设置等等 (72-33m)

(3)JMS供应商特定的属性

③消息体:封装具体的消息数据

JMS api定义了5中消息体格式,也叫消息类型,可以使用不同形式发送,接受数据,并可以兼容现有的消息格式。包括TextMessage、MapMessage、bytesMessage、StreamMessage、ObjectMessage。

5. JMS producer:消息生产者,创建和发送JMS消息的客户端应用

6. JMS consumer:消息消费者,接收和处理JMS消息的客户端应用

消息的消费可以采用以下两种方法之一:

①:同步消费:通过调用消费者的receive方法从目的地中显示提取消息,receive方法可以一直阻塞到消息到达

②:异步消费:客户可以为消费者注册一个消息监听,以定义在消息到达时所采取的动作

7.    A-----m---->AMQ------m---->B

A:消息生产者

B:消息消费者

AMQ:消息中间件(ActiveMQ)

8. JMS domains:消息传递域,JMS规范中定义了两种消息传递域:点对点(point-to-point:简写成PTP)消息传递域和发布/订阅消息传递域(publish/subscribe,简写成pub/sub)

(1)点对点消息传递域的特点如下:

①每个消息只能有一个消费者

②消息的生产者和消费者之间没有时间上的相关性。无论消费者在生产者发送消息的时候处于运行状态,他都是可以提取消息

9. 发布/订阅消息传递域的特点如下:

① 每个消息可以有多个消费者

②生产者和消费者之间有时间上的相关性,订阅一个主题的消费者只能消费自它订阅之后的发布的消息,JMS规范允许客户创建持久订阅,这在一定程度上放松了时间上的相关性要求。持久订阅允许消费者消费它在未处于激活状态时发送的消息

10. 在点对点消息传递域中,目的地被称为queue;在发布/订阅消息传递域中,目的地被称为主题(topic)。

11.ConnectionFactory:连接工厂,用来创建连接对象,以连接到JMS的provider

12.JMS Connection:封装客户和JMS提供者之间的一个虚拟的连接

13.JMS Session:是生产和消费消息的一个单线程上下文

会话用于创建消息生产者(producer)、消息消费者(consumer)和消息(message)等。会话提供了一个事务性的上下文,在这个上下文中,一组发送和接收被组合到了一个原子操作中。

14. Destination:消息发送到的目的地(queue/topic)

15.Acknowledge: 签收

16.Transacted:事务

17.JMS client:用来收发消息的java应用

18.Non-JMS client:使用JMS provider本地API写的应用,用来替换JMS API实现收发消息的功能 ,通常会提供其它的一些特性,比如:CORBA、RMI等。

19.Administred objects:预定义的JMS对象,通常在provider规范中有定义,提供给JMS客户端来访问,比如:ConnectionFactory和Destination

时间: 2024-12-22 05:22:33

ActiviMQ(1)的相关文章

activimq消息队列基本配置

背景: 在了解一个分布式框架的时候,偶然接触到activimq消息队列,于是就决定写一个小demo 首先是linux配置activimq 去官网下载一个activimq的linux安装包,直接解压,到bin目录下执行: activemq start 这样就启动了,很简单 然后可以查看是否有新的端口61616被监听 接着查看是否有相关进程 同时activimq还有一个后台监控页面, 但是这个默认端口是8161,访问地址为: http://10.10.10.30:8161/admin/ 默认用户名.

activimq消息队列持久化配置

activimq持久化常用的有三种方式:1.文件持久化 2.mysql持久化 3.oracle持久化 在activimq的配置文件中默认开启了文件持久化 同时我们需要修改一行代码: 这样在activimq重启之后就不会有消息丢失了 如果要使用mysql持久化的话需要修改配置文件 <persistenceAdapter> <jdbcPersistenceAdapter dataSource="#mysql-ds"/> </persistenceAdapter

windows和centos下安装ActiveMQ

版本:apache-activemq-5.10.2-bin.zip         (版本5.11+需要jdk7+) 官网: http://activemq.apache.org/download.html Windows安装 1.下载解压window版的 ActiveMQ: apache-activemq-5.10.0-bin.zip : 2.进去解压目录:bin下,根据操作系统32bit/64bit,进入不同文件夹win32/win64: 3.双击“activemq.bat: 4. 默认采用

ActiveMQ 的安装与使用(springboot版本)

一.安装 上官网下载tar包 http://activemq.apache.org/ tar -zxvf 后进入bin/linux-86-64 ./activimq start 启动 二.使用 pom文件引入依赖 <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.47</version> &l