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

JBoss ESB学习笔记14——第十三个ESB应用Transform CSV to XML

阅读更多

续上篇介绍了第十二个ESB应用,本文介绍第十三个ESB应用——Transform CSV to XML。

 

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

 

 

1 概述
本实例主要演示了如何将一个CSV文件(逗号分隔的值文件)转换成XML格式字符串,本实例的转换是通过配置Smooks实现的,这里的转换过程分为两步,一是将CSV转换成中间XML格式,然后再转换成目标XML格式。

 

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.quickstart.destination:service=Queue,name=transformCSV2XMLGw" 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=transformCSV2XMLEsb" 	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/transformCSV2XMLGw"
			dest-type="QUEUE" />
	</jms-bus>
	<jms-bus busid="esbChanel">
		<jms-message-filter dest-name="queue/transformCSV2XMLEsb"
			dest-type="QUEUE" />
	</jms-bus>
</jms-provider>

 

3.3 定义转换映射文件
在src目录下新建文件smooks-res.xml,内容如下:

<?xml version='1.0' encoding='UTF-8'?>
<smooks-resource-list xmlns=http://www.milyn.org/xsd/smooks-1.1.xsd
xmlns:csv="http://www.milyn.org/xsd/smooks/csv-1.1.xsd">
    <profiles><profile base-profile="source-csv" /><profile base-profile="canonical-xml" /></profiles>
    <csv:reader targetProfile="source-csv" fields="orderId,orderDate,statusCode,netAmount,totalAmount,tax,userName,firstName,lastName,state,orderLine1Position,orderLine1Quantity,orderLine1ProductId,orderLine1ProductTitle,orderLine1ProductPrice,orderLine2Position,orderLine2Quantity,orderLine2ProductId,orderLine2ProductTitle,orderLine2ProductPrice" />
	<resource-config target-profile="canonical-xml" selector="csv-set"><resource type="xsl">
            <![CDATA[
			<xsl:stylesheet xmlns:xsl="http://www.w3.org/1999/XSL/Transform"
                xmlns:smooks-bean="xalan://org.milyn.templating.xslt.XalanJavabeanExtension"
                extension-element-prefixes="smooks-bean"
                version="1.0"><xsl:output method="xml" encoding="UTF-8" /><xsl:template match="*" name="templatelet">
					<orders><xsl:for-each select="csv-record">
							<Order orderId="{orderId}"
                                orderDate="{orderDate}"
                                statusCode="{statusCode}"
                                netAmount="{netAmount}"
                                totalAmount="{totalAmount}"
                                tax="{tax}" >
								<Customer userName="{userName}" firstName="{firstName}" lastName="{lastName}" state="{state}" />
								<OrderLines>
									<OrderLine posistion="{orderLine1Position}" quantity="{orderLine1Quantity}">
										<Product  productId="{orderLine1ProductId}" title="{orderLine1ProductTitle}" price="{orderLine1ProductPrice}"/>
									</OrderLine>
									<OrderLine posistion="{orderLine2Position}" quantity="{orderLine2Quantity}">
										<Product  productId="{orderLine2ProductId}" title="{orderLine2ProductTitle}" price="{orderLine2ProductPrice}"/>
									</OrderLine>
								</OrderLines>
							</Order>
						</xsl:for-each>
					</orders>
                </xsl:template>
			</xsl:stylesheet>]]>
        </resource>
        <param name="is-xslt-templatelet">false</param>
    </resource-config>
</smooks-resource-list>

 

3.4 定义Service

<service category="Transform" description="Transform CSV 2 XML"
	name="TransformService">
	<listeners />
	<actions mep="OneWay" />
</service>

 

3.5 定义Listener

<listeners>
	<jms-listener busidref="gwChanel" is-gateway="true"
		name="gwListener" />
	<jms-listener busidref="esbChanel" name="esbListener" />
</listeners>

 

3.6 定义Action

<action class="org.jboss.soa.esb.actions.SystemPrintln"
name="printAction">
	<property name="message" value="Message before CVS to XML
transformation" />
</action>
<action class="org.jboss.soa.esb.smooks.SmooksAction"
name="transformCSV2XML">
	<property name="smooksConfig" value="/smooks-res.xml" />
	<property name="messageProfile" value="source-csv" />
</action>
<action class="org.jboss.soa.esb.actions.SystemPrintln"
name="printAfterAction">
	<property name="message" value="Message after CVS to XML
transformation" />
</action>
<action class="org.jboss.soa.esb.smooks.SmooksAction"
name="transform2XML">
	<property name="smooksConfig" value="/smooks-res.xml" />
	<property name="messageProfile" value="canonical-xml" />
</action>
<action class="org.jboss.soa.esb.actions.SystemPrintln"
name="printFinishAction">
	<property name="message"
value="Message after Smooks intermediate xml -> target xml" />
</action>

 

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

<?xml version="1.0" encoding="UTF-8"?>
<jbossesb-deployment>
	<depends>jboss.esb:deployment=smooks.esb</depends>
	<depends>jboss.esb.quickstart.destination:service=Queue,name=transformCSV2XMLGw
	</depends>
	<depends>jboss.esb.quickstart.destination:service=Queue,name=transformCSV2XMLEsb
	</depends>
</jbossesb-deployment>

 

3.7 部署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.TransformCSV2XMLClient.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.File;
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;

import org.jboss.soa.esb.util.FileUtil;

/**
 * <p>Class Name: TransformCSV2XMLClient</p>
 * <p>Description: </p>
 * @author Afa
 * @date 2010-9-17
 * @version 1.0
 */
public class TransformCSV2XMLClient
{
	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/transformCSV2XMLGw");
		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 fileName) throws Exception
	{
		QueueSender sender = session.createSender(queue);
		ObjectMessage objectMessage;
		File file = new File(fileName);
		if(!file.exists())
		{
			throw new Exception("Input message file [" + file.getAbsolutePath() + "] not found.");
		}
		String message = FileUtil.readTextFile(file);
		objectMessage = session.createObjectMessage(message);
		objectMessage.setStringProperty("jbesbfilename", "transformedmessageCSV2XML.log");
		sender.send(objectMessage);
		sender.close();
	}
	
	public static void main(String[] args) throws Exception
	{
		TransformCSV2XMLClient client = new TransformCSV2XMLClient();
		client.setupConnection();
		client.sendAMessage("SampleOrder.csv");
		client.stop();
	}
}

 

在客户端工程下创建SampleOrder.csv文件,并用文本编辑器编辑,输入以下内容:

1,Wed Nov 15 13:45:28 EST 2006,0,59.97,64.92,4.95,user1,Harry,Fletcher,SD,1,1,364,The 40-Year-Old Virgin,29.98,2,1,299,Pulp Fiction,29.99
2,Wed Nov 15 13:45:28 EST 2007,0,60.00,64.92,4.95,user2,Kalle,Anka,SD,1,1,364,Fletch,29.98,2,1,299,Fletch Lives,29.99
3,Wed Nov 15 13:45:28 EST 2007,0,60.00,64.92,4.95,user3,Donald,Duck,SD,1,1,364,The Goonies,29.98,2,1,4,Happy Gilmor,29.99

 

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

JBoss ESB        

 

 

今天阳光明媚,可心里却乌云密布……

天又黑了,可为什么总感觉天还没亮,肚子好饿……

 

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

 

分享到:
评论
2 楼 yarafa 2011-08-30  
哈哈,抱歉,1楼
1 楼 hesihua 2011-08-17  
我今天也是心里乌云密布 希望你的急救  可是你老不上线

相关推荐

    JBOSS_Esb学习资料

    6. **数据转换**:《JBoss_ESB学习笔记14——第十三个ESB应用Transform_CSV_to_XML.doc》展示了如何使用ESB进行数据格式转换,例如从CSV转为XML,这是在集成不同系统时经常遇到的需求。 7. **JMS路由**:《JBoss_...

    JBoss ESB 学习笔记

    #### 十四、第十三个ESB应用Transform CSV to XML - **重点**:演示如何转换不同格式的数据。 - **实现**:编写转换器,将CSV格式的数据转换成XML格式。 #### 十五、第十四个ESB应用Transform XML to POJO - **...

    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的基本概念、搭建开发环境以及进行简单的开发...

    ESB应用Transform_CSV_to_XML

    本篇文章将详细介绍如何利用JBoss ESB实现CSV文件到XML格式的转换,即Transform_CSV_to_XML应用。 #### 二、背景与目的 **背景:** 在实际业务场景中,不同系统间的数据交换往往需要将数据从一种格式转换为另一种...

    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程序员指南

    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

    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 例子

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

    JBoss ESB 开发指南

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

    JBOSSESB学习小结

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

Global site tag (gtag.js) - Google Analytics