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 社区所研发的 HornetQ
• Joram
• Coridan的MantaRay
• The OpenJMS Group的OpenJMS

JMS使用示例

基于Tomcat + JNDI + ActiveMQ实现JMS的点对点消息传送

JMS发布/订阅消息传送例子

译文连接（作了部分修改~~）

http://howtodoinjava.com/jms/jms-java-message-service-tutorial/

 

 

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