J2EE的异步消息机制(上)

在分布式企业级应用程序中，异步消息机制用于有效地协调各个部分的工作。

J2EE为我们提供了JMS和消息驱动豆（Message-Driven Bean），用来实现应用程序各个部件之间的异步消息传递。

一．什么是消息系统？

通常一个消息系统允许分开的未耦合的应用程序之间可靠地异步通信。在企业应用时，需要一种异步的，非阻塞的消息传递。比如，一个客户端可能希望给一个服务器发送一个请求后，不在乎是否马上能得到回应。这样，客户端没有理由必须等待服务器处理请求。客户端应用程序在递交一个请求之后，只需确保请求到达服务器端后，就可以处理其他任务。通常，这是很高效的。消息系统提供了许多其他分布式对象计算模型没有的优点。它鼓励在消息产生者和使用者之间的"松耦合"，在它们之间有很高程度的事务处理。对于使用者，它不在乎谁产生了消息，产生者是否仍在网络上以及消息是什么时候产生的。这就允许建立动态的，可靠的和灵活的系统。整个的子系统能被修改而不会影响系统的其他部分。

另外的优点包括：系统的高度可扩展性，容易与其他系统进行集成，以及高度的可靠性。由于可靠性和可扩展性，使得它们用于解决许多商业和科学计算问题。比如，消息系统是许多应用程序的基础，这些应用程序可以是工作流，网络管理，通信服务或供应链管理程序。在JAVA技术中，处理异步消息的能力是通过JMS来实现的。JMS最初设计是为了给传统的消息对象中间件提供一个标准的JAVA接口。而这些产品是在一个企业级应用程序中必须的。现在出现了许多支持JMS的纯JAVA的产品。

消息系统类型

通常有两种消息类型。

1.发布/订阅（publish/subscribe）

发布/订阅消息系统支持一个事件驱动模型，消息产生者和使用者都参与消息的传递。产生者发布事件，而使用者订阅感兴趣的事件，并使用事件。产生者将消息和一个特定的主题（Topic）连在一起，消息系统根据使用者注册的兴趣，将消息传给使用者。

2.点对点（Peer to peer）

在点对点的消息系统中，消息分发给一个单独的使用者。它维持一个"进入"消息队列。消息应用程序发送消息到一个特定的队列，而客户端从一个队列中得到消息。

J2EE的异步消息机制(上)(2)

二．JMS简介

JMS的目的是提供给消息系统客户一个固定的接口，而且与底层的消息提供者无关。这样，客户端的应用程序可以在不同的机器和操作系统中移植，而且能在不同的消息系统产品之间转移。JMS客户端都是建立在JAVA技术上的，从而也能使用其他JAVAAPI，如JDBC数据库连接，使用JAVABEAN组件模型，JDNI名字服务，JTA客户端事务处理控制以及J2SE和J2EE API来实现企业级应用服务程序。

1.JMS对象模型

图1显示了JMS对象，用于提供JMS客户端与JMS服务提供者相连的对象。

ConnectionFactory是一个客户端用来创建一个Connection的管理对象。由于在Connection创建时有授权和通信建立过程，因此这个对象是比较大的。

Destination对象将一个消息的目的和服务提供者有关的地址及配置信息包装起来。

Session是JMS实体，用来支持事务处理和异步消息消费。JMS并不需要客户端的代码用于异步消息消费或能处理多个并发消息。通常，事务的复杂性都由一个Session来封装。

一个Session是一个原子单位的工作，与数据库的事务一样，要实现多线程事务比较困难。Session提供了在一个线程编程模式下的并发的优点。

MessageProducer和MessageConsumer对象由Session对象创建。用于发送和接受消息。为了确保消息的传递，JMS服务提供者处理的消息都要处于PERSISTENT模式。PERSISTENT模式使得JMS提供者出问题后，也能让消息保存下来。

Session，MessageProducer和MessageCons

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!