JMS的API结构
一个JMS应用的基本步骤
- JMS开发的基本步骤：
- 创建一个JMS Connection Factory
- 通过Connection Factory来创建JMS Connection
- 启动JMS Connection
- 通过Connection创建JMS Session
- 创建JMS Destination
- 创建JMS Producer，或者创建爱你JMS Message，并设置Destination
- 创建JMS Consumer，或者是注册一个JMS Message Listener
- 发送或者接收Message(s)
- 关闭所有的JMS资源（Connection 、Session、Producer、Consumer等）
非持久的Topic消息示例
- 对于非持久的Topic消息的发送
- 基本跟前面发送队列消息是一样的，只是把创建Destination的地方，由创建队列替换成创建Topic，例如：
Destination destination = session.createTopic("MyTopic");
- 对于非持久的Topic消息的接收
- 必须要接收方在线，然后客户端在发送消息，接收方才能接收消息
- 同样把创建Destination的地方，由创建队列替换成创建Topic，例如：
Destination destination = session.createTopic("MyTopic");- 由于不知道客户端发送多少消息，因此改成while循环的方式，例如：
持久Topic消息
- 对于持久的Topic消息发送
- 要用持久化订阅，发送者要用DelIveryMode.PERSISTENT模式发现，在连接之前设定
- 一定要设置完成后，再start这个connection
- 对于持久的Topic消息接收
- 需要在连接上设置消费者ID，用来识别消费者
- 需要创建TopicSubscriber来订阅
- 要设置好了之后再start这个connection
- 一定要先运行一次，等于向消息服务中间件注册这个消费者，然后在运行客户端发送消息，这个时候，无论消费者是否在线，都会接收到，不在线的话，下次连接的时候会把没有收过的消息都接收到
关于持久化和非持久化消息
- 持久化消息
- 这是ActiveMQ的默认传送方式，此模式保证这些消息只被传送一次和成功使用一次。对于这些消息，可靠性是优先考虑的因素。可靠性的另一个重要方面是确保持久化消息传送至目标后，消息服务再向消费者传送它们之前，不会丢失这些消息
- 这意味着在持久性消息传送至目标时，消息服务将其放入持久性数据存储。如果消息服务由于某种原因导致失败，它们可以恢复此消息并将此消息传送至相应的消费者。虽然这样增加了消息传送的开销，但却增加了可靠性
- 非持久化消息
- 保证这些消息最多被传送一次。对于这些消息，可靠性并非主要的考虑因素。此模式并不要求持久性的数据存储，也不保证消息服务由于某种原因导致失败后消息不会丢失。有两种方法指定传送模式：
- 使用setDeliveryMode方法，这样所有的消息都采用此传送模式，如：
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
- 使用send方法为每一条消息设置传送模式