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"/>
实际上还有很多属性用于设置共享文件系统出现的各种情况。这里不再赘述。
分享到:
相关推荐
赠送jar包:sentinel-spring-cloud-gateway-adapter-1.8.0.jar; 赠送原API文档:sentinel-spring-cloud-gateway-adapter-1.8.0-javadoc.jar; 赠送源代码:sentinel-spring-cloud-gateway-adapter-1.8.0-sources....
赠送jar包:sentinel-spring-webflux-adapter-1.8.0.jar; 赠送原API文档:sentinel-spring-webflux-adapter-1.8.0-javadoc.jar; 赠送源代码:sentinel-spring-webflux-adapter-1.8.0-sources.jar; 赠送Maven依赖...
赠送jar包:sentinel-spring-webflux-adapter-1.8.0.jar; 赠送原API文档:sentinel-spring-webflux-adapter-1.8.0-javadoc.jar; 赠送源代码:sentinel-spring-webflux-adapter-1.8.0-sources.jar; 赠送Maven依赖...
赠送jar包:sentinel-spring-webmvc-adapter-1.8.0.jar; 赠送原API文档:sentinel-spring-webmvc-adapter-1.8.0-javadoc.jar; 赠送源代码:sentinel-spring-webmvc-adapter-1.8.0-sources.jar; 赠送Maven依赖信息...
赠送jar包:sentinel-spring-cloud-gateway-adapter-1.8.0.jar; 赠送原API文档:sentinel-spring-cloud-gateway-adapter-1.8.0-javadoc.jar; 赠送源代码:sentinel-spring-cloud-gateway-adapter-1.8.0-sources....
赠送jar包:sentinel-spring-webmvc-adapter-1.8.0.jar; 赠送原API文档:sentinel-spring-webmvc-adapter-1.8.0-javadoc.jar; 赠送源代码:sentinel-spring-webmvc-adapter-1.8.0-sources.jar; 赠送Maven依赖信息...
Spring Integration。 官网 Spring Integration API。 Spring Integration 开发文档。
spring-integration 官方文档pdf高清版本 可以在官网下载,免除大家查找麻烦
spring-integration.zip,spring集成流支持spring集成提供了spring编程模型的扩展,以支持著名的企业集成模式(eip)
activityexample
Collection.zip,集合实现的使用示例。Java集合工具(映射、迭代器等)。
spring-integration-4.2的在线晚点翻译,google翻译 不一定全部准确 有不准确的地方希望大家改正分享!已经是最低分了 源文档:https://docs.spring.io/spring-integration/docs/4.2.0.RELEASE/reference/htmlsingle/
spring-integration-http-demo Spring整合http示范
docker exec -i spring-integration-kotlin-dsl bash -c ' echo "ololo trololo" > /tmp/target/inputs/first-file.txt ' docker exec -i spring-integration-kotlin-dsl bash -c ' echo "trololo|ololo" > /tmp/...
struts-spring-hibernate-_-integration-2.zip
赠送jar包:spring-context-support-1.0.10.jar; 赠送原API文档:spring-context-support-1.0.10-javadoc.jar; 赠送源代码:spring-context-support-1.0.10-sources.jar; 赠送Maven依赖信息文件:spring-context-...
赠送jar包:spring-security-crypto-5.5.2.jar; 赠送原API文档:spring-security-crypto-5.5.2-javadoc.jar; 赠送源代码:spring-security-crypto-5.5.2-sources.jar; 赠送Maven依赖信息文件:spring-security-...
赠送jar包:spring-security-core-5.3.9.RELEASE.jar; 赠送原API文档:spring-security-core-5.3.9.RELEASE-javadoc.jar; 赠送源代码:spring-security-core-5.3.9.RELEASE-sources.jar; 赠送Maven依赖信息文件:...