perl大骆驼和小骆驼

Apache Camel在其主页上 (以及Camel用户指南中 )将其描述为“基于已知企业集成模式的通用开源集成框架”。 Camel框架基于《 企业集成模式 》一书,并提供了该书中描述的模式的实现 。 我看一下这篇文章中使用Camel的“ Hello World”类型示例。

Camel网页和用户指南还引用了StackOverflow线程Apache Camel到底是什么? 其中包括对Apache Camel的一些很好的描述。 David Newcomb在那儿描述了骆驼:


Apache Camel是消息传递技术与路由的结合。 它将消息传递的起点和终点连接在一起,从而允许将消息从不同的源传输到不同的目的地。 例如:JMS-> JSON,HTTP-> JMS或渠道FTP-> JMS,HTTP-> JMS,JMS => JSON。

在本文中,我介绍了一种简单的Camel用法,它不需要使用JMS提供程序,甚至不需要FTP或HTTP。 保持简单的示例可以使您更清楚地使用Camel。 本示例使用Camel自动将文件从指定目录传输到其他指定目录。 将演示三种情况。

在第一种情况下,放置在“输入”目录中的文件会自动复制到“输出”目录,而不会影响源文件。 在第二种情况下,放置在“输入”目录中的文件会自动复制到“输出”目录,然后将“输入”目录中的文件存储在“输入”目录下的特殊“ .camel”子目录中。 第三种情况是在复制到“输出”目录(实际上是“移动”操作)后,从“输入”目录中删除文件。 这三种情况都是用几乎相同的代码实现的。 两者之间的唯一区别是在一行中指定了Camel应该如何处理文件传输。

下一个代码清单显示了使用Camel自动将放置在输入目录中的文件复制到Camel所需的基本代码所需的基本代码。

/*** Simple executable function to demonstrate Camel file transfer.* * @param arguments Command line arguments; excepting duration in milliseconds*    as single argument.*/
public static void main(final String[] arguments)
{final long durationMs = extractDurationMsFromCommandLineArgs(arguments);final CamelContext camelContext = new DefaultCamelContext();try{camelContext.addRoutes(new RouteBuilder(){@Overridepublic void configure() throws Exception{from('file:C:\\datafiles\\input?noop=true').to('file:C:\\datafiles\\output');}});camelContext.start();Thread.sleep(durationMs);camelContext.stop();}catch (Exception camelException){LOGGER.log(Level.SEVERE,'Exception trying to copy files - {0}',camelException.toString());}
}

上面的代码演示了对Camel API和Camel的Java DSL支持的最少使用。 CamelContext是用DefaultCamelContext的实例定义的(第10行)。 第13-21行将骆驼路线添加到此实例化的上下文中,第22行开始上下文,第24行停止上下文。 这一切都非常简单,但是对我来说最有趣的部分是第19行的路由规范。

因为实现提供给Camel Context的RoutesBuilder接口的实例只需要重写其抽象configure方法,所以可以很容易地将类实例化为与CamelContext.addRoutes(RoutesBuilder)内联的匿名类。 这是我在上面的代码中所做的,也是在许多在线提供的Camel示例中所做的事情。

第19行显示了高度可读的语法,描述了路由的“从”和“到”部分。 在这种情况下,放置在输入目录(“ from”)中的文件将被复制到输出目录(“ to”)。 “文件”协议可用于“发件人”和“发件人”部分,因为文件系统是“消息”的来源和去向。 “ from”调用中的“?noop = true”表示对“ input”目录中的文件不做任何更改(处理应对源文件产生“ noop”作用)。

如前所述,以上代码中的第19行指示Camel将“输入”目录中已经存在或放置的文件复制到指定的“输出”目录,而不会影响“输入”目录中的文件。 在某些情况下,我可能想“移动”文件而不是“复制”它们。 在这种情况下,当指定“ from”端点时,可以指定?delete=true而不是?noop=true 。 换句话说,上面的第19行可以替换为将文件放置在“输出”目录中时从“输入”目录中删除文件。 如果在输入上未指定任何参数( ?noop=true?delete=true ),则将发生介于两者之间的操作:“ input”目录中的文件将移至该目录下的一个专门创建的新子目录中。 “输入”目录称为.camel 。 接下来将突出显示这三种情况。

从数据文件\输入复制到数据文件\输出的文件,而不会影响原始文件

from('file:C:\\datafiles\\input?noop=true').to('file:C:\\datafiles\\output');

文件从数据文件\输入移至数据文件\输出

from('file:C:\\datafiles\\input?delete=true').to('file:C:\\datafiles\\output');

从datafiles \ input复制到datafiles \ output的文件,并将原始文件移到.camel子目录

from('file:C:\\datafiles\\input').to('file:C:\\datafiles\\output');

附带说明一下,流畅的'from'和'to'的使用是Camel的Java DSL的示例。 Camel通过实现继承(在RouteBuilder类中定义了“ from”和“ to”之类的方法)而不是通过静态导入 ( 通常用于基于Java的DSL的方法) 来实现此目的。

尽管将RouteBuilder匿名实例RouteBuilder给Camel Context是很常见的,但这不是RouteBuilder的。 在某些情况下,拥有扩展RouteBuilder独立类以及将这些扩展类的实例传递给Camel Context的情况是有利的。 我将使用这种方法来演示我之前描述的所有三种情况。 下一个代码清单显示了扩展RouteBuilder的类。 在许多情况下,我将使用无参数构造函数,但在这种情况下,我将使用构造函数来确定骆驼路线应支持哪种类型的文件传输。

下一个代码清单显示了一个命名的独立类,该类处理上述所有三种情况(复制,使用输入文件归档进行复制以及移动)。 RouteBuilder单个扩展在其构造函数中使用一个枚举来确定如何配置输入端点。

package dustin.examples.camel;import org.apache.camel.builder.RouteBuilder;/*** Camel-based Route Builder for transferring files.* * @author Dustin*/
public class FileTransferRouteBuilder extends RouteBuilder
{public enum FileTransferType{COPY_WITHOUT_IMPACTING_ORIGINALS('C'),COPY_WITH_ARCHIVED_ORIGINALS('A'),MOVE('M');private final String letter;FileTransferType(final String newLetter){this.letter = newLetter;}public String getLetter(){return this.letter;}public static FileTransferType fromLetter(final String letter){FileTransferType match = null;for (final FileTransferType type : FileTransferType.values()){if (type.getLetter().equalsIgnoreCase(letter)){match = type;break;}}return match;}}private final String fromEndPointString;private final static String FROM_BASE = 'file:C:\\datafiles\\input';private final static String FROM_NOOP = FROM_BASE + '?noop=true';private final static String FROM_MOVE = FROM_BASE + '?delete=true';public FileTransferRouteBuilder(final FileTransferType newFileTransferType){if (newFileTransferType != null){switch (newFileTransferType){case COPY_WITHOUT_IMPACTING_ORIGINALS :this.fromEndPointString = FROM_NOOP;break;case COPY_WITH_ARCHIVED_ORIGINALS :this.fromEndPointString = FROM_BASE;break;case MOVE :this.fromEndPointString = FROM_MOVE;break;default :this.fromEndPointString = FROM_NOOP;}}else{fromEndPointString = FROM_NOOP;}}@Overridepublic void configure() throws Exception{from(this.fromEndPointString).to('file:C:\\datafiles\\output');}
}

这篇博客文章演示了如何使用Camel轻松地将文件从一个目录路由到另一个目录。 骆驼支持许多其他的传输机制和数据格式,这里没有显示。 骆驼还支持转换要路由的消息/数据的功能,此处也未显示。 这篇文章重点介绍了如何以有用的方式应用Camel的最简单的示例,但是Camel支持的远远超过此简单示例中显示的内容。

参考: Hello Camel:来自JCG合作伙伴 Dustin Marx的“ 实际事件启发”博客中的自动文件传输 。

翻译自: https://www.javacodegeeks.com/2013/02/hello-camel-automatic-file-transfer.html

perl大骆驼和小骆驼

perl大骆驼和小骆驼_你好骆驼:自动文件传输相关推荐

  1. 你好骆驼:自动文件传输

    Apache Camel在其主页上 (以及Camel用户指南中 )将其描述为"基于已知企业集成模式的通用开源集成框架". Camel框架基于< 企业集成模式 >一书,并 ...

  2. fastapi 传输文件存文件_揭秘|国内影视文件传输的真相,跨境文件传输更不简单...

    2020年影视行业至黑时刻总算要过去了,下半年复苏迹象已经显现.作为影视行业的基础搬运工,文件传输贯穿始末.无论是TB级原始素材还是后期协作的大文件,多团队高效协作必然要考虑大文件传输这个基础工具. ...

  3. 基于小程序+云开发制作一个文件传输助手小程序

    微信文件传输助手是真人?基于云开发制作一个文件传输助手小程序,你发给ta的小秘密,只有你自己知道. 开发步骤 一.创建小程序 二.云开发配置 环境配置 绑定云环境 三.页面设计 首页 详情页 底部弹窗 ...

  4. 值对于 int32 太大或太小。_失效值处理

    失效值处理 桥梁监测系统是一个复杂的系统,用于监测的传感器系统数量众多.种类不同.在采集.传输过程中由于传感器使用了较长的时间,自身出现故障的概率比较大或者在传输的过程中由于不确定的干扰或影响造成数据 ...

  5. 多个表左连接 先连大表还是小表_汽车连接器的拆卸工具

    欢迎关注并置顶"线束世界" ① 点击上方蓝字"线束世界" ② 点击右上角···置顶公众号 电子连接器现如今广泛运用于大型LDE电源.光伏电源.大型网络.计算机通 ...

  6. Qt网络编程小项目-基于Tcp协议的文件传输项目

    目录 项目描述 Qt下Tcp服务器端和客户端流程: 具体流程: 客户端: 服务器端: 源码: 服务器端: 服务器头文件: 服务器源文件: 服务器端ui 客户端: 客户端头文件: 客户端源文件: 客户端 ...

  7. scp 命令 路径_基于SSH的文件传输:scp命令

    日常开发中,经常需要在服务器和本地之间进行文件传输.这里来介绍一种基于SSH的文件传输方法--scp命令 命令格式 scp(secure copy,remote file copy program), ...

  8. python文件安全传输系统_安全的directconnect文件传输程序

    我正在考虑做一个附带的项目,将涉及到一个标准的直接连接方式文件传输.为了澄清,如果9.9.9.9想将文件发送到10.10.10.10,那么10.10.10.10将监听某个端口,然后9.9.9.9可以使 ...

  9. 将本地视频上传到云端_本地-云端的文件传输

    目录下执行 python -m SimpleHTTPServer 在linux下一般用scp这个命令来通过ssh传输文件. 1.从服务器上下载文件 scp username@servername:/p ...

最新文章

  1. 获取IP地址和MAC地址
  2. js - 浅拷贝和深拷贝
  3. listview频繁刷新报错
  4. **【POJ - 2389】 Bull Math (高精度乘法)
  5. ec200t 拨号_移远EC20 R2.0 AT指令拨号流程
  6. C# 自定义类型转换
  7. 2017.7.19 Race 思考记录
  8. 学习戴铭博文《从 ReactiveCocoa 中能学到什么?不用此库也能学以致用》的总结...
  9. opecv-putText
  10. 线程间的通信之wait和notify的使用
  11. Java证书工具keytool用法总结
  12. 永洪BI-通过传输参数控制页面显示多少数据量
  13. C# XmlDocument.Save文件操作System.IO.IOException:The process cannot access the file because it is being
  14. ie6 html 模板,网页排版应该考虑IE6的兼容性问题_HTML/Xhtml_网页制作
  15. aardio 多线程开发入门
  16. Flutter和RN对比分析
  17. 蓝牙5.2协议、主从一体、低功耗、工业级蓝牙模组BLE105新品上市
  18. 【ENVI入门系列】01.ENVI产品简介与入门
  19. MySQL 多个in 条件需要注意的地方
  20. 达梦数据库初始化实例参数说明(页大小 (page_size)、簇大小 (extent_size)、大小写敏感 (case_sensitive)、字符集 (charset))

热门文章

  1. 聊聊并发(四)深入分析ConcurrentHashMap
  2. 阿里巴巴对Java编程【并发处理】的规约
  3. 如何封装并发布一个属于自己的ui组件库
  4. 最全三大框架整合(使用映射)——IDeptDao.java
  5. Ajax响应处理数据的三种格式(主要使用gson包)
  6. php匿名类的应用场景,【modernPHP专题(9)】匿名类
  7. 页面复杂对象传递参数 开发中遇到的问题
  8. java面试设计模式
  9. dismiss的词组_法律英语常用词必记:Dismiss
  10. dex工具与transform_Android Studio打包程序时出现transformClassesWithDexForRelease错误