10.6. Spring Integration

Spring Boot 为使用Spring Integration提供了多种便利,包括spring-boot-starter-integration“Starter”。Spring Integration 提供了对消息传递以及其他传输(例如 HTTP、TCP 等)的抽象。如果 Spring Integration 在您的类路径上可用,它将通过@EnableIntegration注释进行初始化。

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

Spring Boot 还配置了一些由其他 Spring Integration 模块的存在触发的功能。如果spring-integration-jmx也在类路径上,则消息处理统计信息将通过 JMX 发布。如果spring-integration-jdbc可用,则可以在启动时创建默认数据库架构,如下行所示:

spring.integration.jdbc.initialize-schema=always

如果spring-integration-rsocket可用,开发人员可以使用"spring.rsocket.server.*"属性配置 RSocket 服务器,并让它使用IntegrationRSocketEndpointRSocketOutboundGateway组件来处理传入的 RSocket 消息。该基础设施可以处理 Spring Integration RSocket 通道适配器和@MessageMapping处理程序(已给定"spring.integration.rsocket.server.message-mapping-enabled"配置)。

Spring Boot 还可以使用配置属性自动配置ClientRSocketConnector

# Connecting to a RSocket server over TCP
spring.integration.rsocket.client.host=example.org
spring.integration.rsocket.client.port=9898
# Connecting to a RSocket Server over WebSocket
spring.integration.rsocket.client.uri=ws://example.org

有关更多详细信息,请参阅IntegrationAutoConfigurationIntegrationProperties类。

最后更新于