当前位置：首页 > news >正文

Spring Boot 与 Spring Integration 整合教程

news 来源：原创 2025/6/26 7:25:10

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

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

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 {

    @Bean
    public 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 {

    @Bean
    public 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 {

    @Autowired
    private MockMvc mockMvc;

    @Test
    public void testHttpIntegration() throws Exception {
        mockMvc.perform(post("/receive")
                .contentType(MediaType.TEXT_PLAIN)
                .content("Test Message"))
            .andExpect(status().isOk());
    }
}