activemq学习资料.docx

ActiveMQ学习资料 Activemq是Apache软件基金会的一个开源的消息总线系统，使用Java语言编写的，遵循JMS（Java Message Service）规范。下面是Activemq学习资料的知识点总结： JMS基本构件 * 连接工厂（ConnectionFactory）：客户端用来创建连接的对象，例如ActiveMQ提供的ActiveMQConnectionFactory。 * 连接（Connection）：JMS Connection封装了客户端与JMS提供者之间的一个虚拟的连接。 * 会话（Session）：JMS Session是一个生產和消费消息的单线程上下文，提供了一个事务性的上下文，在这个上下文中，一组发送和接收被组合到了一个原子操作中。 * 目的地（Destination）：客户端用来指定它生产的消息的目标和它消费的消息的来源的对象。 JMS规范 * 点对点（PTP）消息传递域：每个消息只能有一个消费者，消息的生产者和消费者之间没有时间上的相关性。 * 发布/订阅（Pub/Sub）消息传递域：每个消息可以有多个消费者，生产者和消费者之间有时间上的相关性。 * 持久订阅（Durable Subscription）：允许消费者消费它在未处于激活状态时发送的消息。 消息生产者和消费者 * 消息生产者（Producer）：由会话创建的一个对象，用于把消息发送到一个目的地。 * 消息消费者（Consumer）：由会话创建的一个对象，用于接收发送到目的地的消息。消息的消费可以采用同步消费或异步消费。 消息 * 消息头（Header）：每个消息头字段都有相应的getter和setter方法。 * 消息属性（Property）：如果需要除消息头字段以外的值，那么可以使用消息属性。 * 消息体（Body）：JMS定义的消息类型有TextMessage、MapMessage、BytesMessage、StreamMessage和ObjectMessage。 JMS可靠性机制 * 确认（Acknowledgement）：JMS消息只有在被确认之后，才认为已经被成功地消费了。 * 持久性（Durability）：JMS支持以下两种消息提交模式：PERSISTENT和NON_PERSISTENT。 * 优先级（Priority）：可以使用消息优先级来指示JMS provider首先提交紧急的消息。 * 消息过期（Expiration）：可以设置消息在一定时间后过期，默认是永不过期。 Activemq学习资料涵盖了JMS规范的基本概念和ActiveMQ的实现细节，为学习和使用Activemq提供了良好的基础。