例子程序介绍
我们的Email应用程序将使用PTP域模型。当一个eamil被放入队列中时我们只希望一个接收者能够收到，另外email可以被多次发送。
JMS 消息被放入队列的条目是JMS消息。这是一个普通的消息，他拥有消息头和消息体。JMS消息有如下几个类型：
类型描述
TextMessage文本消息. 你可以通过msg.setText("foo")和msg.getText方法来操作TextMessageObjectMessage
这种消息存储序列化对象。你可以通过msg.setObject(Object o)和msg.getObject()来操作ObjectMessage.MapMessage
这种消息保存键/值对信息。你可以通过msg.setString(key,value)和msg.getString(key)来操作MapMessage.他还有其他几种getter和setter方法对应基本java类型（比如,getBoolean,getInt,getObject,等等）BytesMessage这种消息是一个字节流。他可被用于封装现有的消息格式。StreamMessage这种消息允许你发送java的原语流。在我们的例子中将使用一个MapMessage，因为他提供了一种方法可以让我们把email的标题信息和内容信息放到消息中。EJB 2.0消息驱动Bean我们已经讲述了JMS的基本概念，现在我们来谈一谈EJB2.0规范中的新概念。
回顾一下前面讲的JMS部分。我们有一个发送者，他把消息放到队列中，然后一个接收者将读取这个消息并使用接收到的信息来发送email。这个接收者可以是一个运行的程序，他接收“Email队列”中的消息。为了实现这个动作我们需要一个接收者，这个接收者的结构允许一个消息流的并行处理，同时它还要处理事务，这将使我们能够处理商业逻辑。这就是消息Bean的由来。也就是说一个消息Bean是一个简单的JMS消费者。一个客户端不能直接访问消息Beans（像你访问状态Bean那样)你只能通过发送JMS消息到消息Bean所侦听的目的地。为了达到重用的目的，像其他的EJB一样，许多的支持信息都在EJB部署描述符中。这意味着我们不必关心我们从那里获得消息(不管是一个queue或者是topic)，我们只需要写一个OnMessage(Message msg)方法来处理消息就可以了。我们已经讲述了JMS和MDB的知识；现在让我们开始我们的例子吧.Email 应用程序的开发步骤：我们将通过下面几步来完成email应用程序：在JMS服务器上安装一个“Email Queue”消息队列。创建一个email客户端，他负责向emial 队列发送java 消息。创建一个消息驱动Bean，他将处理这些消息，然后用这些信息用Email发送。为消息驱动Bean写部署描述符。打包代码。
将被创建的代码是：
代码
描述
com.customware.client.EmailClientemail客户端，他将把消息发送到队列中com.customware.ejb.EmailMDB消息驱动Bean将消耗来自客户端的JMS消息，并且使用EmailHelper来发送邮件。com.customware.util.EmailHelper一个助手类，他有一个静态方法sendmail(Map mail,这个方法将使用JavaMail发送邮件。
第一步：安装一个邮件消息队列
这一步将依赖于你的消息服务器（比如IBM MQSeries,SonicMQ，等等）。我们需要安装一个JMS 队列。我给他取名为EmailQueue，客户端和消息驱动Bean部署描述符要用到它。
第二步：创建一个Email客户端 (EmailClient.java)现在我们需要创建一个客户端(JMS sender)。这个客户端截获搜有关email的信息，然后把它发送出去。main()方法从命令行获得参数，创建一个Hashtable(用于存储Map),调用sendmail(Map m)方法。sendmail方法获得信息，根据获得的信息中创建一个MapMessage，再通过sender.send(message)把消息发送到EmailQueue队列中。主要的工作在构造函数之中，这些是JMS工作的全部内容。
下面是构造函数的内容：
1.通过getInitialContext（）助手方法连接到JNDI服务。
2.为队列查找一个连接工厂[(QueueConnectionFactory) ctx.lookup(CONNECTION_FACTORY)]
3.为我们的JMS服务器创建一个队列连接[conFactory.createQueueConnection()]
4.创建一个JMS会话(session)，这个会话用于生产和消费信息。[connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE)]5.查找队列，他将发送消息[(Queue) ctx.lookup(QUEUE_NAME)]6.最后创建一个发送者，这个发送者将使用会话（我们前面创建的）发送消息到我们查找到的队列中。
第三步：创建一个消息Bean (EmailMDB.java)在写会话 Bean或实体Bean时，你必须创建远程接口、主接口和Bean类（实体Bean还有一个可选的主键类）。而消息Bean只需要Bean类，因为有一个“客户端”他将作为Bean的接口。一个消息驱动Bean必须扩展两个接口：
接口描述
MessageListener
javax.jms.MessageListener这是JMS接口，他提供了一个onMessage(Message msg)方法。当一个消息放入队列中时，消息驱动Bean的onMessage方法将被调用，容器将传输实际的消息来被消费。MessageDrivenBean
javax.ejb.MessageDrivenBean这是EJB接口，他包含EJB生命周期的方法：ejbCreate(): 当EJB创建时容器会调用这个方法ejbRemove(): 当容器销毁EJB时调用setMessageDrivenContext(MessageDrivenContext ctx): 当对象被装载后ejbCreate()调用之前上下文环境被传输到EJB中. 上下文包含信息，容器保存这些信息并允许你查许、处理(getUserTransaction(), setRollbackOnly(), getRollbackOnly())
security (getCallerPrincipal(), isCallerInRole())
如果你看一下EmailMDB.java代码你会发现开头的几个方法实现了MessageDrivenBean接口。我们在这些方法中作的所有事情就是打印他们被调用的信息。setMessageDrivenContext()把上下文环境保存到实例变量中，以便我们今后能够找的到他。你要作的差不多就是这些了。最后要作的就是扩展MessageListener接口的onMessage(Message msg)方法。这就是我们消费消息并处理他们的过程。开始，我们通过抛出的消息创建一个MapMessage。然后我们从map消息中查找“键/”值对，把他们的值装入标准的Hashtable。注意，这些方法我们是通过MapMessage调用的：// 从Map Message获得键
Enumeration mapnames = mapmessage.getMapNames();
// 从MapMessage中获得值
String val = mapmessage.getString(key);
最后，调用 EmailHelper.sendmail(map)方法，把消息当作邮件发送出去。是不是很简单。这就是是消息驱动Bean重要的部分，我们没有写那些晦涩的JMS代码。实际上消息驱动Bean是如何知道从那里获得这些消息？这些我们是通过部署描述符来实现的。
