mule esb exception(一)
2015-06-03 18:07
288 查看
mule esb 异常分类
system exception
message exception
系统异常出现的两种情况:
应用启动时出的异常
连接外部系统时出现的异常
for example:读取文件,当文件正在写入时,file connector endpoint去读这个文件,出现的异常即为系统异常,stackoverflow也有相关参考
系统异常相当于java中的Error
由于系统异常处于应用不可用状态,重点分析 message exception
Message Exception
message exception适用如下情况:
信息源–>信息处理–>…n–>信息处理时如果处理的信息发生异常,就调用异常策略处理异常,异常中也可以有多个信息处理,然后到输出端(outbound message)
废话说了这么多,搞技术的重应用直接上例子
以上例子测试ok,修改了发邮件部分,当然不能暴漏我的邮件服务器啦
以上代码是 file connector inbound 参考这里
以上是对应的异常处理:
捕获异常后打印对应的日志信息
邮件内容信息在 payload中显示,所有赋值payload
发邮件输出异常日志信息
这段非常重要:上面定义的异常策略是为了后期引用,以上代码 指定默认的异常策略为 以上定义的异常:通过名称Catch_Exception_Strategy引用定义异常
以上是个完整的flow例子,一般情况下不会抛出异常,如果我想测试一下,抛出异常后是否会发邮件:
只能手工抛出异常:详细参考这里
添加如上代码
看这个类的实现:
会抛出:UnsupportedOperationException异常
这样就会调用邮件处理输出端发送邮件:
打印异常信息如下:
先简单写到这里,后期再谈 mule esb exception
system exception
message exception
系统异常出现的两种情况:
应用启动时出的异常
连接外部系统时出现的异常
for example:读取文件,当文件正在写入时,file connector endpoint去读这个文件,出现的异常即为系统异常,stackoverflow也有相关参考
系统异常相当于java中的Error
由于系统异常处于应用不可用状态,重点分析 message exception
Message Exception
message exception适用如下情况:
信息源–>信息处理–>…n–>信息处理时如果处理的信息发生异常,就调用异常策略处理异常,异常中也可以有多个信息处理,然后到输出端(outbound message)
废话说了这么多,搞技术的重应用直接上例子
<?xml version="1.0" encoding="UTF-8"?> <mule xmlns:jms="http://www.mulesoft.org/schema/mule/jms" xmlns:smtp="http://www.mulesoft.org/schema/mule/smtp" xmlns:file="http://www.mulesoft.org/schema/mule/file" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:spring="http://www.springframework.org/schema/beans" version="EE-3.6.1" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.mulesoft.org/schema/mule/jms http://www.mulesoft.org/schema/mule/jms/current/mule-jms.xsd http://www.mulesoft.org/schema/mule/smtp http://www.mulesoft.org/schema/mule/smtp/current/mule-smtp.xsd http://www.mulesoft.org/schema/mule/file http://www.mulesoft.org/schema/mule/file/current/mule-file.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd"> <!-- Typical Connector for Inbound Endpoint: Read files --> <file:connector name="input" autoDelete="true" pollingFrequency="1000" fileAge="600000" moveToDirectory="D:\mule\import\backup" moveToPattern="#[message.inboundProperties['originalFilename']].backup" doc:name="File" /> <!-- Typical Connector for Outbound Endpoint: Write files --> <file:connector name="output" doc:name="File" /> <catch-exception-strategy name="Catch_Exception_Strategy" > <logger message=" 文件名: #[message.inboundProperties['originalFilename']] 在 #[server.dateTime.format("yyyy.MM.dd HH:mm:ss '出现异常信息' ")] #[exception]" level="INFO" doc:name="Logger"/> <set-payload value="文件名: #[message.inboundProperties['originalFilename']] 在 #[server.dateTime.format("yyyy.MM.dd HH:mm:ss '出现异常信息' ")] #[exception]" doc:name="Set Payload"/> <smtp:outbound-endpoint host="smtp.mailserver.com" user="host" password="*****" to="test@163.com" from="fromtest@mailserver.com" subject="testfile" responseTimeout="10000" encoding="GB18030" mimeType="text/html" doc:name="SMTP"/> </catch-exception-strategy> <configuration defaultExceptionStrategy-ref="Catch_Exception_Strategy" doc:name="Configuration" doc:description="Use as implicit default exception strategy."/> <flow name="fileimport"> <file:inbound-endpoint connector-ref="input" path="D:\mule\import\input" doc:name="File" responseTimeout="10000"> <file:filename-wildcard-filter pattern="导出*.doc" /> </file:inbound-endpoint> <!-- <null-component /> --> <file:outbound-endpoint connector-ref="output" path="D:\mule\import\output" doc:name="File" responseTimeout="10000" /> </flow> </mule>
以上例子测试ok,修改了发邮件部分,当然不能暴漏我的邮件服务器啦
<file:connector name="input" autoDelete="true" pollingFrequency="1000" fileAge="600000" moveToDirectory="D:\mule\import\backup" moveToPattern="#[message.inboundProperties['originalFilename']].backup" doc:name="File" /> <file:connector name="output" doc:name="File" />
以上代码是 file connector inbound 参考这里
<catch-exception-strategy name="Catch_Exception_Strategy" > <logger message=" 文件名: #[message.inboundProperties['originalFilename']] 在 #[server.dateTime.format("yyyy.MM.dd HH:mm:ss '出现异常信息' ")] #[exception]" level="INFO" doc:name="Logger"/> <set-payload value="文件名: #[message.inboundProperties['originalFilename']] 在 #[server.dateTime.format("yyyy.MM.dd HH:mm:ss '出现异常信息' ")] #[exception]" doc:name="Set Payload"/> <smtp:outbound-endpoint host="smtp.mailserver.com" user="host" password="*****" to="test@163.com" from="fromtest@mailserver.com" subject="testfile" responseTimeout="10000" encoding="GB18030" mimeType="text/html" doc:name="SMTP"/> </catch-exception-strategy> <configuration defaultExceptionStrategy-ref="Catch_Exception_Strategy" doc:name="Configuration" doc:description="Use as implicit default exception strategy."/>
以上是对应的异常处理:
<logger message=" 文件名: #[message.inboundProperties['originalFilename']] 在 #[server.dateTime.format("yyyy.MM.dd HH:mm:ss '出现异常信息' ")] #[exception]" level="INFO" doc:name="Logger"/>
捕获异常后打印对应的日志信息
<set-payload value="文件名: #[message.inboundProperties['originalFilename']] 在 #[server.dateTime.format("yyyy.MM.dd HH:mm:ss '出现异常信息' ")] #[exception]" doc:name="Set Payload"/>
邮件内容信息在 payload中显示,所有赋值payload
<smtp:outbound-endpoint host="smtp.mailserver.com" user="host" password="*****" to="test@163.com" from="fromtest@mailserver.com" subject="testfile" responseTimeout="10000" encoding="GB18030" mimeType="text/html" doc:name="SMTP"/>
发邮件输出异常日志信息
<configuration defaultExceptionStrategy-ref="Catch_Exception_Strategy" doc:name="Configuration" doc:description="Use as implicit default exception strategy."/>
这段非常重要:上面定义的异常策略是为了后期引用,以上代码 指定默认的异常策略为 以上定义的异常:通过名称Catch_Exception_Strategy引用定义异常
以上是个完整的flow例子,一般情况下不会抛出异常,如果我想测试一下,抛出异常后是否会发邮件:
只能手工抛出异常:详细参考这里
添加如上代码
看这个类的实现:
/* *(c) 2003-2014 MuleSoft, Inc. This software is protected under international copyright *law. All use of this software is subject to MuleSoft's Master Subscription Agreement *(or other master license agreement) separately entered into in writing between you and *MuleSoft. If such an agreement is not in place, you may not use the software. */ package org.mule.component.simple; import org.mule.api.MuleEventContext; import org.mule.api.lifecycle.Callable; /** * <code>NullComponent</code> is a service that is used as a placeholder. This * implementation will throw an exception if a message is received for it. */ public class NullComponent implements Callable { public Object onCall(MuleEventContext context) throws Exception { throw new UnsupportedOperationException("This service cannot receive messages. Service is: " + context.getFlowConstruct().getName()); } }
会抛出:UnsupportedOperationException异常
这样就会调用邮件处理输出端发送邮件:
打印异常信息如下:
先简单写到这里,后期再谈 mule esb exception
相关文章推荐
- 控制android 编译源码生成odex .
- iOS中图片拉伸技巧
- ios开发之Swift新手入门
- URAL 1996 Cipher Message 3
- andoid下的股票行情开发
- [.net 面向对象编程基础] (5) 基础中的基础——变量和常量
- hdoj1176_免费馅饼(dp)
- cocos2d安卓android长音效播放不完全
- 不可不知的安卓屏幕知识
- 简单数学问题
- 输出杨辉三角
- SQL Server系统视图 [不定期更新]
- Bootstrap入门学习(三)——简单项目
- Bootstrap入门学习(三)——简单项目
- weblogic启动缓慢解决方案 . 启动到<Info> <Management> <BEA-141107>卡住不动
- STL之list
- WordPress 主题制作常用函数
- 异常详细信息: System.Data.SqlClient.SqlException:用户 'IIS APPPOOL\DefaultAppPool' 登录失败解决办法
- Hyper-V 功能对比 windows 2008 R2 vs 2012
- SEO优化的四个建议