`
yarafa
  • 浏览: 88634 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

JBoss ESB学习笔记6——第五个ESB应用Custom Action

阅读更多

续上篇介绍了第四个ESB应用,本文介绍第五个ESB应用——Custom Action。

 

说明:本文及后续文章虽非百分百的原创,但毕竟包含本人的努力和付出,所以希望大家转载时务请注明出处:http://yarafa.iteye.com,谢谢合作。

 

 

1 概述
本实例主要演示了action类的不同使用方式。

 

2 新建ESB工程
操作过程略。

 

3 ESB配置
3.1 创建消息队列
如概述中所描述,这里将创建两个消息队列。在esbcontent文件夹下创建文件jbm-queue-service.xml用于配置消息队列,内容如下:

<?xml version="1.0" encoding="UTF-8"?>
<server>
	<mbean code="org.jboss.jms.server.destination.QueueService"		name="jboss.esb.customaction.destination:service=Queue,name=customactionGw" 	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.customaction.destination:service=Queue,name=customactionEsb" 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,同时定义两个消息通道,一个用于监听客户端发来的消息,另一个用作ESB消息通道。内容如下:

<jms-provider connection-factory="ConnectionFactory" name="JBossMQ">
	<jms-bus busid="customactionGwChanel">
		<jms-message-filter dest-name="queue/customactionGw"
			dest-type="QUEUE" />
	</jms-bus>
	<jms-bus busid="customactionEsbChanel">
		<jms-message-filter dest-name="queue/customactionEsb"
			dest-type="QUEUE" />
	</jms-bus>
</jms-provider>

 

3.3 定义Service

<service category="CustomAction" description="Custom Action"
	name="CustomActionService">
	<listeners />
	<actions /
</service>

 

3.4 定义Listener
这里定义两个listener,分别用于监听客户端消息和ESB内部消息。其中,前者用于监听客户端消息,因此需要将其is-gateway属性设置为true。

<jms-listener busidref="customactionGwChanel" is-gateway="true" name="JMSListener" />
<jms-listener busidref="customactionEsbChanel" name="EsbListener" />

 

3.5 定义Action类
下面将定义四个action,分别是:MyBasicAction,StatefulAction,CustomConfigAction和CustomBeanConfigAction,其中,CustomBeanConfigAction类在扩展了AbstractActionLifecycle类的基础上同时实现了BeanConfiguredAction接口。下面对各个action一一介绍。


3.5.1 MyBasicAction
这是一个基本的action,与之前的实例中的action功能类似,主要用于打印输出消息内容。类定义如下:

/***********************************************************************
 * <p>Project Name: customaction</p>
 * <p>File Name: com.thu.afa.esb.jbossesb.action.MyBasicAction.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.AbstractActionLifecycle;
import org.jboss.soa.esb.helpers.ConfigTree;
import org.jboss.soa.esb.message.Message;

/**
 * <p>Class Name: MyBasicAction</p>
 * <p>Description: </p>
 * @author Afa
 * @date 2010-9-10
 * @version 1.0
 */
public class MyBasicAction extends AbstractActionLifecycle
{
	protected ConfigTree configTree;
	
	public MyBasicAction(ConfigTree configTree)
	{
		this.configTree = configTree;
	}
	
	public Message noOperation(Message message) { return message; }
	
	public Message process(Message message)
	{
		System.out.println("The default process method called");
		
		return message;
	}
	
	public Message printMessage(Message message) throws Exception
	{
		System.out.println("Message Body: " + message.getBody().get().toString());
		
		return message;
	}
	
	public void exceptionHandler(Message message, Throwable exception)
	{
		System.out.println("!ERROR!");
		System.out.println(exception.getMessage());
		System.out.println("For Message: ");
		System.out.println(message.getBody().get());
	}
}

 

3.5.2 StatefulAction
该类主要用于演示在一个action配置中同时调用多个方法时,action的实例个数。简单的说,在一个action配置中,不论调用多少个方法,都只会有一个action类的实例。

/***********************************************************************
 * <p>Project Name: customaction</p>
 * <p>File Name: com.thu.afa.esb.jbossesb.action.StatefulAction.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.AbstractActionLifecycle;
import org.jboss.soa.esb.helpers.ConfigTree;
import org.jboss.soa.esb.message.Message;

/**
 * <p>Class Name: StatefulAction</p>
 * <p>Description:</p>
 * 
 * @author Afa
 * @date 2010-9-10
 * @version 1.0
 */
public class StatefulAction extends AbstractActionLifecycle
{
	protected ConfigTree configTree;
	private int count = 0;

	public StatefulAction(ConfigTree configTree)
	{
		System.out.println("\n\nConstructor - " + this.getClass().getName() + "\n");
		count++;

		this.configTree = configTree;
	}

	public Message noOperation(Message message)
	{
		return message;
	}

	public Message methodOne(Message message) throws Exception
	{
		count++;
		System.out.println("methodOne Called: " + count);

		return message;
	}

	public Message methodTwo(Message message) throws Exception
	{
		count++;
		System.out.println("methodOne Called: " + count);

		return message;
	}
	
	public Message displayCount(Message message) throws Exception
	{
		System.out.println("DisplayCount count = " + count + "\n");
		return message;
	}
	
	public void exceptionHandler(Message message, Throwable exception)
	{
		System.out.println("!ERROR!");
		System.out.println(exception.getMessage());
		System.out.println("For Message: ");
		System.out.println(message.getBody().get());
	}
}

 

3.5.3 CustomConfigAction
该类主要用于演示如何访问在jboss-esb.xml配置中的action节点及其子节点的信息。

/***********************************************************************
 * <p>Project Name: customaction</p>
 * <p>File Name: com.thu.afa.esb.jbossesb.action.CustomConfigAction.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.util.Set;

import org.jboss.soa.esb.actions.AbstractActionLifecycle;
import org.jboss.soa.esb.helpers.ConfigTree;
import org.jboss.soa.esb.message.Message;

/**
 * <p>Class Name: CustomConfigAction</p>
 * <p>Description: </p>
 * @author Afa
 * @date 2010-9-10
 * @version 1.0
 */
public class CustomConfigAction extends AbstractActionLifecycle
{
	protected ConfigTree configTree;
	
	public CustomConfigAction(ConfigTree configTree)
	{
		this.configTree = configTree;
	}
	
	public Message displayConfig(Message message) throws Exception
	{
		Set<String> names = configTree.getAttributeNames();
		System.out.println("****************************");
		for (String attrName : names)
		{
			String value = configTree.getAttribute(attrName);
			System.out.println("Attribute: " + attrName + " Value: " + value);
		}
		System.out.println("****************************");

		ConfigTree[] subElements = configTree.getAllChildren();
		// Note: even a sub-element can have attributes but trying to keep this simple
		System.out.println("############################");
		for (ConfigTree child : subElements)
		{
			System.out.println("SubElement: " + child.getName() + " Body: " + child.getWholeText());
		}
		System.out.println("############################");
		return message;
	}
}

 

3.5.4 CustomBeanConfigAction
该类演示了如何在jboss-esb.xml配置中对action类属性的注入,这一点与spring的依赖注入有异曲同工之处。需要注意的是:在该类中不能有ConfigTree类型的属性以及包含该类型参数的构造方法。具体原因有待于进一步研究。

/***********************************************************************
 * <p>Project Name: customaction</p>
 * <p>File Name: com.thu.afa.esb.jbossesb.action.CustomBeanConfigAction.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.AbstractActionLifecycle;
import org.jboss.soa.esb.actions.BeanConfiguredAction;
import org.jboss.soa.esb.message.Message;

/**
 * <p>Class Name: CustomBeanConfigAction</p>
 * <p>Description: </p>
 * @author Afa
 * @date 2010-9-10
 * @version 1.0
 */
public class CustomBeanConfigAction extends AbstractActionLifecycle implements BeanConfiguredAction
{
	private String information;
	private Integer repeatCount;
	private String serviceCategory;
	private String serviceName;
	public String getInformation()
	{
		return information;
	}
	public void setInformation(String information)
	{
		this.information = information;
	}
	public Integer getRepeatCount()
	{
		return repeatCount;
	}
	public void setRepeatCount(Integer repeatCount)
	{
		this.repeatCount = repeatCount;
	}
	public String getServiceCategory()
	{
		return serviceCategory;
	}
	public void setServiceCategory(String serviceCategory)
	{
		this.serviceCategory = serviceCategory;
	}
	public String getServiceName()
	{
		return serviceName;
	}
	public void setServiceName(String serviceName)
	{
		this.serviceName = serviceName;
	}
	
	public Message process(Message message) throws Exception
	{
		System.out.println("[" + serviceCategory + ":" + serviceName + "] Repeat message: " + information + " " + repeatCount + " times:");
		for (int i=0; i < repeatCount; i++)
		{
			System.out.println(information);
		}
		
		return message;
	}
}

 

3.6 配置Action 

<actions>
	<action class="com.thu.afa.esb.jbossesb.action.MyBasicAction"
		name="firstAction" process="printMessage">
		<property name="exceptionMethod" value="exceptionHandler" />
	</action>
	<action class="com.thu.afa.esb.jbossesb.action.MyBasicAction"
		name="secondAction">
		<property name="exceptionMethod" value="exceptionHandler" />
	</action>
	<action class="com.thu.afa.esb.jbossesb.action.MyBasicAction"
		name="thirdAction" process="printMessage">
		<property name="exceptionMethod" value="exceptionHandler" />
	</action>
	<action class="com.thu.afa.esb.jbossesb.action.StatefulAction"
		name="fourthAction" process="methodOne,methodTwo,displayCount">
		<property name="exceptionMethod" value="exceptionHandler" />
	</action>
	<action class="com.thu.afa.esb.jbossesb.action.CustomConfigAction"
		name="fifthAction" process="displayConfig">
		<property name="myStuff" value="rocks" />
		<property name="moreStuff" value="rocks harder" />
		<property name="subElements">
			<subElement1>Value of 1</subElement1>
			<subElement2>Value of 2</subElement2>
			<subElement3>Value of 3</subElement3>
		</property>
	</action>
	<action class="com.thu.afa.esb.jbossesb.action.MyBasicAction"
		name="sixthAction" process="printMessage">
		<property name="exceptionMethod" value="exceptionHandler" />
	</action>
	<action name="seventhAction"
class="com.thu.afa.esb.jbossesb.action.CustomBeanConfigAction>
		<property name="information" value="Hola Mundo" />
		<property name="repeatCount" value="5" />
	</action>
</actions>

 

3.7 配置部署文件
部署依赖文件deployment.xml内容如下:

<jbossesb-deployment>
	<depends>jboss.esb.customaction.destination:service=Queue,name=customactionGw
	</depends>
	<depends>jboss.esb.customaction.destination:service=Queue,name=customactionEsb
	</depends>
</jbossesb-deployment>

 

3.8 部署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.CustomActionClient.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: CustomActionClient</p>
 * <p>Description: </p>
 * @author Afa
 * @date 2010-9-10
 * @version 1.0
 */
public class CustomActionClient
{
	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/customactionGw");
		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();
	}

	/**
	 * <p>Title: </p>
	 * <p>Method Name: main</p>
	 * <p>Description: </p>
	 * @author: Afa
	 * @date: 2010-9-10
	 * @param args
	 */
	public static void main(String[] args) throws Exception
	{
		CustomActionClient client = new CustomActionClient();
		client.setupConnection();
		client.sendAMessage("Llu, miss you, afa, custom action");
		client.stop();
	}

}

 

运行客户端程序即可看到以下输出结果:

JBoss ESB, JBoss ESB

 

JBoss ESB, JBoss ESB

 

其中,在第一个结果输出图中,
Constructor - com.thu.afa.esb.jbossesb.action. StatefulAction,这一行信息是在部署ESB时实例化StatefulAction类时,由其构造方法打印输出的结果。

 

上述便是ESB第五个应用实例。如有问题,欢迎指正。

 

 

-----------------------------------------------------
Stay Hungry, Stay Foolish!
http://yarafa.iteye.com
Afa
Jan 15th, 2011
-----------------------------------------------------

分享到:
评论
2 楼 yarafa 2011-02-21  
jyslb 写道
文章不错啊,看了以后对provider和action都有了初步的了解,尤其是6的actions介绍相当不错!希望以后能加入jbpm来介绍:)
对了,你的这些project可以在哪里下载的到?

多谢赞赏,这些例子在jboss-esb的下载包中都有
1 楼 jyslb 2011-02-21  
文章不错啊,看了以后对provider和action都有了初步的了解,尤其是6的actions介绍相当不错!希望以后能加入jbpm来介绍:)
对了,你的这些project可以在哪里下载的到?

相关推荐

    JBOSS_Esb学习资料

    3. **自定义操作**:在《JBoss_ESB学习笔记6——第五个ESB应用Custom_Action.doc》中,我们能学习到如何编写自定义操作,这是扩展ESB功能的关键,使得开发者能够根据特定需求定制服务处理逻辑。 4. **Spring整合**...

    JBoss ESB 学习笔记

    #### 六、第五个ESB应用Custom Action - **重点**:探索如何创建自定义Action组件以满足特定需求。 - **实现**:编写自定义Action组件代码,并将其集成到ESB应用中。 #### 七、第六个ESB应用Http Gateway - **...

    JBossESB学习笔记(1-16全)

    JBossESB学习笔记 收集了网上1-16系列教程,笔记详细介绍了JBossESB各个组件的特性及配置文件的说明

    JBossESB学习笔记.rar_Jboss_ESB_esb和aop

    【JBoss ESB 学习笔记】 JBoss ESB(Enterprise Service Bus,企业服务总线)是Red Hat公司开发的一款开源服务导向架构(SOA)平台,它为分布式应用程序提供了集成和互操作性。本笔记将深入探讨JBoss ESB的核心概念...

    Jboss_ESB学习笔记

    【JBoss ESB学习笔记】 JBoss ESB(Enterprise Service Bus)是Red Hat公司开发的一款开源企业服务总线,它是企业级应用集成的核心组件,用于连接不同系统、服务和应用程序,实现服务之间的通信和交互。本学习笔记...

    JBoss ESB学习笔记1-搭建ESB开发环境.docx

    JBoss ESB(Enterprise Service Bus,企业服务总线)是Red Hat公司提供的一个开源中间件,用于构建服务导向架构(SOA)。它提供了一个平台,让不同系统和服务之间能够通过标准接口进行通信,实现了服务之间的解耦合...

    jbossesb开发手册

    JBoss ESB(Enterprise Service Bus)是一款开源的企业服务总线解决方案,旨在为应用程序之间的通信提供一个灵活且可扩展的基础架构。本手册旨在帮助初学者理解JBoss ESB的基本概念、搭建开发环境以及进行简单的开发...

    JBoss ESB新手指南

    总之,《JBoss ESB新手指南》这本书将带领读者逐步了解和掌握这个强大的中间件平台,从基础概念到实战技巧,全面解析JBoss ESB在企业级集成中的应用。通过深入学习,新手可以快速成长为能够熟练运用JBoss ESB解决...

    Jboss-ESB学习笔记.doc

    本篇学习笔记主要围绕 JBoss ESB 的一个基础应用——“Hello World File Action”进行讲解,这个例子展示了如何利用 JBoss ESB 的 File Gateway 功能来监控文件系统变化,并通过 JMS(Java Message Service)消息...

    JbossESB4.6 程序开发

    在构建基于JBoss ESB 4.6的应用程序时,SOA(面向服务的架构)平台配置是至关重要的第一步。正确的配置能够确保服务之间高效稳定地交互。 - **环境搭建**:安装必要的软件包,如Java环境、JBoss ESB等,并进行版本...

    jboss esb 实例

    jboss esb 实例及讲解,我收集的资料整理做成书

    Jboss ESB简介及开发实例

    一、Jboss ESB的简介 1、 什么是ESB。 ESB的全称是Enterprise Service Bus,即企业服务总线。ESB是过去消息中间件的发展,ESB采用了“总线”这样一种模式来管理和简化应用之间的集成拓扑结构,以广为接受的开放...

    JbossESB开发环境配置.docx

    JBoss ESB 4.9需要一个特定的服务器环境,你可以从官方网站下载D:\jboss-5.1.0.GA/jbossesb-server,这是一个包含大量示例的独立运行版本。这些示例可以通过Ant脚本进行部署和测试: - 使用`ant deploy`命令来部署...

    JBOSS ESB程序员指南

    7. 第五章 使用消息 47 7.1. 怎样使用消息 47 7.2. 消息的结构 47 7.3. 服务 48 7.4. 解包负载 49 7.5. 客户端 49 7.6. 提示和技巧 50 8. 第六章 流程引擎支持 51 8.1. jBPM 51 9. 第七章 Webservices支持 52 9.1. ...

    JBoss ESB 例子

    JBoss ESB 入门例子。主要是一个Server和一个Client。

    JBOSSESB学习小结

    NULL 博文链接:https://siye1982.iteye.com/blog/592400

    JBoss ESB 开发指南

    JBoss ESB(Enterprise Service Bus)是JBoss中间件项目的一个重要组成部分,主要功能在于提供一个灵活、可扩展的平台,用于构建和部署企业级集成解决方案。它支持多种消息传输协议和数据格式,能够处理复杂的消息流...

    JBOSS_ESB_开发手册

    ### JBoss ESB 开发手册概览 #### JBoss ESB 的主要特性 JBoss ESB,即Enterprise Service Bus,是Red Hat JBoss家族中的一员,专注于企业级服务总线解决方案,旨在简化不同应用程序间的集成与通信。其核心功能...

Global site tag (gtag.js) - Google Analytics