- 浏览: 86771 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
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应用——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
运行客户端程序即可看到以下输出结果:
今天阳光明媚,可心里却乌云密布……
天又黑了,可为什么总感觉天还没亮,肚子好饿……
-----------------------------------------------------
Stay Hungry, Stay Foolish!
http://yarafa.iteye.com
Afa
Apr 9th, 2011
-----------------------------------------------------
发表评论
-
JBoss ESB学习笔记16——第十五个ESB应用Web Service Consumer 1
2011-04-15 21:06 3211续上篇介绍了第十四个ESB应用,本文介绍第十五个ESB应用—— ... -
JBoss ESB学习笔记15——第十四个ESB应用Transform XML to POJO
2011-04-12 13:09 1991续上篇介绍了第十三个ESB应用,本文介绍第十四个ESB应用—— ... -
JBoss ESB学习笔记13——第十二个ESB应用Spring AOP
2011-04-03 11:42 1559续上篇介绍了第十一个ESB应用,本文介绍第十二个ESB应用—— ... -
JBoss ESB学习笔记12——第十一个ESB应用Spring Hello World
2011-04-01 15:27 2273续上篇介绍了第十个ESB应用,本文介绍第十一个ESB应用——S ... -
JBoss ESB学习笔记11——第十个ESB应用Message Filters
2011-03-29 20:35 1918续上篇介绍了第九个ESB应用,本文介绍第十个ESB应用——Me ... -
JBoss ESB学习笔记10——第九个ESB应用JMS Topic
2011-03-26 21:14 2309续上篇介绍了第八个ESB应用,本文介绍第九个ESB应用——JM ... -
JBoss ESB学习笔记9——第八个ESB应用JMS Router
2011-03-11 21:16 2500续上篇介绍了第七个ESB应用,本文介绍第八个ESB应用——JM ... -
JBoss ESB学习笔记8——第七个ESB应用Https Gateway
2011-03-05 11:29 2489续上篇介绍了第六个ESB应用,本文介绍第七个ESB应用——Ht ... -
JBoss ESB学习笔记7——第六个ESB应用Http Gateway
2011-02-26 10:45 3419续上篇介绍了第五个ESB应用,本文介绍第六个ESB应用——Ht ... -
JBoss ESB学习笔记6——第五个ESB应用Custom Action
2011-01-15 10:34 2208续上篇介绍了第四个ESB应用,本文介绍第五个ESB应用——Cu ... -
JBoss ESB学习笔记5——第四个ESB应用Hello World File Action
2011-01-08 11:23 2579续上篇介绍了第三个ESB应用,本文介绍第四个ESB应用——He ... -
JBoss ESB学习笔记4——第三个ESB应用Hello World Notification
2011-01-03 15:01 2977续上篇介绍了第二个ESB应用,本文介绍第三个ESB应用——He ... -
JBoss ESB学习笔记3——第二个ESB应用Hello World Action
2010-12-21 22:20 3768续上篇介绍了第一个ESB应用,本文介绍第二个ESB应用——He ... -
JBoss ESB学习笔记2——第一个ESB应用Hello World
2010-12-13 20:34 6513续上文搭建好开发环境后就可以开发ESB应用了。本文介绍第一个E ... -
JBoss ESB学习笔记1——搭建ESB开发环境
2010-12-12 13:55 7697最近由于工作需要用到 ...
相关推荐
自己辛苦整理的网上的JBoss ESB学习笔记 ,非常详细,代码操作都...14——第十三个ESB代码Transform CSV to XML 122 15——第十四个ESB代码Transform XML to POJO 128 16——第十五个ESB代码Web Service Consumer 1 151
JBossESB学习笔记 收集了网上1-16系列教程,笔记详细介绍了JBossESB各个组件的特性及配置文件的说明
Jboss_ESB学习笔记以及总结和实例
ESB应用Transform_CSV_to_XML.
Jboss_ESB学习笔记,介绍的很详细,可以作为入门文档来看。
jboss esb 实例及讲解,我收集的资料整理做成书
Jboss_ESB学习笔记.doc
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的简介 1、 什么是ESB。 ESB的全称是Enterprise Service Bus,即企业服务总线。ESB是过去消息中间件的发展,ESB采用了“总线”这样一种模式来管理和简化应用之间的集成拓扑结构,以广为接受的开放...
JBoss ESB新手指南 / JBoss ESB Beginners Guide。 一本很好的jboss esb入门书籍。
jbossesb开发手册,适合初学者学习使用
JBoss ESB 入门例子。主要是一个Server和一个Client。
NULL 博文链接:https://siye1982.iteye.com/blog/592400
ESB应用Transform_XML_to_POJO
JBOSS_Esb学习资料包含各种基础学习资料与协议交互资料
JBoss ESB Beginner's Guide
1.JBossESB的总体要求和我们应采取的架构方法的纲要。2.JBossESB的主要目的是提供一个部署,运行和管理的SOA基础结构。 3.SOA原则将贯穿于整个架构,而传统意义上ESB可能是它所提供功能的一狭小部分
。。。
中文版,简易介绍 JBOSS ESB的说明文档.
JbossESB开发环境配置.docxJbossESB开发环境配置.docx