MQ消息队列（2）—— Java消息服务接口（JMS）

标签：you   方式   strong   code   顺序   结合   atd   red   形式   

一、理解JMS

  1、什么是JMS？

        JMS即Java消息服务（Java Message Service）应用程序接口，API是一个消息服务的标准或者说是规范，允许应用程序组件基于JavaEE平台创建、发送、接收和读取消息。它使分布式通信耦合度更低，消息服务更加可靠以及异步性。

　　我们可以简单的理解：两个应用程序之间需要进行通信，我们使用一个JMS服务，进行中间的转发，通过JMS 的使用，我们可以解除两个程序之间的耦合。

       JMS不是消息队列，更不是某种消息队列协议。JMS是Java消息服务接口，是一套规范的JAVA API 接口。

　　1）这套规范接口由SUN提出，并在2002年发布JMS规范的Version 1.1版本。

　　2）JMS和消息中间件厂商无关，既然是一套接口规范，就代表这它需要各个厂商进行实现。

　　3）大部分消息中间件产品都支持JMS 接口规范，eg: 可以使用JMS API来连接Stomp协议的产品（例如ActiveMQ）。

　　　  就像您可以使用JDBC API来连接ORACLE或者MYSQL一样。

2、JMS的消息模型

　JMS具有两种通信模式：（点对点）和（发布/订阅模式）。

3、JMS中消息的产生和消费

 在JMS中，消息的产生和消息是异步的。对于消费来说，JMS的消息者可以通过两种方式来消费消息。 
○ 同步 ：订阅者或接收者调用receive方法来接收消息，receive方法在能够接收到消息之前（或超时之前）将一直阻塞 
○ 异步 ：订阅者或接收者可以注册为一个消息监听器。当消息到达之后，系统自动调用监听器的onMessage方法。

4、对象模型

(1) ConnectionFactory
创建Connection对象的工厂，针对两种不同的jms消息模型，分别有QueueConnectionFactory和TopicConnectionFactory两种。可以通过JNDI来查找ConnectionFactory对象。

(2) Destination
Destination，即 消息生产者的 消息发送目标，或者说 消息消费者的 消息来源。

对于消息生产者来说，它的Destination是某个队列（Queue）或某个主题（Topic）;

对于消息消费者来说，它的Destination也是某个队列或主题（即消息来源）。

所以，Destination实际上就是两种类型的对象：Queue、Topic。可以通过JNDI来查找Destination。

(3) Connection
Connection表示在客户端和JMS系统之间建立的链接（对TCP/IP socket的包装）。

Connection可以产生一个或多个Session。

跟ConnectionFactory一样，Connection也有两种类型：QueueConnection和TopicConnection。

(4) Session
Session是我们操作消息的接口。可以通过session创建生产者、消费者、消息等。

Session提供了事务的功能。

当我们需要使用session发送/接收多个消息时，可以将这些发送/接收动作放到一个事务中。

同样，也分QueueSession和TopicSession。

(5) 消息的生产者
消息生产者由Session创建，并用于将消息发送到Destination。

同样，消息生产者分两种类型：QueueSender和TopicPublisher。

可以调用消息生产者的方法（send或publish方法）发送消息。

(6) 消息消费者
消息消费者由Session创建，用于接收被发送到Destination的消息。

两种类型：QueueReceiver和TopicSubscriber。

可分别通过session的createReceiver(Queue)或createSubscriber(Topic)来创建。

当然，也可以session的creatDurableSubscriber方法来创建持久化的订阅者。

(7) MessageListener
消息监听器。如果注册了消息监听器，一旦消息到达，将自动调用监听器的onMessage方法。

EJB中的MDB（Message-Driven Bean）就是一种MessageListener。

 5、消息的组成

 Message主要由三部分组成，分别是Header,Properties和Body, 解释如下：

1. Header: 消息头，所有类型的这部分格式都是一样的
2. Properties: 属性，按类型可以分为 应用设置的属性 ， 标准属性 和 消息中间件定义的属性
3. Body: 消息正文，指我们具体需要消息传输的内容。

消息头

消息属性

       消息属性的主要作用是可以对头信息进行一个额外的补充，毕竟消息头信息：一是有限，二是很多不能由应用程序设定。

　　通常，消息属性可以用在消息选择器的表达式里，结合起来实现对消息的过滤。

　　消息属性的值只能是基本的类型，或者这些基本类型对应的包装类型。也就是说，不能将一个自定义的对象作为属性值。

　　通常情况下，如果能够放在body里的内容，就不必放在消息属性里。

 消息体

       为了适应不同场景下的消息，提高消息存储的灵活性，JMS定义了几种具体类型的消息，不同的子类型的消息体也不一样。

　　需要注意的是，Message接口并没有提供一个统一的getBody之类的方法。

消息子接口定义如下：

1）TextMessage: 最简单的消息接口，用于发送文本类的消息，设置/获取其body的方法定义如下setText()/getText().

2）StreamMessage: 流式消息接口，里面定义了一系列的对基本类型的set/get方法，

　　　　　　　　　  消息发送者可以通过这些方法写入基本类型的数据，

　　　　　　　　　 消息接收者需要按发送者的写入顺序来读取相应的数据。

3）MapMessage：把消息内容存储在Map里，本接口定义了一系列对基本类型的的set/get方法，

                                与StreamMessage不同的是，每个值都对应了一个相应的key，

                                所以消息接收者不必按顺序去读取数据。

4）ObjectMessage: 将对象作为消息的接口，提供了一个set/get 对象的方法，需要注意的是只能设置一个对象，这个对象可以是一个Collection，但必须是序列化的。
5）BytesMessage: 以字节的形式来传递消息的接口，除了提供了对基本类型的set/get，还提供了按字节方式进行set/get。 

MQ消息队列（2）—— Java消息服务接口（JMS）

标签：you   方式   strong   code   顺序   结合   atd   red   形式   

原文地址：https://www.cnblogs.com/651434092qq/p/11082126.html