消息驱动Bean ：来自J2EE的轻量级的网络通信工具

   如果你要处理消息驱动Bean,那恭喜你，它比起实体Bean和会话Bean可是要轻松许多。关于消息驱动Bean的文档，你GOOGLE一下可以搜索出很多。我这里就不重复了。我写博文有个很重要的目的，是总结，是日记，是提醒自己。当然，走到这里的哥们，如果也能帮助你一下，我当然也是很乐意的，呵呵！
  
   我只对我觉得它比较重要的特性进行陈述，这些问题都是我看来很重要的。对真正使用它是起到很大帮助的。本篇可能会采取N次修改方案，不排除个人认识的错误性和局限性。NOW,现在开始总结了。

   消息驱动Bean是EJB2.0开始提出来的，它不同于PRC,RMI等机制，它采取了一个叫middleman的设计理念，我想把它弄出来肯定是有它的原因的。异步处理是逼迫这个叫中间人层出来的主要原因吧，它可以帮助程序设计者不要担心消息发送后的事情，也不要担心消息服务器出了什么问题，所以消息驱动Bean有无状态的特点。正是这个特点导致它的实现接口看上去那么的简单。

   消息驱动Bean能支持的是大概是两种消息传递模式：发布/订阅和点到点。发布订阅对应于主题模式(Topic)，点到点对应于队列模式(Queue)。JAVA消息服务接口就是这两种类型，你想使用不同类型的Bean当然就要实现不同的接口来帮你完成设计。

   JAVA消息服务的创建使用流程大概是：
   1.定位JAVA消息服务驱动程序
   2.创建消息连接
   3.创建消息服务会话
   4.定位消息服务目的地
   5.创建消息服务发生者或消息服务使用者
   6.发送或接收消息

   代码范式如下： 

  

import java.util.Hashtable;
import java.util.Properties;
import javax.naming.*;
import javax.jms.*;

public class Client {
	public static void main(String[] args) throws NamingException, JMSException {
		Hashtable ht = System.getProperties();
		//初始化JNDI
		Properties prop = new Properties();
		Context ctx = new InitialContext(prop);
		//通过JNDI查询获得连接工厂 
		TopicConnectionFactory factory = (TopicConnectionFactory) ctx.lookup("javax.jms.TopicConnectionFactory");
		//使用连接工厂创建主题类型JMS连接 
		TopicConnection conn = factory.createTopicConnection();
		//使用连接创建会话 
		TopicSession session = conn.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
		//通过JNDI查询消息目的地 
		Topic topic = (Topic) ctx.lookup("testtopic");
		//创建消息发生者 
		TopicPublisher publisher = session.createPublisher(topic);
		//创建文本消息，然后发布此消息 
		TextMessage msg = session.createTextMessage();
		msg.setText("I am a superman");
		publisher.publish(msg);
	}
}

 

   理解这段代码，你必须要提前理解JDBC的使用规范，很有点类似哦。工厂，连接，会话等概念，你也要必须心中有数。至于其他的，我清楚了，也就不说了。不明白可以GOOGLE查找其他知识点。

   EJB这个容器帮我解决了比如多线程并发请求，事物处理等复杂的事情。创建EJB的Bean可以不考虑这些问题，你可以用单线程思路来设计程序。EJB会自动实例化组件的多个实例来解决并发请求进行服务。最好不要在Bean中来控制线程，这样会导致EJB容器很难控制事务。

   EJB和消息服务集成后，就有了消息驱动Bean这个组件概念。EJB的消息驱动Bean就可以处理来自JMS的消息。它没有主接口，本地主接口，远程接口，所以它可以接受来自任何消息客户端。MOM（面向消息的中间件）就可以和EJB的消息驱动Bean进行通信。消息驱动Bean具有以下特点：
   1.接口只有一个方法
   2.不具备任何返回值
   3.不能发送异常给客户端
   4.无状态
   5.可以持久，也可以非持久

   提供一个示例程序： 
 

import javax.ejb.*;
import javax.jms.*;

public class TestBean implements MessageDrivenBean, MessageListener {

	private static final long serialVersionUID = 1L;

	protected MessageDrivenContext ctx;

	// 将此Bean实例同特殊上下文相联系
	public void setMessageDrivenContext(MessageDrivenContext ctx) {
		this.ctx = ctx;
	}

	// 初始化此Bean
	public void ejbCreate() {
		System.out.println("ejbCreate");
	}

	// 商务方法
	public void onMessage(Message msg) {
		if (msg instanceof TextMessage) {
			TextMessage tm = (TextMessage) msg;
			try {
				String text = tm.getText();
				System.out.println("Received new message:" + text);
			} catch (JMSException e) {
				e.printStackTrace();
			}
		}
	}

	// 销毁此Bean
	public void ejbRemove() {
		System.err.println("ejbRemove");
	}
}

 
   最后给出Bean的部署配置文件：
   ejb-jar.xml

<?xml version="1.0"?> 
<ejb-jar xmlns="http://java.sun.com/xml/ns/j2ee" 
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
  xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee 
                http://java.sun.com/xml/ns/j2ee/ejb-jar_2_0.xsd" 
  version="2.0"> 
  <message-driven>   
        <ejb-name>Test</ejb-name>        
        <ejb-class>TestBean</ejb-class>     
        <transaction-type>Container</transaction-type> 
        <message-driven-destination> 
          <destination-type>javax.jms.Topic</destination-type> 
        </message-driven-destination> 
  </message-driven> 
  </enterprise-beans> 
</ejb-jar>

补充说明：
<message-driven-destination>配置标签指定是用的主题还是队列消息，但是不指明绑定到哪个主题或队列，这个配置是应用服务器特定的部署描述符中完成的，不同的EJB服务商可能使用的配置符不尽相同，这样做是为了更好的跨应用服务器的移植。