JMS（Java Message Service）
- API规范
- 模式
- 点对点
- 发布订阅
点对点
- 组成
- 消息队列（Queue）
- 发送者(Sender)
- 接收者(Receiver)
- 每个消息都被发送到一个特定队列，接收者从队列获取消息
- 队列保留着消息，直到他们被消费或超时
- 特点
- 每个消息只有一个消费者
- 发送者和接收者时间上没有依赖，接收者运行与否，不会影响消息被发送到队列
- 接收者成功收消息后需向队列应答
- 场景
- 如果你希望发送的每个消息都应该被成功处理的话，那么你需要P2P模式
发布订阅
- 组成
- 主题（Topic）
- 发布者（Publisher）
- 订阅者（Subscriber）
- 发布者将消息发送到Topic，系统将消息传递给多个订阅者
- 特点
- 每个消息可以有多个消费者
- 发布者和订阅者有时间上的依赖
- 针对某个主题（Topic），为了消费消息，订阅者必须保持运行的状态
- 为了缓和严格的时间相关性，JMS允许订阅者创建可持久化订阅；这样，即使订阅者没有被激活（运行），也能接收到发布者的消息
- 场景
- 如果希望发送的消息可以不被做任何处理、或被一个消费者处理、或可以被多个消费者处理的话，那么可以采用Pub/Sub模型
消费消息
- JMS中，消息的产生和消费是异步的
- 消费端而言，则有同步和异步2种
- 同步
- 消费者调用receive方法接收消息，接收到消息之前（或超时之前）将一直阻塞
- 异步
- 消费者注册为消息监听器；消息到达后，系统自动调用监听器的onMessage方法
- 同步
JMS编程模型
- ConnectionFactory
- QueueConnectionFactory
- TopicConnectionFactory
- Destination
- Queue
- Topic
- Connection
- 对socket的包装，可产生1到多个session
- QueueConnection
- TopicConnection
- Session
- 可以创建生产者，消费者，消息
- 有事务功能，可将多个消息动作放在一起
- QueueSession
- createReceiver(Queue)
- TopicSession
- createSubscriber(Topic)
- creatDurableSubscriber
- 生产者
- QueueSender.send
- TopicPublisher.publish
- 消费者
- QueueReceiver
- TopicSubscriber
- MessageListener
- 消息监听器
- 若注册了消息监听器，一旦消息到达，将自动调用监听器的onMessage方法
- EJB中的MDB（Message-Driven Bean）就是一种MessageListener
消息中间件
- MOM，Message Orient Middleware
- 用途和优点
- 应用间传递数据
- 建立网络通信通道，进行数据可靠传送
- 保证数据不重发，不丢失
- 跨平台，能够为不同操作系统上的软件集成提供数据传送
AMQP（Advanced Message Queuing Protocol）
- AMQP是一种协议，而JMS是一种API规范
- 消息服务应用层协议，基于此协议的客户端和消息中间件可传递消息，不受产品和开发语言等限制
- RabbitMQ是AMQP的一个完整实现
