- 浏览: 799812 次
- 性别:
- 来自: 西安
文章分类
- 全部博客 (307)
- struts (8)
- hibernate (3)
- spring (32)
- opensourceproject (12)
- javaScript (9)
- primeton EOS (2)
- journey of heart (10)
- Design pattern (6)
- ejb (17)
- point (37)
- Linux&Unix (22)
- ibatis (10)
- AJAX (6)
- DB (26)
- Protocol (6)
- chart (4)
- web server (11)
- webservice (7)
- integration (3)
- tuxedo (5)
- ext (4)
- android (1)
- c/c++ (12)
- JVM (1)
- paginationFrame (2)
- code (2)
- report (1)
- High-performance web (1)
- svn (1)
- JQuery (1)
- workDaily (2)
- cloud (16)
- Python (8)
- English (2)
- shell (5)
- googleCode (1)
- nio (1)
- hyper-v (1)
- debug (3)
- vbs (2)
- openstack (3)
- K8S (1)
- Mesos (0)
- Spark (0)
- Marathon (0)
最新评论
-
钱图大展:
chao2751021 写道lib包哪里去下载,找不到
大型网站用户行为记录的一个实现--基于clickStream(第一部分) -
钱图大展:
无法下载
大型网站用户行为记录的一个实现--基于clickStream(第一部分) -
fm395728572:
shell脚本中用到了环境变量,但是获取不到,例如脚本中有一句 ...
ganymed-ssh2 for Java -
liuhanjiang:
我qq147229234
大型网站用户行为记录的一个实现--基于clickStream(第一部分) -
liuhanjiang:
博主 我利用您提供的方法实现博文中介绍的clickstream ...
大型网站用户行为记录的一个实现--基于clickStream(第一部分)
消息驱动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 是队列模式 ,主题模式何其类似
附件中式 全部的工程代码
- ejb2test.rar (315.6 KB)
- 下载次数: 58
发表评论
-
本地客户端调用 websphere6.1 ejb资源 解决方案
2011-01-21 12:25 1779开发环境: 中我们都是在jboss4.0上部署ejb2. ... -
ejb2.0用本地引用提高EJB访问效率
2009-12-24 15:21 3000用本地引用提高EJB访问效率 EJB 1 ... -
ejb3.0 跨平台,跨JVM调用出现的问题及解决方案
2009-11-09 21:58 2326首先 ... -
ejb3 定时器开发
2009-10-28 08:35 3740定时服务用作在一段特定的时间后执行某段程序 ... -
ejb3 第12讲 --开发EJB容器模型的WEB服务
2009-08-05 08:04 3860JAX-WS JAX-WS规范是一组XML web ... -
ejb3 第10讲 --开发单表映射的实体bean
2009-08-02 23:29 1488目的:使用ejb3 ... -
ejb3 第9讲 --配置jboss数据源
2009-08-02 20:19 1095这个比较简单: 去$JBOSS_HOME\ ... -
ejb3 第8讲 --通过注解方式注入并使用其他EJB或者服务
2009-07-08 08:02 3246情景:有两个bean,一个是HelloWorldBean ... -
ejb3 第7讲 --开发有状态bean
2009-07-05 21:21 1396用 @Stateful 注解的方式表明 bean是有状态 ... -
ejb3 第6讲--开发具有本地接口的无状态bean
2009-07-03 07:01 2822理解: 1.当ejb的服务器端和客户端 ... -
ejb3 第5讲--通过ANT提高EJB应用的开发效率
2009-07-02 22:10 1430<?xml version="1.0" ... -
ejb3 第4讲--把jboss集成进eclipse
2009-06-29 22:45 1256这个比较简单,就不多说了 -
ejb3.0 第2,3讲-开发第一个无状态会话bean和客户端
2009-06-29 22:11 1659ejb中的3种bean: 什么是会话bea ... -
ejb3.0第11讲 --开发消息驱动bean
2009-06-24 08:23 2597概念: 1.java ... -
ejb3.0 --第1讲下载安装运行JBOSS
2009-06-24 07:08 15811.下载地址:jboss4.2.3http://www. ... -
ejb2.0 HelloWord
2008-09-27 07:38 7951中国电信网上营业厅项目是使用ejb2.0开发的,在项目中 ...
相关推荐
关于EJB2.0的相关资料,具体的有新的CMP组件模型,新的支持JMS的bean类型
EJB2.0 Entity bean(PDF).zip EJB2.0 Entity bean(PDF).zip
jboss是一个基于J2EE的开放源代码的应用服务器。 JBoss代码遵循LGPL许可,可以在任何商业应用...JBoss是一个管理EJB的容器和服务器,支持EJB 1.1、EJB 2.0和EJB3的规范。但JBoss核心服务不包括支持servlet/JSP的WEB容器
使用eclipse通过jboss开发简单的ejb应用(jboss7.x & ejb3.x),包含server和client。
里面清楚的讲解各个部分, ,资料仅作参考, 有兴趣兄弟赶紧去学学啊。希望有所帮助
ejb2.0的新特性介绍
ejb2.0 ejb3.0的区别,比较详细讲解两者的区别
精通EJB2.0 书籍源码
EJB2.0经典视频,深入浅出讲解了EJB2.0规范,及语法.并配备有经典的实例进行解析讲解,适合初学者研读。
EJB之消息驱动Bean的总结。ejb 消息驱动Bean j2ee jms java
ejb2.0开发
javax.ejb.EnterpriseBean.class javax.ejb.EntityBean.class javax.ejb.EntityContext.class javax.ejb.FinderException.class javax.ejb.Handle.class javax.ejb.HomeHandle.class javax.ejb.MessageDrivenBean....
图解eclipse+myelcipse开发EJB2.0 一个最令初学者理解的开发 代码+文字+图片
ejb的使用指南,我见过的最好的EJB书籍之一,希望能得到大家的喜爱
ejb 消息驱动Bean例子.有Queue,Topic
Ejb2.0经典教程,有需要的朋友看看吧,不错的哦!
EJB3.0开发Session Bean.rar EJB3.0开发Session Bean.rar
使用ejb2.0 ql教程代码