同系列文章:
Apache ActiveMQ是一个非常流行和强大的开源消息和集成模式(Integration Patterns)服务器,速度快、支持多种跨语言客户端和协议,易于使用企业集成模式(Enterprise Integration Patterns),拥有许多先进的特性,完全支持JMS 1.1和J2EE 1.4规范。ActiveMQ基于Apache 2.0许可。
一、基本术语
1.连接工厂ConnectionFactory
连接工厂用于创建连接对象
2.连接Connection
封装了客户与服务之间一个虚拟的连接。
3.会话Session
是生产和消费消息的一个单线程上下文。会话用于创建消息生产者(Producer)、消息消费者(Consumer)和消息(Message)等。会话提供了一个事务性的上下文,在这个上下文中,一组发送和接收被组合到了一个原子操作中。
4.目的地Destination
目的地是客户用来指定它生产的消息的目标和它消费的消息的来源的对象。定义了两种消息传递域:点对点(P2P)消息传递域和发布/订阅消息传递域。在点对点消息传递域中,目的地被称为队列(Queue);在发布/订阅消息传递域中,目的地被称为主题(Topic)。
5.消息生产者Producer
消息生产者是由会话创建的一个对象,用于把消息发送到一个目的地。
6.消息消费者Consumer
消息消费者是由会话创建的一个对象,它用于接收发送到目的地的消息。消息的消费可以采用以下两种方法之一:同步消费,通过调用消费者的Receive方法从目的地中显式提取消息。Receive方法可以一直阻塞到消息到达。异步消费,客户可以为消费者注册一个消息监听器,以定义在消息到达时所采取的动作。
7.消息Message
消息由以下三部分组成:
消息头,每个消息头字段都有相应的getter和setter方法。
消息属性,如果需要除消息头字段以外的值,那么可以使用消息属性。
消息体,定义的消息类型有TextMessage、MapMessage、BytesMessage、StreamMessage和ObjectMessage。
二、命令说明:
启动ActiveMQ:activemq start
停止ActiveMQ:activemq stop
管理ActiveMQ:http://localhost:8161/admin(默认用户名admin,默认密码admin)
侦听端口:默认端口为61616,netstat -an|find "61616"
- 每个消息只能有一个消费者
- 消息的生产者和消费者之间没有时间上的相关性。无论消费者在生产者发送消息的时候是否处于运行状态,它都可以提取消息
- 目的地被称为队列(Queue)
- 每个消息可以有多个消费者
- 生产者和消费者之间有时间上的相关性。订阅一个主题的消费者只能消费自它订阅之后发布的消息。JMS规范允许客户创建持久订阅,这在一定程度上放松了时间上的相关性要求。持久订阅允许消费者消费它在未处于激活状态时发送的消息
- 目的地被称为主题(Topic)