- 浏览: 2543061 次
- 性别:
- 来自: 成都
文章分类
最新评论
-
nation:
你好,在部署Mesos+Spark的运行环境时,出现一个现象, ...
Spark(4)Deal with Mesos -
sillycat:
AMAZON Relatedhttps://www.godad ...
AMAZON API Gateway(2)Client Side SSL with NGINX -
sillycat:
sudo usermod -aG docker ec2-use ...
Docker and VirtualBox(1)Set up Shared Disk for Virtual Box -
sillycat:
Every Half an Hour30 * * * * /u ...
Build Home NAS(3)Data Redundancy -
sillycat:
3 List the Cron Job I Have>c ...
Build Home NAS(3)Data Redundancy
mule2.2.x架构(三)示例学习hello
所有的示例文档
http://www.mulesoft.org/display/MULE2INTRO/Examples
本例参考示例地址
http://www.mulesoft.org/display/MULE2INTRO/Hello+World+Example
2.简单示例hello
2.1.接受标准输入驱动
主要分析了配置文件hello-config.xml
<!-- 提示语言,从hello-messages_zh_CN.properties中提取第三个元素 -->
<stdio:connector name="SystemStreamConnector"
promptMessageCode="3"
resourceBundle="messages.hello-messages"
messageDelayTime="1000"/>
<!-- 装换的工具类 -->
<custom-transformer name="StdinToNameString" class="com.sillycat.easymule.hello.transformer.StdinToNameString"/>
<custom-transformer name="NameStringToChatString" class="com.sillycat.easymule.hello.transformer.NameStringToChatString"/>
<custom-transformer name="ChatStringToString" class="com.sillycat.easymule.hello.transformer.ChatStringToString"/>
<custom-transformer name="ExceptionToString" class="com.sillycat.easymule.hello.transformer.ExceptionToString"/>
<model name="helloSample">
<service name="GreeterUMO">
<!-- 接受系统标准输入 -->
<inbound>
<stdio:inbound-endpoint system="IN" transformer-refs="StdinToNameString"/>
</inbound>
<component class="com.sillycat.easymule.hello.service.Greeter"/>
<outbound>
<!-- 根据类型,返回到不同的vm,vm貌似是mule的一个memory queen -->
<filtering-router>
<vm:outbound-endpoint path="chitchatter"/>
<payload-type-filter expectedType="com.sillycat.easymule.hello.model.NameString"/>
</filtering-router>
<filtering-router>
<vm:outbound-endpoint path="userErrorHandler"/>
<payload-type-filter expectedType="java.lang.Exception"/>
</filtering-router>
</outbound>
<default-service-exception-strategy>
<vm:outbound-endpoint path="systemErrorHandler"/>
</default-service-exception-strategy>
</service>
<!-- 正常的接受chitchatter的vm分支 -->
<service name="ChitChatUMO">
<inbound>
<vm:inbound-endpoint path="chitchatter" transformer-refs="NameStringToChatString"/>
</inbound>
<component class="com.sillycat.easymule.hello.service.ChitChatter"/>
<!-- 输出到控制台 -->
<outbound>
<pass-through-router>
<stdio:outbound-endpoint system="OUT" transformer-refs="ChatStringToString" />
</pass-through-router>
</outbound>
</service>
<!-- handler一些出错信息 -->
<service name="UserErrorHandler">
<inbound>
<vm:inbound-endpoint path="userErrorHandler" transformer-refs="ExceptionToString"/>
</inbound>
<outbound>
<pass-through-router>
<stdio:outbound-endpoint system="OUT"/>
</pass-through-router>
</outbound>
</service>
<service name="SystemErrorHandler">
<inbound>
<vm:inbound-endpoint path="systemErrorHandler"/>
</inbound>
<outbound>
<pass-through-router>
<stdio:outbound-endpoint system="ERR"/>
</pass-through-router>
</outbound>
</service>
</model>
2.2接受http请求驱动
主要分析了配置文件hello-http-config.xml,没有什么大的区别,主要是区分了第一个inbound,另外新增了transformer
<inbound>
<inbound-endpoint address="http://localhost:8888"
transformer-refs="HttpRequestToNameString" synchronous="true">
<not-filter>
<wildcard-filter pattern="/favicon.ico" />
</not-filter>
</inbound-endpoint>
</inbound>
以上是接受http请求的inbound,接受请求
http://localhost:8888?name=Ross
为啥是name=Ross
com.sillycat.easymule.hello.transformer.HttpRequestToNameString里面的NAME_REQUEST_PARAMETER就写死了再url里面去寻找
新增的transformer
<custom-transformer name="NameStringToChatString"
class="com.sillycat.easymule.hello.transformer.NameStringToChatString" />
<custom-transformer name="ChatStringToString"
class="com.sillycat.easymule.hello.transformer.ChatStringToString" />
<custom-transformer name="HttpRequestToNameString"
class="com.sillycat.easymule.hello.transformer.HttpRequestToNameString" />
<custom-transformer name="ExceptionToString"
class="com.sillycat.easymule.hello.transformer.ExceptionToString" />
<message-properties-transformer name="PlainTextResponseTransformer">
<add-message-property key="Content-Type" value="text/plain" />
</message-properties-transformer>
简单的测试完毕,基本上是按照英文文档上拷贝了一次。等学习完所有的example,再考虑如何和自己的系统结合。
所有的示例文档
http://www.mulesoft.org/display/MULE2INTRO/Examples
本例参考示例地址
http://www.mulesoft.org/display/MULE2INTRO/Hello+World+Example
2.简单示例hello
2.1.接受标准输入驱动
主要分析了配置文件hello-config.xml
<!-- 提示语言,从hello-messages_zh_CN.properties中提取第三个元素 -->
<stdio:connector name="SystemStreamConnector"
promptMessageCode="3"
resourceBundle="messages.hello-messages"
messageDelayTime="1000"/>
<!-- 装换的工具类 -->
<custom-transformer name="StdinToNameString" class="com.sillycat.easymule.hello.transformer.StdinToNameString"/>
<custom-transformer name="NameStringToChatString" class="com.sillycat.easymule.hello.transformer.NameStringToChatString"/>
<custom-transformer name="ChatStringToString" class="com.sillycat.easymule.hello.transformer.ChatStringToString"/>
<custom-transformer name="ExceptionToString" class="com.sillycat.easymule.hello.transformer.ExceptionToString"/>
<model name="helloSample">
<service name="GreeterUMO">
<!-- 接受系统标准输入 -->
<inbound>
<stdio:inbound-endpoint system="IN" transformer-refs="StdinToNameString"/>
</inbound>
<component class="com.sillycat.easymule.hello.service.Greeter"/>
<outbound>
<!-- 根据类型,返回到不同的vm,vm貌似是mule的一个memory queen -->
<filtering-router>
<vm:outbound-endpoint path="chitchatter"/>
<payload-type-filter expectedType="com.sillycat.easymule.hello.model.NameString"/>
</filtering-router>
<filtering-router>
<vm:outbound-endpoint path="userErrorHandler"/>
<payload-type-filter expectedType="java.lang.Exception"/>
</filtering-router>
</outbound>
<default-service-exception-strategy>
<vm:outbound-endpoint path="systemErrorHandler"/>
</default-service-exception-strategy>
</service>
<!-- 正常的接受chitchatter的vm分支 -->
<service name="ChitChatUMO">
<inbound>
<vm:inbound-endpoint path="chitchatter" transformer-refs="NameStringToChatString"/>
</inbound>
<component class="com.sillycat.easymule.hello.service.ChitChatter"/>
<!-- 输出到控制台 -->
<outbound>
<pass-through-router>
<stdio:outbound-endpoint system="OUT" transformer-refs="ChatStringToString" />
</pass-through-router>
</outbound>
</service>
<!-- handler一些出错信息 -->
<service name="UserErrorHandler">
<inbound>
<vm:inbound-endpoint path="userErrorHandler" transformer-refs="ExceptionToString"/>
</inbound>
<outbound>
<pass-through-router>
<stdio:outbound-endpoint system="OUT"/>
</pass-through-router>
</outbound>
</service>
<service name="SystemErrorHandler">
<inbound>
<vm:inbound-endpoint path="systemErrorHandler"/>
</inbound>
<outbound>
<pass-through-router>
<stdio:outbound-endpoint system="ERR"/>
</pass-through-router>
</outbound>
</service>
</model>
2.2接受http请求驱动
主要分析了配置文件hello-http-config.xml,没有什么大的区别,主要是区分了第一个inbound,另外新增了transformer
<inbound>
<inbound-endpoint address="http://localhost:8888"
transformer-refs="HttpRequestToNameString" synchronous="true">
<not-filter>
<wildcard-filter pattern="/favicon.ico" />
</not-filter>
</inbound-endpoint>
</inbound>
以上是接受http请求的inbound,接受请求
http://localhost:8888?name=Ross
为啥是name=Ross
com.sillycat.easymule.hello.transformer.HttpRequestToNameString里面的NAME_REQUEST_PARAMETER就写死了再url里面去寻找
新增的transformer
<custom-transformer name="NameStringToChatString"
class="com.sillycat.easymule.hello.transformer.NameStringToChatString" />
<custom-transformer name="ChatStringToString"
class="com.sillycat.easymule.hello.transformer.ChatStringToString" />
<custom-transformer name="HttpRequestToNameString"
class="com.sillycat.easymule.hello.transformer.HttpRequestToNameString" />
<custom-transformer name="ExceptionToString"
class="com.sillycat.easymule.hello.transformer.ExceptionToString" />
<message-properties-transformer name="PlainTextResponseTransformer">
<add-message-property key="Content-Type" value="text/plain" />
</message-properties-transformer>
简单的测试完毕,基本上是按照英文文档上拷贝了一次。等学习完所有的example,再考虑如何和自己的系统结合。
发表评论
-
SOAP AXIS2 with HTTPS
2011-11-24 15:28 4246SOAP AXIS2 with HTTPS 1. sampl ... -
xfire后续问题补充
2010-01-06 14:34 2627xfire后续问题补充 问题一:xfire的方法中,需要知道 ... -
AXIS实现WebService
2010-01-06 11:51 3953AXIS实现WebService webservice里面对 ... -
xfire的webservice安全机制之签名
2010-01-05 23:31 1376xfire的webservice安全机制之签名 服务端配置修 ... -
xfire的webservice安全机制之签名
2010-01-05 23:29 1609xfire的webservice安全机制之签名 服务端配置修 ... -
xfire的webservice安全机制之用户校验
2010-01-05 23:29 2103xfire的webservice安全机制之用户校验 xfir ... -
xfire的webservice安全机制之加密(三)
2010-01-05 23:29 1261如何用KEYTOOL工具生成私匙和公匙 1、通过别名和密码创 ... -
xfire的webservice安全机制之加密(二)
2010-01-05 23:28 2813xfire的webservice安全机制 下面是客户端调用的 ... -
xfire的webservice安全机制之加密(一)
2010-01-05 23:28 2879xfire的webservice安全机制 在原来使用xfir ... -
spring下的webservice之xfire
2010-01-05 23:25 2031http://xfire.codehaus.org/ xfi ... -
Xfire在Weblogic10.3上发布的问题
2010-01-05 10:37 6316Xfire在Weblogic10.3上发布的问题 最近项目的 ... -
mule2.2.x架构(八)部署到WEB项目
2010-01-05 10:36 1959mule2.2.x架构(八)部署到WEB项目 所有的示例文档 ... -
xfire的Client的WSDL调用
2010-01-05 10:36 3151xfire的Client的WSDL调用 也只是想测试一下,如 ... -
mule2.2.x架构(七)示例学习LoanBroker
2010-01-05 10:36 1702mule2.2.x架构(七)示例学习LoanBroker 所 ... -
xfire的client的JAVA调用方式
2010-01-05 10:35 3539xfire的client的JAVA调用方式 平时我们调用xf ... -
mule2.2.x架构(六)示例学习scripting
2010-01-05 10:35 1465mule2.2.x架构(六)示例学习scripting 所有 ... -
mule2.2.x架构(五)示例学习errorHandle
2010-01-05 10:34 1672mule2.2.x架构(五)示例学习errorHandle ... -
mule2.2.x架构(四)示例学习StockQuote
2010-01-05 10:34 1867mule2.2.x架构(四)示例学习StockQuote 所 ... -
mule2.2.x架构(二)示例学习echo
2010-01-05 10:33 1768mule2.2.x架构(二)示例学习echo 所有的示例文档 ... -
mule2.2.x架构(一)环境搭建
2010-01-05 10:31 2273mule2.2.x架构(一)环境搭建 MULE首页 http ...
相关推荐
《Mule2.2 BookStore例子学习》 Mule2.2是一款强大的企业级集成平台,主要用于构建应用程序之间的数据和流程集成。在这个BookStore的例子中,我们将深入理解Mule ESB(Enterprise Service Bus)的核心概念和工作...
#### 三、Mule 架构 Mule 的架构设计考虑到了如何高效处理数据和消息,下面是一些关键点: - **SOA 的概念**: Mule 基于 SOA 思想构建,这意味着服务是独立的单元,彼此之间可以协作,但又可以独立运行。这有助于...
GomPlayer类似于KMplayer,同样也是一款来自韩国播放器,界面精美、功能全面。多媒体播放器GOMPlayer... 以‘查找解码’功能来支持所有视频的播放,在BT或e-mule等P2P网站中下载的影片会经常不能播放,GOM Player以独
Mule讲解.docxMule讲解.docx
2) 支持BT或e-mule等P2P站点中接收到损坏的文件, 因中断页传送完成的文件, 索引损坏的AVI文件的播放. 3) 想截取的视频画面可以储存为图像 (JPG, BMP)文件, 还可以通过连续截图取功能来实现把影片的场景以帧为单位, ...
包含http、cxf、vm、sap、activeMq、ftp、file、poll、Smtp、attachment、melExpression、Java、template节点的使用示例等。
弹性APM Mule3代理介绍此插件允许使用Elastic APM监视Mule 3.x组件的应用程序性能。 它提供了一种非侵入性的方式来度量和基准化Mule中的各个流程和步骤,并添加了对Mule组件的应用程序性能监控,以与日志,指标和...
然而,Mule的内部API并未基于JBI标准,而是拥有自己独特的架构设计,这为开发人员提供了更多的自由度和创新空间。 相比之下,ServiceMix的核心在于其JBI基础。作为一款遵循JBI标准的集成平台,ServiceMix旨在提供一...
【Mule Web Service 示例】 Mule ESB(Enterprise Service Bus)是一种强大的集成平台,它允许开发者轻松地构建和部署分布式应用程序。在这个示例中,我们将深入探讨如何使用Mule来发布Web服务,这是一种允许不同...
在“EIP经典案例ESB实践之Mule实现.doc”文档中,你将深入了解到如何使用Mule ESB来实施Load Broker方案,包括具体的配置步骤、示例代码以及最佳实践。通过学习和实践,你可以掌握如何利用Mule ESB优化企业的服务...
ESB解决方案-mule分享 ESB(Enterprise Service Bus)是传统中间件技术与 XML、WEB 服务等技术结合的产物。它提供了网络中最基本的服务总线功能,用于集成多个异构系统,实现系统之间的数据交换和业务流程集成。 ...
《Mule ESB实战:基于mule-2.2.1-src的开发示例解析》 Mule ESB,作为一款强大的企业服务总线(Enterprise Service Bus),在集成和连接不同系统方面展现了卓越的能力。本篇文章将围绕"mule_examples.rar_mule_mule...
附带的源码是书中示例的实现,读者可以下载并跟随书中步骤操作,这将极大地增强学习体验,加深对Mule ESB工作原理的理解。源码的分析和实践将帮助读者掌握实际开发中的技巧和最佳实践。 Mule ESB的强大之处在于其...
The book closes with a set of chapterson the nuts and bolts of working with Mule. Readers can take Mule farther bylearning techniques for testing, performance tuning, BPM orchestration, andeven a ...
org.mule.module.management.agent.JmxAgent: Registered Endpoint Service with name: Mule.04cd6ac8-9c81-11e0-95b7-8bd1ea0dc252:type=Endpoint,service="HelloWorld",connector=connector.http.mule.default,...
【企业服务总线(ESB)】是现代企业IT架构中的关键组成部分,它解决了企业内部“信息孤岛”问题,实现了系统间的高效集成。ESB的出现源于企业对信息共享、系统互操作性和软件重用的迫切需求。随着业务规模的扩大和...