ActiveMQ简介

Apache ActiveMQ是Apache软件基金会所研发的开放源代码消息中间件;由于ActiveMQ是一个纯Java程序,因此只需要操作系统支持Java虚拟机,ActiveMQ便可执行。


Destination

目的地,JMS Provider(消息中间件)负责维护,用于对Message进行管理的对象。MessageProducer需要指定Destination才能发送消息,MessageConsumer需要指定Destination才能接收消息。


Producer

消息生成者(客户端,生成消息),负责发送Message到目的地。应用接口为MessageProducer


Consumer(Receiver)

消息消费者(处理消息),负责从目的地中消费(处理、监听、订阅)Message。应用接口为MessageConsumer


Message

消息,消息封装一次通信的内容。常见类型有:StreamMessage、BytesMessage、TextMessage、ObjectMessage、MapMessage


ConnectionFactory

链接工厂,用于创建链接的工厂类型


Connection

连接,用于建立访问ActiveMQ连接类型,由链接工厂创建


Session

会话,一次持久有效有状态的访问,由链接创建,是具体操作消息的基础支撑


Queue & Topic

Queue是队列目的地,Topic是主题目的地,都是Destination的子接口

Queue特点:队列中的消息,默认只能由唯一的一个消费者处理。一旦处理,消息删除

Topic特点:主题中的消息,会发送给所有的消费者同时处理。只有在消息可以重复处理的业务场景中可以使用


PTP

Point to Point,点对点消息模型。基于Queue实现的消息处理方式


PUB & SUB

Publish & Subscribe,消息的发布 / 订阅模型。基于Topic实现的消息处理方式




回到顶部