JMS消息服务

JAVA--JMS消息服务规范相关知识点脑图描述,什么是消息服务，JMS能实现什么?

JMS消息服务

• JMS消息传送模型
  • 点对点传输模型
    • 1、点对点传输模型——适合于只有一个业务处理程序的场景  此模型由：消息发送者、消息队列、消息接收者[处理者] 组成。 每个消息只有一个接收者； 消息发送者和接收者并没有时间依赖性，互不可见。 当消息发送者发送消息的时候，无论接收者程序在不在运行，都能获取到消息； 当接收者收到消息的时候，会发送确认收到通知（acknowledgement）。
  • 发布/订阅 模型
    • 2、发布订阅 模型  此模型由 消息发送者、主题、多个订阅者 组成。 topic主要用于保存和传递消息，且会一直保存消息直到消息被传递给客户端。 一个消息可以传递给多个订阅者 发布者和订阅者有时间依赖性，只有当客户端创建订阅后才能接受消息，且订阅者需一直保持活动状态以接收消息。 为了缓和这样严格的时间相关性，JMS允许订阅者创建一个可持久化的订阅。这样，即使订阅者没有被激活（运行），它也能接收到发布者的消息。
• JMS消息接收方式
  • 同步接收
    • 1、同步接收 消息订阅者调用receive()方法。在receive()中，消息未到达或在到达指定时间之前，该方法会一直阻塞，直到有消息到来。
  • 异步接收
    • 2、异步接收 消息订阅者注册一个消息监听者，类似于事件监听器，只要消息到达，JMS服务提供者会通过调用监听器的onMessage()来处理消息。
• JMS编程接口组成
  • 
  • 连接工厂（Connection Factories）和目的地（Destination）
  • 连接（Connections）
  • 会话（Sessions）
  • 消息生产者（Message Producers）
  • 消息消费者（Message Consumers）
  • 消息监听者（Message Listeners）
• JMS的消息组成
  • 消息头
    • JMS消息头预定义了若干字段用于客户端与JMS提供者之间识别和发送消息，预编译头如下： – JMSDestination – JMSDeliveryMode – JMSMessageID – JMSTimestamp – JMSCorrelationID – JMSReplyTo – JMSRedelivered – JMSType – JMSExpiration – JMSPriority
  • 消息属性
    • 给消息设置自定义属性，这些属性主要是提供给应用程序的。对于实现消息过滤功能，消息属性非常有用，JMS API定义了一些标准属性，JMS服务提供者可以选择性的提供部分标准属性。
  • 消息体
    • JMS API定义了五种类型的消息格式： Text message : javax.jms.TextMessage，表示一个文本对象。 Object message : javax.jms.ObjectMessage，表示一个JAVA对象。 Bytes message : javax.jms.BytesMessage，表示字节数据。 Stream message :javax.jms.StreamMessage，表示java原始值数据流。 Map message : javax.jms.MapMessage，表示键值对。
• JMS使用步骤
  • 发送消息
    • 创建连接使用的工厂类JMS ConnectionFactory
    • 使用管理对象JMS ConnectionFactory建立连接Connection，并启动
    • 使用连接Connection 建立会话Session
    • 使用会话Session和管理对象Destination创建消息生产者MessageSender
    • 使用消息生产者MessageSender发送消息
  • 接受消息
    • 创建连接使用的工厂类JMS ConnectionFactory
    • 使用管理对象JMS ConnectionFactory建立连接Connection，并启动
    • 使用连接Connection 建立会话Session
    • 使用会话Session和管理对象Destination创建消息接收者MessageReceiver
    • 使用消息接收者MessageReceiver接受消息
      • 需要用setMessageListener将MessageListener接口绑定到MessageReceiver消息接收者中(必须实现了MessageListener接口，需要定义onMessage事件方法)
• JMS的实现
  • ActiveMQ
• SOAP与JMS对比
  • SOAP专注于远程服务调用，JMS专注于信息交换
  • 大多数情况下soap是两系统间的直接交互（Consumer <--> Producer）
  • 大多数情况下JMS是三方系统交互（Consumer <- Broker -> Producer）
  • JMS也可以实现request-response模式的通信，只要Consumer或Producer其中一方兼任broker即可
  • 多数情况下，WS是同步的，JMS是异步。虽然，WS也可以是异步的，而JMS也可以是同步的。
• JMS 与 RMI 的区别
  • 用 JMS 服务，对象是在物理上被异步从网络的某个 JVM 上直接移动到另一个 JVM 上
  • 而 RMI 对象是绑定在本地 JVM 中，只有函数参数和返回值是通过网络传送的
• JMS的使用场景
  • JMS一般适用于Web场景下的高并发处理
  • 消息分发
  • 点对点消息发送
  • 广播
  • 日志
• 为什么要用JMS
  • 异步处理，可以对应用进行解耦，提高应用并发
  • 可靠传递：JMS保证消息只会递送一次
  • 高并发时，应用无法同时响应海量的请求，而客户端无法一直阻塞等待后台完成逻辑处理，所以需要请求的收发与业务逻辑进行解耦
  • 常见场景：商品秒杀活动，大量用户共同抢购同一件商品，加入异步消息后，其过程是：用户发起秒杀请求，服务器接收请求后，向消息队列发送一个抢购的事件信息，并立刻返回结果“订单处理中”，客户避免客户等待。至于是否抢购成功，在后台处理完成抢购请求后，返回最终结果
• 什么是Java消息服务
  • JMS是java平台上的消息规范
  • 两个应用程序之间进行异步通信的API
  • 为标准消息协议和消息服务提供了一组通用接口
  • 包括创建、发送、读取消息等