精心整理了最新的面試資料和簡歷模板，有需要的可以自行獲取
點擊前往百度網盤獲取
點擊前往夸克網盤獲取
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());}
}
6.2 運行測試
在 input 目錄放置 .txt 文件，觀察控制臺輸出。
常見應用場景
- 文件監控處理：自動處理新增文件
- 消息隊列集成：連接 RabbitMQ/Kafka
- 數據庫同步：通過 JDBC 適配器同步數據
- 系統間通信：使用 HTTP/FTP/SFTP 協議交互
擴展學習
- 官方文檔：Spring Integration Reference
- 高級特性：事務支持、錯誤處理、自定義組件
- 書籍推薦：《Spring Integration in Action》
通過本教程，您可以快速實現 Spring Boot 與 Spring Integration 的整合，構建靈活的企業級集成應用。建議通過實際項目需求逐步探索更多集成模式。
)
