Spring 集成

DeepSeek V3 中英对照 Spring Integration

Spring Boot 为使用 Spring Integration 提供了多种便利，包括 spring-boot-starter-integration starter。Spring Integration 提供了对消息传递以及其他传输方式（如 HTTP、TCP 等）的抽象。如果你的 classpath 中存在 Spring Integration，它将通过 @EnableIntegration 注解进行初始化。

Spring Integration 的轮询逻辑依赖于自动配置的 TaskScheduler。默认的 PollerMetadata（每秒轮询无限制的消息数量）可以通过 spring.integration.poller.* 配置属性进行自定义。

Spring Boot 还会根据额外的 Spring Integration 模块的存在配置一些功能。如果 spring-integration-jmx 也在类路径中，消息处理统计信息将通过 JMX 发布。如果 spring-integration-jdbc 可用，默认的数据库模式可以在启动时创建，如下所示：

Properties

spring.integration.jdbc.initialize-schema=always

properties

YAML

spring:
  integration:
    jdbc:
      initialize-schema: "always"

yaml

如果 spring-integration-rsocket 可用，开发者可以使用 spring.rsocket.server.* 属性来配置 RSocket 服务器，并让它使用 IntegrationRSocketEndpoint 或 RSocketOutboundGateway 组件来处理传入的 RSocket 消息。该基础设施可以处理 Spring Integration RSocket 通道适配器和 @MessageMapping 处理器（前提是配置了 spring.integration.rsocket.server.message-mapping-enabled）。

Spring Boot 也可以使用配置属性自动配置一个 ClientRSocketConnector：

Properties

spring.integration.rsocket.client.host=example.org
spring.integration.rsocket.client.port=9898

properties

YAML

# Connecting to a RSocket server over TCP
spring:
  integration:
    rsocket:
      client:
        host: "example.org"
        port: 9898

yaml

Properties

spring.integration.rsocket.client.uri=ws://example.org

properties

YAML

# Connecting to a RSocket Server over WebSocket
spring:
  integration:
    rsocket:
      client:
        uri: "ws://example.org"

yaml

有关更多详情，请参阅 IntegrationAutoConfiguration 和 IntegrationProperties 类。