Spring 集成
Spring Boot 为使用 Spring 集成提供了多种便利,包括spring-boot-starter-integration起动机。
Spring 集成通过消息传递以及其他传输(如 HTTP、TCP 等)提供抽象。
如果 Spring 集成在您的类路径上可用,则通过@EnableIntegration注解。
Spring 集成轮询逻辑依赖于自动配置的 TaskScheduler.
默认的PollerMetadata(轮询每秒无限数量的消息)可以使用spring.integration.poller.*configuration 属性。
Spring Boot 还配置了一些由其他 Spring 集成模块的存在触发的功能。
如果spring-integration-jmx也在 Classpath 上,则消息处理统计信息将通过 JMX 发布。
如果spring-integration-jdbc可用,则可以在启动时创建默认数据库架构,如以下行所示:
-
Properties
-
YAML
spring.integration.jdbc.initialize-schema=always
spring:
integration:
jdbc:
initialize-schema: "always"
如果spring-integration-rsocket可用,开发人员可以使用spring.rsocket.server.*属性,并让它使用IntegrationRSocketEndpoint或RSocketOutboundGateway组件来处理传入的 RSocket 消息。
此基础结构可以处理 Spring 集成 RSocket 通道适配器和@MessageMappinghandlers(给定spring.integration.rsocket.server.message-mapping-enabled已配置)。
Spring Boot 还可以自动配置ClientRSocketConnector使用配置属性:
-
Properties
-
YAML
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
-
Properties
-
YAML
spring.integration.rsocket.client.uri=ws://example.org
# Connecting to a RSocket Server over WebSocket
spring:
integration:
rsocket:
client:
uri: "ws://example.org"