Java消息服务基础

核心提示：在不同系统之间交换信息的一大障碍是如何在精确交换和格式化数据方面取得一致，java Message Service（ Java消息服务，Java消息服务基础，简称JMS）通过提供一种与J2EE应用程序或传统系统交互的方法部分的解决了这个问题，

　　在不同系统之间交换信息的一大障碍是如何在精确交换和格式化数据方面取得一致。java Message Service（ Java消息服务，简称JMS）通过提供一种与J2EE应用程序或传统系统交互的方法部分的解决了这个问题。

　　JMS的通用接口集合以异步方式发送或接收消息。异步方式接收消息显然是使用间断网络连接的客户机，诸如移动电话和PDA的最好的选择。另外， JMS采用一种宽松结合方式整合企业系统的方法，其主要的目的就是创建能够使用跨平台数据信息的、可移植的企业级应用程序，而把开发人力解放出来。

　　Java消息服务支持两种消息模型：Point-to-Point消息(P2P)和发布订阅消息（Publish Subscribe messaging，简称Pub/Sub）。JMS规范并不要求供给商同时支持这两种消息模型，但开发者应该熟悉这两种消息模型的优势与缺点。

　　P2P消息模型是在点对点之间传递消息时使用。假如应用程序开发者希望每一条消息都能够被处理，那么应该使用P2P消息模型。与Pub/Sub消息模型不同，P2P消息总是能够被传送到指定的位置。

　　Pub/Sub模型在一到多的消息广播时使用。假如一定程度的消息传递的不可靠性可以被接受的话，那么应用程序开发者也可以使用Pub/Sub消息模型。换句话说，它适用于所有的消息消费程序并不要求能够收到所有的信息或者消息消费程序并不想接收到任何消息的情况。

　　JMS通过答应创建持久订阅来简化时间相关性，即使消息预订者未激活也可以接收到消息。此外，使用持久订阅还可通过队列提供灵活性和可靠性，而仍然答应消息被发给许多的接收者。
Topic Subscriber topic Subscriber =
topicsession.createDurableSubscriber(topic, subscriptionName);

Connection对象表示了到两种消息模型中的任一种的消息系统的连接。服务器端和客户机端对象要求治理创建的JMS连接的状态。连接是由Connection Factory创建的并且通过JNDI查寻定位。

//取得用于 P2P的 QueueConnectionFactory
QueueConnectionFactory = queueConnectionFactory( );
Context messaging = new InitialContext( );
QueueConnectionFactory = (QueueConnectionFactory)
Messaging.lookup(“QueueConnectionFactory”);

//取得用于 pub/sub的 TopicConnectionFactory
TopicConnectonFactory topicConnectionFactory;

Context messaging = new InitialContext();
topicConnectionFactory = (TopicConnectionFactory)
messaging.lookup(“TopicConnectionFactory”);

注重：用于P2P的代码和用于PublishSubscribe的代码非常相似。

　　假如session被标记为transactional的话，确认消息就通过确认和校正来自动地处理。假如session没有标记为 transactional，你有三个用于消息确认的选项。

　　· AUTO_ACKNOWLEDGE session将自动地确认收到一则消息。

　　· CLIENT_ACKNOWLEDGE 客户端程序将确认收到一则消息，调用这则消息的确认方法。

　　· DUPS_OK_ACKNOWLEDGE 这个选项命令session“懒散的”确认消息传递，可以想到，这将导致消息提供者传递的一些复制消息可能会出错。这种确认的方式只应当用于消息消费程序可以容忍潜在的副本消息存在的情况。

queueSession = queueConnection.createQueueSession(false, session.AUTO_ACKNOWLEDGE);//P2P

topicSession = topicConnection.createTopicSession(false, session.AUTO_ACKNOWLEDGE); //Pub-Sub

注重：在本例中，一个session目的从连结中创建，非值指出session是non-transactional的，并且 session将自动地确认收到一则消息。
　　JMS现在有两种传递消息的方式。标记为NON_PERSISTENT的消息最多投递一次，而标记为PERSISTENT的消息将使用暂存后再转送的机理投递。假如一个JMS服务离线，那么持久性消息不会丢失但是得等到这个服务恢复联机时才会被传递。所以默认的消息传递方式是非持久性的。即使使用非持久性消息可能降低内务和需要的存储器，并且这种传递方式只有当你不需要接收所有的消息时才使用。

　　虽然 JMS规范并不需要JMS供给商实现消息的优先级路线，但是它需要递送加快的消息优先于普通级别的消息。JMS定义了从0到9的优先级路线级别，0是最低的优先级而9则是最高的。更非凡的是0到4是正常优先级的变化幅度，而5到9是加快的优先级的变化幅度。举例来说：

topicPublisher.publish (message, DeliveryMode.PERSISTENT, 8, 10000); //Pub-Sub
或
queueSender.send(message, DeliveryMode.PERSISTENT, 8, 10000);//P2P