`
8366
  • 浏览: 809277 次
  • 性别: Icon_minigender_1
  • 来自: 西安
社区版块
存档分类
最新评论

ejb2.0消息驱动bean的开发(JBOSS4.0.4.GA 环境)

    博客分类:
  • ejb
阅读更多

 

          消息驱动bean主要使用在异步的业务中,比如用户在页面上查询了话费(余额,实时话费,语音,短信。。。),我们需要把用户这个行为记录到数据库中,就可以使用消息驱动bean。

           首先使用springAOP 拦截到 调用的 业务方法,发现是业务关注的方法的时候,在invoke 方法中发送一条消息到消息队列中去,(此业务场景我们使用 点对点的 消息发送模式)然后 ,消息驱动bean从监听的队列中取到消息,插入到数据库中。查询话费 和 将行为入库 是异步的,因此不会阻塞。不影响前台页面显示速度。

 

 

开发一个消息驱动bean 的步骤:

 

 

1.首先 写 消息驱动bean ,负责从消息队列中取消息,然后执行相应的业务方法

 

 

package cn.com.xinli.ejb.mdb;
import javax.ejb.EJBException;
import javax.ejb.MessageDrivenBean;
import javax.ejb.MessageDrivenContext;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import org.apache.log4j.Logger;

public class MDBean implements MessageDrivenBean,MessageListener
{
	Logger log=Logger.getLogger(MDBean.class);
	private transient MessageDrivenContext mdc = null;
	public void onMessage(Message message)
	{		
		if(message instanceof TextMessage)
		{
			TextMessage msg=(TextMessage) message; 
			try {
				log.info("接收到消息:"+msg.getText());
			} catch (JMSException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		else
		{
			log.info("消息类型不正确!"); 
		}
	}
	 public void ejbCreate() 
	 {
		  
	 }
	public void ejbRemove() throws EJBException
	{
		// TODO Auto-generated method stub
		
	}
	public void setMessageDrivenContext(MessageDrivenContext mdc)
			throws EJBException
	{
		this.mdc = mdc;
		// TODO Auto-generated method stub
	}

}

 

 

2. 配置 ejb-jar.xml

 

<?xml version="1.0" encoding="gb2312"?> 
<!DOCTYPE ejb-jar PUBLIC "-//Sun Microsystems, Inc.//DTD Enterprise JavaBeans 2.0//EN" 
"http://java.sun.com/dtd/ejb-jar_2_0.dtd">
<ejb-jar>
	<description>ejb</description>
	<display-name>myEJBTest</display-name>
<enterprise-beans>

		
			<message-driven id="ejb_mdb">
			<ejb-name>mdb</ejb-name>
            <ejb-class>cn.com.xinli.ejb.mdb.MDBean</ejb-class>
           	<transaction-type>Bean</transaction-type>
           	<acknowledge-mode>Auto-acknowledge</acknowledge-mode>
           	<message-driven-destination>
            <destination-type>javax.jms.Queue</destination-type> 
            </message-driven-destination>
		</message-driven>
	</enterprise-beans>
</ejb-jar>

 

 

3. 配置 jboss.xml

 

<?xml version="1.0" encoding="gb2312"?>
<jboss>
	
	<message-driven>
        <ejb-name>mdb</ejb-name>    
        <configuration-name>Standard Message Driven Bean</configuration-name>
        <!-- 消息驱动bean 监听的消息队列的 JNDI
        <destination-jndi-name>queue/mdb</destination-jndi-name>  
        -->
      </message-driven> 
	</enterprise-beans>
</jboss>

 

 

4. 讲bean 打成jar包 放在 D:\jboss-4.0.4.GA\server\default\deploy 下

 

5. 在jboss中配置消息队列 也在 D:\jboss-4.0.4.GA\server\default\deploy 下 ,配置文件必须 符合  *-service.xml  的命名规范,这里我们叫 bsn-service.xml

 

<?xml version="1.0" encoding="UTF-8"?>

<!-- $Id: jbossmq-destinations-service.xml,v 1.4.6.1 2004/11/16 04:32:39 ejort Exp $ -->

<!-- 
   | This file defines the default Queues and Topics that JBossMQ
   | ships with.  The default Queues and Topics are used by the 
   | JBoss test suite and by the sample jms programs.
   |
   | You can add other destinations to this file, or you can create other
   | *-service.xml files to contain your application's destinations.
 -->

<server>
  <!-- Destination without a configured SecurityManager or without a 
       a SecurityConf will default to role guest with read=true, write=true,
       create=false.
  -->
  <mbean code="org.jboss.mq.server.jmx.Queue" 
	 name="jboss.mq.destination:service=Queue,name=queueRecordb">
	  <attribute name="JNDIName">queue/mdb</attribute> 
   <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
  </mbean>
</server>

  

 

6.发布

 

7.客户端测试,观察 JBOSS 控制台 会有

 

09:43:36,156 INFO  [MDBean] 接收到消息:你好

 

package cn.com.xinli.ejb.test;

import java.util.Properties;

import javax.jms.Destination;
import javax.jms.MessageProducer;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.InitialContext;

import org.apache.log4j.Logger;

public class Test
{

	static Logger log=Logger.getLogger(Test.class);
	/**
	 * @param args
	 */
	public static void main(String[] args)
    {
		
       
        Properties props = new Properties();
        props.setProperty("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
        props.setProperty("java.naming.provider.url", "localhost:1099");
        props.setProperty("java.naming.factory.url.pkgs", "org.jboss.naming");
        try
        {
            InitialContext ctx = new InitialContext(props);
            
        	QueueConnectionFactory factory=(QueueConnectionFactory)ctx.lookup("QueueConnectionFactory");
			QueueConnection conn=factory.createQueueConnection();
			
			QueueSession session=conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
			
			Destination destination=(Destination)ctx.lookup("queue/mdb");
			MessageProducer producer = session.createProducer(destination);
			
			TextMessage msg = session.createTextMessage("你好");
			producer.send(msg);
			log.info("发送消息成功!!");
            
            /*
            Object objRef = ctx.lookup("helloEJB");
            
            HelloWorldHome home = (HelloWorldHome) PortableRemoteObject.narrow(objRef, HelloWorldHome.class);
            
            HelloWorldRemote remote = home.create();
            
            log.info(remote.sayHello());
            */
        }
        catch (Exception ex)
        {
            ex.printStackTrace();
        }
    }
}

  

 

备注:

 

1. 许多教程上说 必须要到   D:\jboss-4.0.4.GA\server\default\deploy  配置一个 消息队列 类似 bsn-service.xml

    其实这不是必要的

 

如果我们没有配置  a ,b

a.     <!-- 消息驱动bean 监听的消息队列的 JNDI-->
        <destination-jndi-name>queue/mdb</destination-jndi-name> 

b.   也没有配置 bsn-service.xml 那么JBOSS启动的时候发现没有队列和消息驱动bean 关联,则它会自己创建一个消息队列 ,这个消息对列的命名规范 是   : queue/消息驱动bean的jndi

 

      客户端就可以往这个队列 上发送消息。

 

2. 如果我们配置了 消息驱动bean 关联的队列 和 JBosS下的 bsn-service.xml ,那么我们就可以使用自定义的 队列的JNDI了 比如

 

  a. 配置 mdb 这个消息驱动bean 监听的 对列的JNDI 为

<destination-jndi-name>myqueue</destination-jndi-name> 

 

b.配置 bsn-service.xml的内容为

 

<?xml version="1.0" encoding="UTF-8"?>

<!-- $Id: jbossmq-destinations-service.xml,v 1.4.6.1 2004/11/16 04:32:39 ejort Exp $ -->

<!-- 
   | This file defines the default Queues and Topics that JBossMQ
   | ships with.  The default Queues and Topics are used by the 
   | JBoss test suite and by the sample jms programs.
   |
   | You can add other destinations to this file, or you can create other
   | *-service.xml files to contain your application's destinations.
 -->

<server>
  <!-- Destination without a configured SecurityManager or without a 
       a SecurityConf will default to role guest with read=true, write=true,
       create=false.
  -->
  <mbean code="org.jboss.mq.server.jmx.Queue" 
	 name="jboss.mq.destination:service=Queue,name=queueRecordb">
	  <attribute name="JNDIName">myqueue</attribute> 
   <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
  </mbean>
</server>

  

 

 

 

 

那么客户端就可以往 我们自定义的 队列的JDNI上  myqueue  发送消息了

 

3.  在JBOSS中有两个默认的工厂 一个是 QueueConnectionFactory

另外一个是 TopicConnectionFactory ,这两个工厂是由JBOSS容器帮我们建立的 ,不需要我们去配置,而在websphere 上建立消息驱动bean的时候 就需要我们配置 连接工厂了

 

4. 以上模拟的的消息驱动bean 是队列模式 ,主题模式何其类似 

 


附件中式 全部的工程代码

 

 

 

 

 

 

分享到:
评论
1 楼 lixw 2009-10-23  
很好的例子,受教了!

相关推荐

    下载和安装jboss-4.0.4.GA 服务器

    本篇文章将详细介绍如何下载与安装JBoss 4.0.4.GA版本,并配置必要的环境变量,以及进行基本的功能验证。 #### 二、下载 首先,我们需要从官方源或可靠的第三方资源下载JBoss 4.0.4.GA的安装包。根据提供的部分内容...

    jboss-4.0.5.GA.zip

    2. **EJB 3.0**:JBoss 4.0.5.GA实现了EJB 3.0规范,简化了Enterprise JavaBeans的开发,通过注解(Annotation)可以轻松地声明bean的属性,无需XML配置文件,提高了开发效率。 3. **JPA**:这一版本引入了JPA作为...

    EJB2.0 Entity bean(PDF) .zip_EJB2 enti_EJB2.0 P_ejb_ejb2 CMP sup

    **企业级JavaBeans (EJB) 2.0 实体Bean详解** EJB(Enterprise JavaBeans)是Java EE(Enterprise Edition)平台的核心组件之一,它为构建可部署在服务器端的分布式应用程序提供了一种框架。EJB 2.0是EJB规范的一个...

    jboss-4.2.3.GA_下的jboss-4.2.3.GA_下的

    1. **EJB容器**:JBoss 4.2.3.GA支持EJB 3.0规范,简化了企业级组件的开发,允许开发者通过注解来定义bean的行为,无需XML配置。 2. **JMS支持**:集成JMS服务,允许应用进行异步通信和消息队列处理,提供高可用性...

    EJB2.0 实例开发

    EJB2.0作为其一个重要版本,引入了许多特性,如会话bean、实体bean和消息驱动bean,以及容器管理持久性(CMP)等。本实例开发将深入探讨EJB2.0的核心概念,特别是会话bean的实例化与使用。 1. **会话Bean(Session ...

    jboss-5.1.0.GA 下载地址

    2. **EJB 3.0**:企业JavaBean(EJB)3.0是Java EE 5中的核心部分,简化了EJB的使用,引入了无状态会话bean、有状态会话bean和实体bean的概念,以及注解驱动的编程模型,使得开发更为简洁。 3. **Java Persistence ...

    ejb2.0.rar_EJB2.0特性_ejb2.0

    2. **Message-driven Beans (MDB)**:EJB2.0引入了消息驱动Bean,这是一种特殊类型的session Bean,用于处理JMS(Java Message Service)消息。MDB使得异步处理和解耦通信成为可能,提高了系统的可扩展性。 3. **...

    精通EJB2.0 书籍源码

    EJB2.0是EJB技术的一个里程碑,引入了会话bean、实体bean和消息驱动bean的概念,以及容器管理的持久性(CMP)和bean管理的持久性(BMP)。 2. **env.bat和startWebLogic.bat**:这两个文件通常是与Oracle WebLogic ...

    EJB2.0开发.rar_EJB2.0 pdf_ejb_ejb 2_ejb2.0_websphere

    - **消息驱动Bean(Message-driven Beans,MDB)**:用于处理JMS(Java Message Service)消息,是异步处理的好选择。 - **实体Bean(Entity Beans)**:代表持久化数据,分为容器管理的持久性(CMP)和bean管理的...

    全面研读EJB2.0规范

    EJB2.0规范主要包含三种类型的组件:会话Bean(Session Beans)、实体Bean(Entity Beans)和消息驱动Bean(Message-Driven Beans)。这些组件提供了业务逻辑的封装,使得开发者能够专注于业务处理,而不是底层的...

    ejb2.0与ejb3.0的区别

    - **EJB 3.0**:增强了消息驱动Bean的功能,使其能够更灵活地处理异步消息传递。 - **EJB 3.0**:引入了新的注解,如`@Stateless`、`@Stateful`、`@Singleton`等,使得EJB的类型和行为更加明确。 - **EJB 3.0**:...

    jboss-4.2.2.GA

    1. **安装**:用户可以通过下载解压`jbos-4.2.2.GA`压缩包,然后根据需要配置环境变量,如JAVA_HOME和JBOSS_HOME。 2. **启动与停止**:使用`bin/run.sh`(Linux/Unix)或`bin/run.bat`(Windows)脚本启动服务器,...

    ejb2.0开发

    EJB 2.0的核心概念包括会话bean、实体bean和消息驱动bean,它们各自承担不同的职责,共同构建出强大的后端系统。 1. **会话Bean**: 会话Bean代表了客户端与服务器之间的交互逻辑,可以理解为业务服务。它们分为无...

    EJB2.0

    2. 消息驱动Bean(Message-Driven Beans,MDB):这是EJB2.0引入的新特性,主要用于处理JMS(Java Message Service)消息。MDB充当消息消费者,自动接收和处理来自消息队列的消息,简化了异步处理和解耦设计。 3. ...

    Ejb2.0教程-java教程

    EJB 2.0 主要由三种类型的组件组成:Entity Beans(实体Bean)、Session Beans(会话Bean)和Message Driven Beans(消息驱动Bean)。实体Bean用于表示数据库中的持久化对象,会话Bean用于处理业务逻辑,而消息驱动...

    ejb2.rar_ejb2_ejb2.0

    EJB 2.0的核心目标是提供一种标准的、面向对象的方法来构建企业级应用,它定义了三个主要组件类型:会话bean(Session Beans)、实体bean(Entity Beans)和消息驱动bean(Message-Driven Beans)。这些组件可以在...

    jboss-4.2.3.GA.zip

    【描述】中提到的四个jar文件——`jboss-jaxws.jar`、`jboss-jaxws-ext.jar`、`jboss-jaxrpc.jar`和`jboss-saaj.jar`,都是针对Web服务(WebService)的关键组件,它们对于在JBoss 4.2.3.GA环境中运行Web服务至关...

    EJB2和EJB3 消息驱动bean

    ### EJB2与EJB3消息驱动Bean:深入解析与应用 #### 一、EJB2消息驱动Bean ##### 1. **理解消息驱动Bean(MDB)** 消息驱动Bean是Java EE中用于处理异步消息的一种特殊类型的EJB。在EJB2中,MDB主要用于接收来自消息...

Global site tag (gtag.js) - Google Analytics