JMS（Java消息服务）入门教程

什么是Java消息服务　

　　Java消息服务指的是两个应⽤程序之间进⾏异步通信的API，它为标准消息协议和消息服务提供了⼀组通⽤接⼝，包括创建、发送、读取消息等，⽤于⽀持JAVA应⽤程序开发。在J2EE中，当两个应⽤程序使⽤JMS进⾏通信时，它们之间并不是直接相连的，⽽是通过⼀个共同的消息收发服务连接起来，可以达到解耦的效果，我们将会在接下来的教程中详细介绍。

为什么需要JMS

　　在JAVA中，如果两个应⽤程序之间对各⾃都不了解，甚⾄这两个程序可能部署在不同的⼤洲上，那么它们之间如何发送消息呢？举个例⼦，⼀个应⽤程序A部署在印度，另⼀个应⽤程序部署在美国，然后每当A触发某件事后，B想从A获取⼀些更新信息。当然，也有可能不⽌⼀个B对A的更新信息感兴趣，可能会有N个类似B的应⽤程序想从A中获取更新的信息。

　　在这种情况下，JAVA提供了最佳的解决⽅案-JMS，完美解决了上⾯讨论的问题。

　　JMS同样适⽤于基于事件的应⽤程序，如聊天服务，它需要⼀种发布事件机制向所有与服务器连接的客户端发送消息。JMS与RMI不同，发送消息的时候，接收者不需要在线。服务器发送了消息，然后就不管了；等到客户端上线的时候，能保证接收到服务器发送的消息。这是⼀个很强⼤的解决⽅案，能处理当今世界很多普遍问题。

JMS的优势

异步

　　JMS天⽣就是异步的，客户端获取消息的时候，不需要主动发送请求，消息会⾃动发送给可⽤的客户端。

可靠

　　JMS保证消息只会递送⼀次。⼤家都遇到过重复创建消息问题，⽽JMS能帮你避免该问题。

JMS消息传送模型

　　在JMS API出现之前，⼤部分产品使⽤“点对点”和“发布/订阅”中的任⼀⽅式来进⾏消息通讯。JMS定义了这两种消息发送模型的规范，它们相互独⽴。任何JMS的提供者可以实现其中的⼀种或两种模型，这是它们⾃⼰的选择。JMS规范提供了通⽤接⼝保证我们基于JMS API编写的程序适⽤于任何⼀种模型。

　　让我们更加详细的看下这两种消息传送模型：

点对点消息传送模型

　　在点对点消息传送模型中，应⽤程序由消息队列，发送者，接收者组成。每⼀个消息发送给⼀个特殊的消息队列，该队列保存了所有发送给它的消息(除了被接收者消费掉的和过期的消息)。点对点消息模型有⼀些特性，如下：

每个消息只有⼀个接收者；

消息发送者和接收者并没有时间依赖性；

当消息发送者发送消息的时候，⽆论接收者程序在不在运⾏，都能获取到消息；当接收者收到消息的时候，会发送确认收到通知（acknowledgement）。

发布/订阅消息传递模型订阅消息传递模型

　　在发布/订阅消息模型中，发布者发布⼀个消息，该消息通过topic传递给所有的客户端。在这种模型中，发布者和订阅者彼此不知道对⽅，是匿名的且可以动态发布和订阅topic。topic主要⽤于保存和传递消息，且会⼀直保存消息直到消息被传递给客户端。发布/订阅消息模型特性如下：

⼀个消息可以传递给多个订阅者

发布者和订阅者有时间依赖性，只有当客户端创建订阅后才能接受消息，且订阅者需⼀直保持活动状态以接收消息。

为了缓和这样严格的时间相关性，JMS允许订阅者创建⼀个可持久化的订阅。这样，即使订阅者没有被激活（运⾏），它也能接收到发布者的消息。

接收消息

　　在JMS中，消息的接收可以使⽤以下两种⽅式：

同步

　　使⽤同步⽅式接收消息的话，消息订阅者调⽤receive()⽅法。在receive()中，消息未到达或在到达指定时间之前，⽅法会阻塞，直到消息可⽤。

异步

　　使⽤异步⽅式接收消息的话，消息订阅者需注册⼀个消息监听者，类似于事件监听器，只要消息到达，JMS服务提供者会通过调⽤监听器的onMessage()递送消息。

JMS编程接⼝

　　JMS应⽤程序由如下基本模块组成：

1. 管理对象（Administered objects）-连接⼯⼚（Connection Factories）和⽬的地（Destination）2. 连接对象（Connections）3. 会话（Sessions）

4. 消息⽣产者（Message Producers）5. 消息消费者（Message Consumers）6. 消息监听者（Message Listeners）

JMS管理对象

管理对象（Administered objects）是预先配置的JMS对象，由系统管理员为使⽤JMS的客户端创建，主要有两个被管理的对象：

连接⼯⼚（ConnectionFactory）⽬的地（Destination）

这两个管理对象由JMS系统管理员通过使⽤Application Server管理控制台创建，存储在应⽤程序服务器的JNDI名字空间或JNDI注册表。

连接⼯⼚（ConnectionFactory）

客户端使⽤⼀个连接⼯⼚对象连接到JMS服务提供者，它创建了JMS服务提供者和客户端之间的连接。JMS客户端（如发送者或接受者）会在JNDI名字空间中搜索并获取该连接。使⽤该连接，客户端能够与⽬的地通讯，往队列或话题发送/接收消息。让我们⽤⼀个例⼦来理解如何发送消息：

QueueConnectionFactory queueConnFactory = (QueueConnectionFactory) initialCtx.lookup (\"primaryQCF\");Queue purchaseQueue = (Queue) initialCtx.lookup (\"Purchase_Queue\");Queue returnQueue = (Queue) initialCtx.lookup (\"Return_Queue\");

⽬的地（Destination）

⽬的地指明消息被发送的⽬的地以及客户端接收消息的来源。JMS使⽤两种⽬的地，队列和话题。如下代码指定了⼀个队列和话题。创建⼀个队列Session

QueueSession ses = con.createQueueSession (false, Session.AUTO_ACKNOWLEDGE); //get the Queue object Queue t = (Queue) ctx.lookup (\"myQueue\"); //create QueueReceiver QueueReceiver receiver = ses.createReceiver(t); 创建⼀个话题Session

TopicSession ses = con.createTopicSession (false, Session.AUTO_ACKNOWLEDGE); // get the Topic object Topic t = (Topic) ctx.lookup (\"myTopic\"); //create TopicSubscriber TopicSubscriber receiver = ses.createSubscriber(t);

JMS连接

连接对象封装了与JMS提供者之间的虚拟连接，如果我们有⼀个ConnectionFactory对象，可以使⽤它来创建⼀个连接。Connection connection = connectionFactory.createConnection();创建完连接后，需要在程序使⽤结束后关闭它：connection.close();

JMS 会话（Session）

Session是⼀个单线程上下⽂，⽤于⽣产和消费消息，可以创建出消息⽣产者和消息消费者。Session对象实现了Session接⼝，在创建完连接后，我们可以使⽤它创建Session。Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

JMS消息⽣产者

消息⽣产者由Session创建，⽤于往⽬的地发送消息。⽣产者实现MessageProducer接⼝，我们可以为⽬的地、队列或话题创建⽣产者；MessageProducer producer = session.createProducer(dest);MessageProducer producer = session.createProducer(queue);MessageProducer producer = session.createProducer(topic);创建完消息⽣产者后，可以使⽤send⽅法发送消息：producer.send(message);

JMS消息消费者

消息消费者由Session创建，⽤于接受⽬的地发送的消息。消费者实现MessageConsumer接⼝，，我们可以为⽬的地、队列或话题创建消费者；MessageConsumer consumer = session.createConsumer(dest);MessageConsumer consumer = session.createConsumer(queue);MessageConsumer consumer = session.createConsumer(topic);

JMS消息监听器

JMS消息监听器是消息的默认事件处理者，他实现了MessageListener接⼝，该接⼝包含⼀个onMessage⽅法，在该⽅法中需要定义消息达到后的具体动作。通过调⽤setMessageListener⽅法我们给指定消费者定义了消息监听器Listener myListener = new Listener();

consumer.setMessageListener(myListener);

JMS消息结构

JMS客户端使⽤JMS消息与系统通讯，JMS消息虽然格式简单但是⾮常灵活， 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服务的提供者，如下：

JBoss 社区所研发的 HornetQJoram

Coridan的MantaRay

The OpenJMS Group的OpenJMS

JMS使⽤⽰例

译⽂链接（做了部分修改~~）

以上就是JMS的⼊门教程，学习愉快~