J2EE 组件开发：消息驱动的EJB

　　一、概述
　　消息服务是一种在分布式应用之间提供消息传递服务的软件，具有可靠、异步、宽松结 合、语言中立、平台中立的特点，而且通常是可配置的。它的实现原理是：对发送者和接收者之间传递的消息进行封装，并在分布式消息客户程序结合的位置加上一个软件处理层。消息服务为消息的客户程序提供了一个接口，这个接口隔离了底层的消息服务， 使得各种不同的客户程序能够通过一个友好的编程接口方便地通信。
　　
　　Java消息服务（Java Message Service，JMS）是一个Java API，它定义了消息的客户程序如何以一种标准化的形式与底层的消息服务提供者交互。JMS提供了一种接口，底层消息服务提供者通过该接口向客户程序提供JMS消息服务。JMS提供了点对点消息模式（Point-to-Point）和发布-订阅消息模式（Publish-Subscribe）。点对点消息模式通过一
　　个消息队列实现，消息的生产者向队列写入消息，消息的消费者从队列提取消息。
　　
　　发布-订阅消息模式通过一个话题（Topic）节点构成的层次结构实现，消息的生产者向这个层次结构发布消息，消息的消费者向这个结构订阅消息。
　　点对点消息模式具有如下特点：
　　每一个消息只有一个消费者。
　　消息的接收者和发送者之间不存在时间上的依赖关系。不论发送者发送消息时接收者是 否在运行，接收者都可以提取信息。
　　接收者对于成功处理的消息给出回执。
　　
　　发布-订阅消息模式具有如下特点：
　　每一个消息可以有多个消费者。
　　向某个话题订阅的客户程序只能收到那些在它订阅之后发布的消息。为了接收到消息， 订阅者必须保持活动状态。因此，发布者和订阅者之间存在时间上的依赖关系。JMS API在一定程度上放宽了对这种依赖关系的要求，允许创建持久性订阅（Durable S ubscription）。有了持久性订阅，当订阅者不活动时发送的消息也能接收到。
　　
　　EJB 2.0规范定义了一种新的EJB类型，即消息驱动的EJB（Message-Driven EJB，简称MDB），它能够以EJB的形式实现JMS消息的接收者。消息驱动的EJB实现一组新的接口，这组接口使得EJB能够异步地接收和处理JMS消息生产者发送到队列或话题的消息。EJB客户程序的构造方式与普通JMS消息生产者的构造方式完全一样，也就是说，JMS消息生产者不必知道消息的消费者是一个EJB。相对于会话Bean和实体Bean而言，消息驱动的Bean最大的特点是客户程序不通过接口访 问Bean。与会话Bean和实体Bean不同，消息驱动的Bean只有一个Bean类。
　　
　　从某些方面看，消息驱动的Bean类似于无状态会话Bean：
　　消息驱动的Bean不为特定的客户保留数据或对话状态。
　　一个消息驱动Bean的所有的实例都是等价的，这使得容器能够把消息指派给任意一个消息驱动Bean的实例。容器能够建立消息驱动Bean的缓冲池，实现消息的并发处理。一个消息驱动的Bean能够处理来自多个客户程序的消息。
　　消息驱动Bean的实例变量可以在处理客户消息期间包含一些状态信息，例如JMS连接、打开的数据库连接，或者是对EJB对象的引用。当一个消息到达，容器调用消息驱动Bean的onMessage()方法处理消息。onMessage()方法通常把消息定型（cast）成为五种JMS消息类型之一，然后按照应用的业务逻辑的要求处理消息。
　　
　　传递给消息驱动Bean的消息可能处于一个事务之内，这时，onMessage()方法内的所有操作都属于该事务的一部分。如果消息处理结果被回退，则系统将再次投递该消息。哪些时候应该使用消息驱动的Bean呢？会话Bean和实体Bean能够发送JMS消息，能够同步接收消息，但不能异步接收。一些时候，为防止过多地占用服务器资源，在服务器端的组件中，我们想要避免阻塞，这时，我们可以用消息驱动的Bean异步接收消息。
　　
　　二、MDB体系结构
　　图一描述了消息驱动的Bean组件的基本体系结构。
　　在图一中，位于顶端的是javax.ejb.EnterpriseBean接口，它是所有EJB的基础接口。EnterpriseBean接口派生出了javax.ejb.MessageDrivenBean接口，所有消息驱动的EJB类
　　必须实现javax.ejb.MessageDrivenBean接口。此外，消息驱动的Bean必须实现javax.jms.MessageListener接口。公用的、非最终的、非抽象的消息驱动的EJB，比如图一显示的MyMessageDrivenEJBean，必须同时实现MessageListener接口和MessageDrivenBean接口。消息驱动的EJB与其他类型的EJB不同，它们不把业务方法导出给客户程序，它们关心的只是遵从EJB容器的接口要求。由于这个原因，消息驱动的Bean必须有一个不需要参
　　数的公用构造方法（ejbCreate()方法），而且不应该实现finalize()方法。
　　
　　2.1 MDB接口
　　在消息驱动的Bean中，setMessageDrivenContext()方法用来把一个MessageDrivenContext的对象实例传递给EJB，它是MessageDrivenBean接口定义中容器调用的第一个方法。
　　MessageDrivenContext对象封装了一个EJB消息驱动容器上下文的接口，支持消息驱动的EJB实例访问容器提供的运行时消息驱动上下文
　　对于消息驱动的EJB来说，关键之一是要实现一个没有参数的ejbCreate()方法。当EJB容器准备创建消息驱动EJB的实例时，它将调用这个方法。容器之所以决定创建某个EJB的实例，可能是因为它要构造一个Bean实例的缓冲池，也可能是因为它接收到了客户的请求。这个ejbCreate()方法和其他Bean上的EJB构造方法类似，属于EJB实现的一种特殊的构造函数或初始化方法。
　　当EJB容器准备不让Bean实例继续处理客户程序的请求时，它就会调用消息驱动Bean的ejbRemove()方法。何时在消息驱动的Bean上调用ejbRemove()方法由EJB容器单独决定，不受EJB客户程序的任何约束。应当注意的是，容器并不保证一定调用ejbRemove()方法 .在正常操作时，容器会调用ejbRemove()方法；但是，当消息驱动的Bean向容器抛出了
　　系统异常时，不能保证ejbRemove()方法一定会被调用。由于这个原因，Bean开发者必须按时检查和清除Bean分配的所有资源。
　　对于Bean开发者来说，最重要的任务也许是实现onMessage()方法。当一个异步消息必须由Bean实例处理时，容器将调用onMessage()方法。onMessage()方法的参数是一个普通的JMS javax.jms.Message的实例，消息驱动的EJB实例从这个Message的实例提取待处理的数据完成消息处理。
　　
　　2.2 JMS消息接口
　　那么，在onMessage()方法调用传入的 JMS消息中，消息驱动的Bean如何提取信息，可以提取哪些信息呢？图二描述了基本JMS消息类型的核心接口和概念。在一个以JMS为基础的消息系统中，Message接口是在系统中传递的所有消息的最基本的接口（或称之为根接口，Root Interface）。Destination接口描述了消息传递的一个终端；类似地，由于消息有一个传递模式，所以图二还显示了Message接口与DeliveryMode接口的概念上的关系。
　　JMS消息的头信息可以通过一组标准的方法设置或提取，这组标准方法的名字为getJMSXXX()或setJMSXXX()形式（下面我们分别称之为get方法和set方法），其中XXX是消息头信息中的属性名字，例如getJMSDeliveryMode()方法。在Message接口中，通过get方法和set方法操作的标准头信息属性包括：唯一的消息ID，时标（Timestamp），答复和目标地址，消息传递模式，消息类型，以及消息的优先级。
　　
　　在JMS消息中，JMS容器提供者特有的属性可以通过getXXXProperty()方法提取，或通过setXXXProperty()方法设置，其中XXX表示属性的类型，例如byte getByteProperty(java.lang.String name)。每一个属性有一个通过String对象指定的名字和相应的值。名字以JMSX前缀开头的属性作为标准JMS属性保留。与消息正文数据（或称之为消息体，与消息头相对而言）的五种类型对应，五种消息类型扩展了Message接口，如图三所示。Byte数据由BytesMessage封装，Serializable对象由ObjectMessage封装，String消息由TextMessage封装，键-值对由MapMessage封装，I
　　/O流由StreamMessage封装。
　　
　　这些派生消息类型上的方法为特定类型的消息正文定义了get和set操作，而在Message基础接口内，有一个通用的clearBody()方法，这个方法清除消息的正文，并把它置入只写模式。clearBody()方法只清除消息正文，不清除消息头或属性。如果消息正文是只读的，调用该消息后，消息正文的状态将和新消息的空白正文状态一样。
　　
　　2.3 MDB客户程序接口
　　消息驱动Bean的客户程序并不知道接收端实际处理消息的将是一个EJB。事实上，消息驱动Bean的客户程序的构造方法与普通JMS客户程序的构造方法完全一样。JMS的核心体系如图四所示。从图中我们可以看出，JMS ConnectionFactory（连接工厂）初始上下文通过Java名称和目录接口（Java Naming and Directory Interface，JND
　　I）创建。随后，连接工厂将用来创建与JMS服务提供者的连接。有了JMS连接，我们就可以获得创建消息生产者和消息消费者的会话（Session）。实际上，消息驱动Bean的客户程序就是消息的生产者，它发送的消息将由消息驱动的Bean（即消息消费者）接收。
　　
　　三、点对点消息队列模式
　　图五显示了在一个支持点对点消息队列的系统中JMS的基本体系结构。消息队列体系实际上是核心JMS体系的一个扩展，特别地，它加入了对消息队列功能的支持。连接工厂、连接、会话、消息生产者、消息消费者等都用点对点消息队列形式的接口进行了扩展。JMS客户程序利用JNDI获得一个QueueConnectionFactory对象的引用。随后，我们用Que
　　ueConnectionFactory.createQueueConnection()方法之一创建一个QueueConnection对象的实例。调用createQueueConnection()方法时可以指定一个用户名字和密码，或者，我们也可以使用该方法不带参数的版本，此时假定使用默认用户身份。QueueConnection接口是Connection接口的一种子类型，它代表着