当前位置:首页 > 开发 > 系统架构 > 架构 > 正文

Spring Integration-File Adapter使用

发表于: 2012-05-31   作者:Dead_knight   来源:转载   浏览次数:
摘要: File Adapter主要应用于企业应用程序之间共享文件系统的情况,一个应用写入,而其他应用通过轮询文件系统进行读取。File Adapter从不同的文件系统提取文件再转变成框架的Message并发布至通道中,或者从通道中提取Message再转变为文件并写入文件系统中。   一、配置环境 1.下载Spring Integration http://s3.amazonaws

File Adapter主要应用于企业应用程序之间共享文件系统的情况,一个应用写入,而其他应用通过轮询文件系统进行读取。File Adapter从不同的文件系统提取文件再转变成框架的Message并发布至通道中,或者从通道中提取Message再转变为文件并写入文件系统中。

 

一、配置环境

1.下载Spring Integration

http://s3.amazonaws.com/dist.springframework.org/release/INT/spring-integration-2.1.0.RELEASE-dist.zip

 

2.配置classpath依赖的jar

 

spring-integration-core-2.1.0.RELEASE.jar 

spring-integration-file-2.1.0.RELEASE.jar

org.springframework.asm-3.1.0.RELEASE.jar

org.springframework.aop-3.1.0.RELEASE.jar

org.springframework.beans-3.1.0.RELEASE.jar

org.springframework.core-3.1.0.RELEASE.jar

org.springframework.context-3.1.0.RELEASE.jar

org.springframework.context.support-3.1.0.RELEASE.jar

org.springframework.expression-3.1.0.RELEASE.jar

aopalliance-1.0.jar

commons-logging-1.1.1.jar

 

二、XML配置文件:spring-integration-file-context.xml

 

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int="http://www.springframework.org/schema/integration"
	xmlns:int-file="http://www.springframework.org/schema/integration/file"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
	    http://www.springframework.org/schema/integration 
	    http://www.springframework.org/schema/integration/spring-integration-2.1.xsd
        http://www.springframework.org/schema/integration/file
		http://www.springframework.org/schema/integration/file/spring-integration-file-2.1.xsd">
	<!-- 定义通道 -->
	<int:channel id="file-channel"/>
	
	<!-- 文件类型-输入通道适配器 -->
	<int-file:inbound-channel-adapter
		directory="D:/spring-integration-samples/input" channel="file-channel">
	    <int:poller fixed-rate="1000"/>
	</int-file:inbound-channel-adapter>
	
	<!-- 文件类型-输出通道适配器 -->
	<int-file:outbound-channel-adapter directory="D:/spring-integration-samples/output" channel="file-channel"/>
</beans>

 

三、编写测试类

 

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class TestFileSupport {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		ApplicationContext context = new ClassPathXmlApplicationContext(
		"spring-integration-file-context.xml");
	}
}

 

四、示例说明

实现功能:每秒间隔轮询D:/spring-integration-samples/input目录,如果发现该目录有文件,就依次复制到D:/spring-integration-samples/output目录中。实际上就是文件copy的功能

该示例使用了Spring Integration提供的File适配器。

 

深入File Adapter

1.防止重复读取:prevent-duplicates="true"

 

<int-file:inbound-channel-adapter
        directory="D:/spring-integration-samples/input" 
        channel="file-channel" prevent-duplicates="true">

 

2.文件过滤:filename-pattern="*.doc"或者filename-regex="[ABC]_positions.doc"

<int-file:inbound-channel-adapter
        directory="D:/spring-integration-samples/input" 
        channel="file-channel" filename-pattern="*.doc">
或者
<int-file:inbound-channel-adapter
        directory="D:/spring-integration-samples/input" 
        channel="file-channel" filename-regex="[ABC]_positions.doc">

 

 

3.文件锁:<file:nio-locker/>

<int-file:inbound-channel-adapter
        directory="D:/spring-integration-samples/input" 
        channel="file-channel" filename-regex="[ABC]_positions.doc">
    <file:nio-locker/>
    ……
</int-file:inbound-channel-adapter>

 

4.删除源文件:delete-source-files="true"

 

<int-file:outbound-channel-adapter 
        directory="D:/spring-integration-samples/output" 
        channel="file-channel" delete-source-files="true"/>

 

实际上还有很多属性用于设置共享文件系统出现的各种情况。这里不再赘述。

Spring Integration-File Adapter使用

  • 0

    开心

    开心

  • 0

    板砖

    板砖

  • 0

    感动

    感动

  • 0

    有用

    有用

  • 0

    疑问

    疑问

  • 0

    难过

    难过

  • 0

    无聊

    无聊

  • 0

    震惊

    震惊

编辑推荐
参考:http://www.2cto.com/kf/201305/211728.html 错误十三 在配置拦截器后,运行的时候报错=>
一、 使用WCF_SQL、WCF_Oracle、WCF_SAP adapter的公共安装前提
说起Adapter的使用,首先想到的就是listview或各种各样的Adapter。下面我们对常用的一些Adapter进行
http://www.nowamagic.net/librarys/veda/detail/317 Zend_Db_Adapter 是 zendframework 的数据库抽
http://www.nowamagic.net/librarys/veda/detail/317 Zend_Db_Adapter 是 zendframework 的数据库抽
点击查看原网页 ListView是在Android很常見的一種視圖,ListView不論在電話簿中還是觀看大量的列表
Abstract Adapter Pattern有Class Adapter和Object Adapter兩種實現方式。Class Adapter的優點是可o
项目用到ListView,由于要用到 ImageView ,图片源不是在资源里面的,没法使用资源 ID,因此无法直
项目用到ListView,由于要用到 ImageView ,图片源不是在资源里面的,没法使用资源 ID,因此无法直
首先我要说明的是这里“android用户编程技巧”系列的文章中所涉及的技术技巧以及讲述方式不是我本人
版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号