- 浏览: 88643 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
518ts520:
03:07:24,852 INFO [ServiceInvo ...
JBoss ESB学习笔记16——第十五个ESB应用Web Service Consumer 1 -
dy.f:
你理解错误了,selector="type='fro ...
JBoss ESB学习笔记5——第四个ESB应用Hello World File Action -
xiaoshalou_2002:
错误贴上 。Exception in thread &q ...
JBoss ESB学习笔记12——第十一个ESB应用Spring Hello World -
xiaoshalou_2002:
我这边16个例子中的客户端运行都出错,是少了 ...
JBoss ESB学习笔记12——第十一个ESB应用Spring Hello World -
qianyang:
ligenhang 写道我部署也报java.lang.Runt ...
JBoss ESB学习笔记2——第一个ESB应用Hello World
续上篇介绍了第十一个ESB应用,本文介绍第十二个ESB应用——Spring AOP。
说明:本文及后续文章虽非百分百的原创,但毕竟包含本人的努力和付出,所以希望大家转载时务请注明出处:http://yarafa.iteye.com,谢谢合作。
1 概述
本实例主要演示了Spring AOP在ESB中的应用。
2 新建ESB工程
新建ESB工程,在jbossesb-server-4.7中找到以下两个jar包:jbossesb-spring.jar和spring-2.5.6.SEC01.jar,并将这两个jar包复制到esbcontent/lib目录下,同时添加到项目的classpath。Jar包的具体位置不记得了,大家直接搜索就行。
3 ESB配置
3.1 创建消息队列
<?xml version="1.0" encoding="UTF-8"?> <server> <mbean code="org.jboss.jms.server.destination.QueueService" name="jboss.esb.quickstart.destination:service=Queue,name=springaopRequest" xmbean-dd="xmdesc/Queue-xmbean.xml"> <depends optional-attribute-name="ServerPeer"> jboss.messaging:service=ServerPeer </depends> <depends>jboss.messaging:service=PostOffice</depends> </mbean> <mbean code="org.jboss.jms.server.destination.QueueService" name="jboss.esb.quickstart.destination:service=Queue,name=springaopResponse" xmbean-dd="xmdesc/Queue-xmbean.xml"> <depends optional-attribute-name="ServerPeer"> jboss.messaging:service=ServerPeer </depends> <depends>jboss.messaging:service=PostOffice</depends> </mbean> <mbean code="org.jboss.jms.server.destination.QueueService" name="jboss.esb.quickstart.destination:service=Queue,name=springaopEsb" xmbean-dd="xmdesc/Queue-xmbean.xml"> <depends optional-attribute-name="ServerPeer"> jboss.messaging:service=ServerPeer </depends> <depends>jboss.messaging:service=PostOffice</depends> </mbean> </server>
3.2 定义Provider
这里将定义一个JMS Provider,并定义2个消息通道,内容如下:
<jms-provider connection-factory="ConnectionFactory" name="JBossMQ"> <jms-bus busid="gwChanel"> <jms-message-filter dest-name="queue/springaopRequest" dest-type="QUEUE" /> </jms-bus> <jms-bus busid="esbChanel"> <jms-message-filter dest-name="queue/springaopEsb" dest-type="QUEUE" /> </jms-bus> </jms-provider>
3.3 定义Service
<service category="SpringAop" description="Spring Aop" name="SpringAopService"> <listeners /> <actions mep="OneWay"> <action /> </actions> </service>
3.4 定义Listener
<listeners> <jms-listener busidref="gwChanel" is-gateway="true" name="gwListener" /> <jms-listener busidref="esbChanel" name="esbListener" /> </listeners>
3.5 定义Java Bean
这是一个普通的JavaBean,为了验证Spring在ESB中的IOC而引入。
/*********************************************************************** * <p>Project Name: springaop</p> * <p>File Name: com.thu.afa.esb.jbossesb.action.SaySomething.java</p> * <p>Copyright: Copyright (c) 2010</p> * <p>Company: <a href="http://afa.thu.com">http://afa.thu.com</a></p> ***********************************************************************/ package com.thu.afa.esb.jbossesb.action; /** * <p>Class Name: SaySomething</p> * <p>Description: </p> * @author Afa * @date 2010-9-16 * @version 1.0 */ public class SaySomething { private String greeting; public String getGreeting() { return greeting; } public void setGreeting(String greeting) { this.greeting = greeting; } }
3.6 定义Action
/*********************************************************************** * <p>Project Name: springaop</p> * <p>File Name: com.thu.afa.esb.jbossesb.action.MySpringEnabledAction.java</p> * <p>Copyright: Copyright (c) 2010</p> * <p>Company: <a href="http://afa.thu.com">http://afa.thu.com</a></p> ***********************************************************************/ package com.thu.afa.esb.jbossesb.action; import org.jboss.soa.esb.actions.AbstractSpringAction; import org.jboss.soa.esb.helpers.ConfigTree; import org.jboss.soa.esb.message.Message; /** * <p>Class Name: MySpringEnabledAction</p> * <p>Description: </p> * @author Afa * @date 2010-9-16 * @version 1.0 */ public class MySpringEnabledAction extends AbstractSpringAction { @SuppressWarnings({"deprecation" }) public MySpringEnabledAction(final ConfigTree configTree) { this.configTree = configTree; } public Message sayHelloAopStyle(Message message) throws Exception { SaySomething saySomething = (SaySomething) getBeanFactory().getBean("saySomething"); String helloString = (String) message.getBody().get(); saySomething.setGreeting(helloString); message.getBody().add(saySomething.getGreeting()); return message; } }
注意:这里的action 扩展的是AbstractSpringAction类,而不是AbstractActionLifecycle。这里在对调用setGreeting方法进行了拦截,具体配置会在下面的配置中说明。
3.7 定义拦截器
/*********************************************************************** * <p>Project Name: springaop</p> * <p>File Name: com.thu.afa.esb.jbossesb.action.MyInterceptor.java</p> * <p>Copyright: Copyright (c) 2010</p> * <p>Company: <a href="http://afa.thu.com">http://afa.thu.com</a></p> ***********************************************************************/ package com.thu.afa.esb.jbossesb.action; import java.lang.reflect.Method; import org.springframework.aop.AfterReturningAdvice; /** * <p>Class Name: MyInterceptor</p> * <p>Description: </p> * @author Afa * @date 2010-9-16 * @version 1.0 */ public class MyInterceptor implements AfterReturningAdvice { /* (non-Javadoc) * <p>Title: </p> * <p>Method Name: afterReturning</p> * <p>Description: </p> * @author: Afa * @date: 2010-9-16 * @see org.springframework.aop.AfterReturningAdvice#afterReturning(java.lang.Object, java.lang.reflect.Method, java.lang.Object[], java.lang.Object) * * @param returnValue * @param method * @param args * @param target * @throws Throwable */ public void afterReturning(Object returnValue, Method method, Object[] args, Object target) throws Throwable { SaySomething something = (SaySomething) target; System.out.println(something.getGreeting()); System.out.println("*****GREETING VALUE PRE-INTERCEPTOR*****"); System.out.println(something.getGreeting()); something.setGreeting("I used AOP to change the greeting! JMS has got nothing on me!"); System.out.println("*****GREETING VALUE POST-INTERCEPTOR*****"); System.out.println(something.getGreeting()); } }
说明:这里有三条同样的打印出书语句:System.out.println(something.getGreeting()),其中,第一条和第二条输出的都是在拦截器处理之前的内容,第三条是输出修改内容后的结果。
3.8 Spring配置
在src目录下创建spring配置文件:spring-context.xml,该文件将定义由spring容器管理的类以及aop设置,内容如下:
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd"> <bean id="saySomething" class="com.thu.afa.esb.jbossesb.action.SaySomething" /> <aop:config proxy-target-class="true"> <aop:advisor pointcut="execution(* setGreeting*(..))" advice-ref="myInterceptor" /> </aop:config> <bean id="myInterceptor" class="com.thu.afa.esb.jbossesb.action.MyInterceptor" /> </beans>
说明:这里定义了一个拦截器,对SaySomething的set分发进行拦截。
3.9 配置Action
<actions mep="OneWay"> <action name="sayHelloAopStyle" class="com.thu.afa.esb.jbossesb.action.MySpringEnabledAction" process="sayHelloAopStyle"> <property name="exceptionMethod" value="exceptionHandler" /> <property name="springContextXml" value="spring-context.xml" /> </action> </actions>
说明:
1) 在MySpringEnabledAction中的sayHelloAopStyle方法中,首先获取客户端发来的消息,然后调用SaySomething的set方法,但是由于定义了拦截器的关系,在执行了set方法之后还会执行拦截器的方法,而在拦截器中再一次调用了SaySomething的set方法,所以action中的set将不起作用。下面将会验证这一点。
2) 这里的springContextXml属性指明了spring配置文件的位置。
3.10 配置部署文件
部署依赖文件deployment.xml内容如下:
<jbossesb-deployment> <depends>jboss.esb:deployment=spring.esb</depends> <depends>jboss.esb.quickstart.destination:service=Queue,name=springaopRequest </depends> <depends>jboss.esb.quickstart.destination:service=Queue,name=springaopResponse </depends> <depends>jboss.esb.quickstart.destination:service=Queue,name=springaopEsb </depends> </jbossesb-deployment>
3.11 部署ESB
将整个工程导出成一个ESB文件,并保存至JBoss ESB Server的部署目录下,启动JBoss ESB Server即可。
4 ESB客户端
4.1 新建Java工程
这里略去操作过程以及添加所需要的Jar包,具体操作过程可参考第一个ESB实例说明。
4.2 发送消息的客户端
/*********************************************************************** * <p>Project Name: helloworldclient</p> * <p>File Name: com.thu.afa.esb.jbossesb.client.SpringHelloWorldClient.java</p> * <p>Copyright: Copyright (c) 2010</p> * <p>Company: <a href="http://afa.thu.com">http://afa.thu.com</a></p> ***********************************************************************/ package com.thu.afa.esb.jbossesb.client; import java.util.Properties; import javax.jms.ObjectMessage; import javax.jms.Queue; import javax.jms.QueueConnection; import javax.jms.QueueConnectionFactory; import javax.jms.QueueSender; import javax.jms.QueueSession; import javax.naming.Context; import javax.naming.InitialContext; /** * <p>Class Name: SpringHelloWorldClient</p> * <p>Description: </p> * @author Afa * @date 2010-9-16 * @version 1.0 */ public class SpringAopClient { private QueueConnection connection; private QueueSession session; private Queue queue; public void setupConnection() throws Exception { Properties properties = new Properties(); properties.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory"); properties.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces"); properties.put(Context.PROVIDER_URL, "jnp://127.0.0.1:1099"); InitialContext context = new InitialContext(properties); QueueConnectionFactory factory = (QueueConnectionFactory) context.lookup("ConnectionFactory"); connection = factory.createQueueConnection(); queue = (Queue) context.lookup("queue/springaopRequest"); session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE); connection.start(); System.out.println("Connection Started"); } public void stop() throws Exception { if(connection != null) connection.stop(); if(session != null) session.close(); if(connection != null) connection.close(); } public void sendAMessage(String text) throws Exception { QueueSender sender = session.createSender(queue); ObjectMessage message = session.createObjectMessage(text); sender.send(message); sender.close(); } public static void main(String[] args) throws Exception { SpringAopClient client = new SpringAopClient(); client.setupConnection(); client.sendAMessage("Llu, miss you, afa - spring aop"); client.stop(); } }
运行客户端程序即可看到以下输出结果:
说明:上述几行打印输出结果都是在拦截器中执行的,其中最后一行是在拦截器中调用set方法后打印输出的结果。
-----------------------------------------------------
Stay Hungry, Stay Foolish!
http://yarafa.iteye.com
Afa
Apr 3rd, 2011
-----------------------------------------------------
发表评论
-
JBoss ESB学习笔记16——第十五个ESB应用Web Service Consumer 1
2011-04-15 21:06 3258续上篇介绍了第十四个ESB应用,本文介绍第十五个ESB应用—— ... -
JBoss ESB学习笔记15——第十四个ESB应用Transform XML to POJO
2011-04-12 13:09 2067续上篇介绍了第十三个ESB应用,本文介绍第十四个ESB应用—— ... -
JBoss ESB学习笔记14——第十三个ESB应用Transform CSV to XML
2011-04-09 13:12 1989续上篇介绍了第十二个ESB应用,本文介绍第十三个ESB应用—— ... -
JBoss ESB学习笔记12——第十一个ESB应用Spring Hello World
2011-04-01 15:27 2343续上篇介绍了第十个ESB应用,本文介绍第十一个ESB应用——S ... -
JBoss ESB学习笔记11——第十个ESB应用Message Filters
2011-03-29 20:35 1964续上篇介绍了第九个ESB应用,本文介绍第十个ESB应用——Me ... -
JBoss ESB学习笔记10——第九个ESB应用JMS Topic
2011-03-26 21:14 2375续上篇介绍了第八个ESB应用,本文介绍第九个ESB应用——JM ... -
JBoss ESB学习笔记9——第八个ESB应用JMS Router
2011-03-11 21:16 2554续上篇介绍了第七个ESB应用,本文介绍第八个ESB应用——JM ... -
JBoss ESB学习笔记8——第七个ESB应用Https Gateway
2011-03-05 11:29 2533续上篇介绍了第六个ESB应用,本文介绍第七个ESB应用——Ht ... -
JBoss ESB学习笔记7——第六个ESB应用Http Gateway
2011-02-26 10:45 3470续上篇介绍了第五个ESB应用,本文介绍第六个ESB应用——Ht ... -
JBoss ESB学习笔记6——第五个ESB应用Custom Action
2011-01-15 10:34 2261续上篇介绍了第四个ESB应用,本文介绍第五个ESB应用——Cu ... -
JBoss ESB学习笔记5——第四个ESB应用Hello World File Action
2011-01-08 11:23 2631续上篇介绍了第三个ESB应用,本文介绍第四个ESB应用——He ... -
JBoss ESB学习笔记4——第三个ESB应用Hello World Notification
2011-01-03 15:01 3029续上篇介绍了第二个ESB应用,本文介绍第三个ESB应用——He ... -
JBoss ESB学习笔记3——第二个ESB应用Hello World Action
2010-12-21 22:20 3820续上篇介绍了第一个ESB应用,本文介绍第二个ESB应用——He ... -
JBoss ESB学习笔记2——第一个ESB应用Hello World
2010-12-13 20:34 6558续上文搭建好开发环境后就可以开发ESB应用了。本文介绍第一个E ... -
JBoss ESB学习笔记1——搭建ESB开发环境
2010-12-12 13:55 7762最近由于工作需要用到 ...
相关推荐
4. **Spring整合**:《JBoss_ESB学习笔记13——第十个ESB应用Spring_AOP.doc》和《JBoss_ESB学习笔记12——第十个ESB应用Spring_helloworld.doc》涉及到Spring框架与ESB的结合,Spring AOP(面向切面编程)在ESB中的...
【JBoss ESB 学习笔记】 JBoss ESB(Enterprise Service Bus,企业服务总线)是Red Hat公司开发的一款开源服务导向架构(SOA)平台,它为分布式应用程序提供了集成和互操作性。本笔记将深入探讨JBoss ESB的核心概念...
#### 十三、第十二个ESB应用Spring AOP - **重点**:介绍如何在ESB应用中应用Spring的面向切面编程(AOP)。 - **实现**:编写AOP切面,实现在方法调用前后添加额外的行为。 #### 十四、第十三个ESB应用Transform ...
JBossESB学习笔记 收集了网上1-16系列教程,笔记详细介绍了JBossESB各个组件的特性及配置文件的说明
【JBoss ESB学习笔记】 JBoss ESB(Enterprise Service Bus)是Red Hat公司开发的一款开源企业服务总线,它是企业级应用集成的核心组件,用于连接不同系统、服务和应用程序,实现服务之间的通信和交互。本学习笔记...
JBoss ESB(Enterprise Service Bus,企业服务总线)是Red Hat公司提供的一个开源中间件,用于构建服务导向架构(SOA)。它提供了一个平台,让不同系统和服务之间能够通过标准接口进行通信,实现了服务之间的解耦合...
JBoss ESB(Enterprise Service Bus)是一款开源的企业服务总线解决方案,旨在为应用程序之间的通信提供一个灵活且可扩展的基础架构。本手册旨在帮助初学者理解JBoss ESB的基本概念、搭建开发环境以及进行简单的开发...
总之,《JBoss ESB新手指南》这本书将带领读者逐步了解和掌握这个强大的中间件平台,从基础概念到实战技巧,全面解析JBoss ESB在企业级集成中的应用。通过深入学习,新手可以快速成长为能够熟练运用JBoss ESB解决...
本篇学习笔记主要围绕 JBoss ESB 的一个基础应用——“Hello World File Action”进行讲解,这个例子展示了如何利用 JBoss ESB 的 File Gateway 功能来监控文件系统变化,并通过 JMS(Java Message Service)消息...
在构建基于JBoss ESB 4.6的应用程序时,SOA(面向服务的架构)平台配置是至关重要的第一步。正确的配置能够确保服务之间高效稳定地交互。 - **环境搭建**:安装必要的软件包,如Java环境、JBoss ESB等,并进行版本...
jboss esb 实例及讲解,我收集的资料整理做成书
JBoss ESB 4.9需要一个特定的服务器环境,你可以从官方网站下载D:\jboss-5.1.0.GA/jbossesb-server,这是一个包含大量示例的独立运行版本。这些示例可以通过Ant脚本进行部署和测试: - 使用`ant deploy`命令来部署...
一、Jboss ESB的简介 1、 什么是ESB。 ESB的全称是Enterprise Service Bus,即企业服务总线。ESB是过去消息中间件的发展,ESB采用了“总线”这样一种模式来管理和简化应用之间的集成拓扑结构,以广为接受的开放...
1. 目录 1. 目录 2 2. 关于本指南 5 2.1. 本指南包括什么 5 2.2. 读者 5 2.3. 必要知识 5 2.4. 本指南的组织结构 5 2.5. 关于本文档的协定 5 2.6. 附件 6 2.7. 我们的联系方式 6 ...13. 第十一章 术语表 67
ESB应用Spring_AOP
JBoss ESB 入门例子。主要是一个Server和一个Client。
NULL 博文链接:https://siye1982.iteye.com/blog/592400
JBoss ESB(Enterprise Service Bus)是JBoss中间件项目的一个重要组成部分,主要功能在于提供一个灵活、可扩展的平台,用于构建和部署企业级集成解决方案。它支持多种消息传输协议和数据格式,能够处理复杂的消息流...