Spring Boot 与 Spring Integration 整合教程

精心整理了最新的面试资料和简历模板，有需要的可以自行获取

点击前往百度网盘获取
点击前往夸克网盘获取

Spring Boot 与 Spring Integration 整合教程

简介

Spring Integration 是 Spring 生态系统中用于实现企业集成模式（Enterprise Integration Patterns, EIP）的框架，支持消息驱动、通道、路由、过滤等特性。结合 Spring Boot 的自动配置能力，可以快速构建轻量级集成应用。

环境准备

JDK 17+
Maven 3.8+ 或 Gradle
IDE（推荐 IntelliJ IDEA 或 VS Code）

步骤 1：创建 Spring Boot 项目

通过 Spring Initializr 创建项目，添加以下依赖：

Spring Web（可选，用于 HTTP 集成）
Spring Integration
Spring Integration File（文件处理示例）
Lombok（简化代码）

生成 pom.xml 关键依赖：

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-integration</artifactId>
</dependency>
<dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-file</artifactId>
</dependency>

步骤 2：配置 Spring Integration

2.1 启用 Integration 配置

在启动类添加 @EnableIntegration 注解：

@SpringBootApplication
@EnableIntegration
public class IntegrationApplication {public static void main(String[] args) {SpringApplication.run(IntegrationApplication.class, args);}
}

2.2 配置文件通道（可选）

在 application.properties 中配置默认通道：

# 设置轮询器线程池大小
spring.task.execution.pool.core-size=5

步骤 3：实现文件处理示例

3.1 创建文件输入通道

@Configuration
public class FileIntegrationConfig {@Beanpublic MessageChannel fileInputChannel() {return new DirectChannel();}@Bean@InboundChannelAdapter(value = "fileInputChannel", poller = @Poller(fixedDelay = "1000"))public MessageSource<File> fileReadingMessageSource() {FileReadingMessageSource source = new FileReadingMessageSource();source.setDirectory(new File("input"));source.setFilter(new SimplePatternFileListFilter("*.txt"));return source;}@Bean@ServiceActivator(inputChannel = "fileInputChannel")public MessageHandler fileProcessingHandler() {return message -> {File file = (File) message.getPayload();System.out.println("Processing file: " + file.getName());// 实现文件处理逻辑};}
}

步骤 4：HTTP 请求处理示例

4.1 添加 HTTP 支持

@Configuration
@EnableIntegration
public class HttpIntegrationConfig {@Beanpublic HttpRequestHandlerEndpointSpec httpInboundGateway() {return IntegrationFlows.from(Http.inboundChannelAdapter("/receive").requestMapping(m -> m.methods(HttpMethod.POST))).handle(message -> {String payload = (String) message.getPayload();System.out.println("Received: " + payload);}).get();}
}

步骤 5：消息路由示例

@Bean
public IntegrationFlow routingFlow() {return IntegrationFlows.from("inputChannel").<String, Boolean>route(payload -> payload.contains("urgent"),mapping -> mapping.subFlowMapping(true, sf -> sf.channel("highPriorityChannel")).subFlowMapping(false, sf -> sf.channel("normalChannel"))).get();
}@Bean
public MessageChannel highPriorityChannel() {return MessageChannels.direct().get();
}@Bean
public MessageChannel normalChannel() {return MessageChannels.direct().get();
}

步骤 6：测试应用

6.1 编写测试类

@SpringBootTest
@AutoConfigureMockMvc
public class IntegrationTest {@Autowiredprivate MockMvc mockMvc;@Testpublic void testHttpIntegration() throws Exception {mockMvc.perform(post("/receive").contentType(MediaType.TEXT_PLAIN).content("Test Message")).andExpect(status().isOk());}
}