续上篇介绍了第三个ESB应用,本文介绍第四个ESB应用——Hello World File Action。
说明:本文及后续文章虽非百分百的原创,但毕竟包含本人的努力和付出,所以希望大家转载时务请注明出处:http://yarafa.iteye.com,谢谢合作。
1 概述
本实例演示了JBoss ESB的File Gateway的使用及特性,当ESB所监听的特定目录下具有特定扩展名的文件发生变化时,将发送一个JMS消息到消息队列,然后由ESB处理该消息。最后根据ESB的配置将输出一个具有特定扩展名的文件到输出目录。
2 新建ESB工程
操作过程略。
3 ESB配置
3.1 创建消息队列
本例中只用到了一个消息队列,如下所示:
<?xml version="1.0" encoding="UTF-8"?>
<server>
<mbean code="org.jboss.jms.server.destination.QueueService" name="jboss.esb.helloworld.destination:service=Queue,name=helloworldfile" xmbean-dd="xmdesc/Queue-xmbean.xml">
<depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer
</depends>
</mbean>
</server>
3.2 定义Provider
这里将定义一个fs-provider和一个JMS Provider,分别用于监听文件系统的变化和监听ESB消息。内容如下:
<fs-provider name="FSprovider1">
<fs-bus busid="helloFileChannel">
<fs-message-filter
directory="F:\Workspace\Eclipse-JEE\helloworldfile\file\input"
error-delete="false"
error-directory="F:\Workspace\Eclipse-JEE\helloworldfile\file\error"
error-suffix=".IN_ERROR" input-suffix=".txt" post-delete="false"
post-directory="F:\Workspace\Eclipse-JEE\helloworldfile\file\output"
post-suffix=".sentToEsb"
work-suffix=".esbWorking" />
</fs-bus>
</fs-provider>
<jms-provider connection-factory="ConnectionFactory"
name="JBossMessaging">
<jms-bus busid="quickstartEsbChannel">
<jms-message-filter dest-name="queue/helloworldfile"
dest-type="QUEUE"
selector="type='fromHelloworldFileAction'" />
</jms-bus>
</jms-provider>
fs-provider配置说明:
directory:ESB的监听目录
input-suffix:监听文件的扩展名,不是指定扩展名的文件将被忽略
error-delete:如果发生内部错误或者ESB无法加载文件,该属性决定是否删除文件
error-directory:在文件加载或者处理失败时的文件存放目录
error-suffix:发生错误时的文件扩展名
post-directory:当post-delete属性设置为false且未发生错误的情况下,该目录用于存放处理后的文件
post-suffix:处理后的文件扩展名
work-suffix:正在被处理时的文件扩展名,“被处理”指的是文件已通过gateway并已被传输到ESB listener/service。
3.3 定义Service
<service category="myCategory" description="Hello World File Action
(esb listener)" name="myFileListener">
<listeners />
<actions /
</service>
3.4 定义Listener
这里定义两个listener,分别用于监听文件通道和消息队列,内容如下:
<fs-listener busidref="helloFileChannel" is-gateway="true"
name="FileGateway" poll-frequency-seconds="10" />
<jms-listener busidref="quickstartEsbChannel"
name="helloWorldFileAction" />
3.5 定义Action类
这里使用自定义的action类,因此需要扩展AbstractActionLifecycle类。类的全部代码如下:
/***********************************************************************
* <p>Project Name: helloworldfile</p>
* <p>File Name: com.thu.afa.esb.jbossesb.action.HelloWorldFileAction.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.Body;
import org.jboss.soa.esb.message.Message;
/**
* <p>Class Name: HelloWorldFileAction</p>
* <p>Description: </p>
* @author Afa
* @date 2010-9-8
* @version 1.0
*/
public class HelloWorldFileAction extends AbstractActionLifecycle
{
protected ConfigTree configTree;
public HelloWorldFileAction(ConfigTree configTree)
{
this.configTree = configTree;
}
public Message noOperation(Message message) { return message; }
public Message displayMessage(Message message) throws Exception
{
System.out.println("Body: " + new String((byte[])message.getBody().get()));
return message;
}
public Message playWithMessage(Message message) throws Exception
{
Body body = message.getBody();
String content = new String((byte[])body.get());
StringBuffer buffer = new StringBuffer();
buffer.append("Before------------------");
buffer.append(content);
buffer.append("After-------------------");
body.add(buffer.toString());
return message;
}
}
类方法说明:
displayMessage方法用于在控制台打印输出消息的内容
playWithMessage方法用于处理消息
3.6 配置Action
由于使用了自定义的action类,因此在说明action配置之前介绍了action类的定义。下面将说明action的配置。
<actions mep="OneWay">
<action
class="com.thu.afa.esb.jbossesb.action.HelloWorldFileAction"
name="myAction" process="displayMessage,playWithMessage" />
<action class="org.jboss.soa.esb.actions.SystemPrintln"
name="dump">
<property name="message" />
<property name="printfull" value="true" />
</action>
</actions>
配置说明:这里定义了两个action,分别用自定义的action类显示文件内容并做相应的处理后,再由ESB本身提供的SystemPrintln类在控制台输出经处理后的消息内容。
3.7 配置部署文件
部署依赖文件deployment.xml内容如下:
<jbossesb-deployment>
<depends>jboss.esb.helloworld.destination:service=Queue,name=helloworldfile
</depends>
</jbossesb-deployment>
3.8 部署ESB
将整个工程导出成一个ESB文件,并保存至JBoss ESB Server的部署目录下,启动JBoss ESB Server即可。
4 ESB客户端
4.1 新建Java工程
这里略去操作过程以及添加所需要的Jar包,具体操作过程可参考第一个ESB实例说明。
4.2 客户端实现
这里的客户端生成一个文本文件,并保存在ESB的监听目录下,之后可看到ESB的处理操作。
/***********************************************************************
* <p>Project Name: helloworldclient</p>
* <p>File Name: com.thu.afa.esb.jbossesb.client.HelloWorldFileClient.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.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
/**
* <p>Class Name: HelloWorldFileClient</p>
* <p>Description: </p>
* @author Afa
* @date 2010-9-9
* @version 1.0
*/
public class HelloWorldFileClient
{
/**
* <p>Title: </p>
* <p>Method Name: main</p>
* <p>Description: </p>
* @author: Afa
* @date: 2010-9-9
* @param args
*/
public static void main(String[] args) throws Exception
{
File file = new File("F:/Workspace/Eclipse-JEE/helloworldfile/file/input/test.txt");
BufferedWriter out = new BufferedWriter(new FileWriter(file));
out.write("Llu, miss you, afa");
out.close();
}
}
运行该程序可看到如下输出结果:
处理中的文件:
处理后的输出文件:
ESB的SystemPrintln类在控制台输出结果:
上述便是ESB第四个应用实例。如有问题,欢迎指正。
-----------------------------------------------------
Stay Hungry, Stay Foolish!
http://yarafa.iteye.com
Afa
Jan 8th, 2011
-----------------------------------------------------
分享到:
相关推荐
1. **基础入门**:如《JBoss_ESB学习笔记5——第四个ESB应用Hello World File Action.doc》所示,初学者通常从“Hello World”程序开始,了解如何创建并运行一个简单的ESB服务。这一阶段会介绍ESB的基本概念,如服务...
#### 五、第四个ESB应用Hello World File Action - **重点**:了解如何使用File Action处理文件相关的消息。 - **实现**:实现读取文件内容作为消息的一部分,并能够处理这些文件数据。 #### 六、第五个ESB应用...
JBossESB学习笔记 收集了网上1-16系列教程,笔记详细介绍了JBossESB各个组件的特性及配置文件的说明
【JBoss ESB 学习笔记】 JBoss ESB(Enterprise Service Bus,企业服务总线)是Red Hat公司开发的一款开源服务导向架构(SOA)平台,它为分布式应用程序提供了集成和互操作性。本笔记将深入探讨JBoss ESB的核心概念...
本篇学习笔记主要围绕 JBoss ESB 的一个基础应用——“Hello World File Action”进行讲解,这个例子展示了如何利用 JBoss ESB 的 File Gateway 功能来监控文件系统变化,并通过 JMS(Java Message Service)消息...
【ESB应用Hello_World_File_Action】是关于JBoss ESB的一个示例教程,主要讲解如何利用JBoss ESB的File Gateway功能来监控文件系统的变化,并通过JMS消息队列进行处理。在这个应用中,当指定目录下的特定扩展名文件...
【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 4.6的应用程序时,SOA(面向服务的架构)平台配置是至关重要的第一步。正确的配置能够确保服务之间高效稳定地交互。 - **环境搭建**:安装必要的软件包,如Java环境、JBoss ESB等,并进行版本...
JBoss ESB 4.9需要一个特定的服务器环境,你可以从官方网站下载D:\jboss-5.1.0.GA/jbossesb-server,这是一个包含大量示例的独立运行版本。这些示例可以通过Ant脚本进行部署和测试: - 使用`ant deploy`命令来部署...
jboss esb 实例及讲解,我收集的资料整理做成书
### JBoss ESB详解:Hello_World应用与关键概念解析 #### 一、Hello_World应用简介 在深入了解JBoss Enterprise Service Bus(ESB)的关键概念之前,让我们首先通过一个简单的Hello_World应用来熟悉其基本操作流程...
一、Jboss ESB的简介 1、 什么是ESB。 ESB的全称是Enterprise Service Bus,即企业服务总线。ESB是过去消息中间件的发展,ESB采用了“总线”这样一种模式来管理和简化应用之间的集成拓扑结构,以广为接受的开放...
6. 第四章 JBossESB 21 6.1. Rosetta 21 6.2. JBossESB的核心 22 6.3. JBossESB的组件 23 6.4. 配置 23 6.5. 消息存储 24 6.6. ESB-aware和ESB-unaware用户 25 6.7. 端点引用(EPRs) 26 6.8. EPR到服务的映射 27 ...
JBoss ESB 入门例子。主要是一个Server和一个Client。
在本篇文章中,我们将关注于使用JBoss ESB创建一个名为“Hello World Action”的示例应用。JBoss ESB是Red Hat JBoss中间件的一部分,它提供了一个开放源码的ESB平台,用于构建和管理SOA(面向服务架构)应用程序。 ...