Spring-Integration

Spring Integration 简介

1、简介 本文将通过一些实际的案例,带你了解 Spring Integration 的核心概念。 Spring Integration 提供了许多功能强大的组件,可大大增强企业架构内系统和流程的互联性。 2、设置 <dependency> <groupId>org.springframework.integration</groupId> <artifactId>spring-integration-core</artifactId> <version>5.1.13.RELEASE</version> </dependency> <dependency> <groupId>org.springframework.integration</groupId> <artifactId>spring-integration-file</artifactId> <version>5.1.13.RELEASE</version> </dependency> 你可以从 Maven Central 下载最新版本的 Spring Integration Core 和 Spring Integration File Support。 3、消息传递模式 这个库中的一个基本模式是消息传递(Messaging)。该模式围绕消息展开,消息是离散的数据负载(Discrete Payloads),通过预定义的通道从源系统或进程传递到一个或多个系统或进程。 从历史上看,这种模式是整合多个不同系统的最灵活方式,它可以: 几乎完全解耦集成所涉及的系统 允许集成中的参与系统完全不考虑彼此的底层协议、格式或其他实现细节 鼓励开发和重复使用参与集成的组件 4、消息集成的实际应用 举一个基本例子,将 MPEG 视频文件从指定文件夹复制到另一个配置文件夹: @Configuration @EnableIntegration public class BasicIntegrationConfig{ public String INPUT_DIR = "the_source_dir"; public String OUTPUT_DIR = "the_dest_dir"; public String FILE_PATTERN = "*.mpeg"; @Bean public MessageChannel fileChannel() { return new DirectChannel(); } @Bean @InboundChannelAdapter(value = "fileChannel", poller = @Poller(fixedDelay = "1000")) public MessageSource<File> fileReadingMessageSource() { FileReadingMessageSource sourceReader= new FileReadingMessageSource(); sourceReader.