Spring 集成

Spring Boot 为使用 Spring Integration 提供了多种便利,包括spring-boot-starter-integration起动机。 Spring Integration 提供了对消息传递和其他传输(如 HTTP、TCP 等)的抽象。 如果 Spring Integration 在您的类路径上可用,则通过@EnableIntegration注解。spring-doc.cadn.net.cn

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

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

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

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

Spring Boot 还可以自动配置ClientRSocketConnector使用配置属性:spring-doc.cadn.net.cn

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