|
此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 Spring Integration 6.5.1！ |
消息桥
消息传递网桥是一个相对简单的端点，它连接两个消息通道或通道适配器。
例如，您可能想要连接一个PollableChannel设置为SubscribableChannel这样订阅端点就不必担心任何轮询配置。
相反，消息传递网桥提供轮询配置。
通过在两个通道之间提供中间轮询器，您可以使用消息传递桥来限制入站消息。
轮询器的触发器确定消息到达第二个通道的速率，而轮询器的maxMessagesPerPoll属性对吞吐量强制实施限制。
消息传递桥的另一个有效用途是连接两个不同的系统。 在这种情况下，Spring Integration 的作用仅限于在这些系统之间建立连接并管理轮询器（如有必要）。 在两个系统之间至少有一个转换器，以便在它们的格式之间进行转换可能更为常见。 在这种情况下，通道可以作为转换器端点的“输入通道”和“输出通道”提供。 如果不需要数据格式转换，消息桥可能确实足够了。
使用 XML 配置网桥
您可以使用<bridge>元素用于在两个消息通道或通道适配器之间创建消息传递桥。
为此，请提供input-channel和output-channel属性，如以下示例所示：
<int:bridge input-channel="input" output-channel="output"/>如上所述，消息传递桥的一个常见用例是连接一个PollableChannel设置为SubscribableChannel.
执行此角色时，消息传递网桥还可以充当限制器：
<int:bridge input-channel="pollable" output-channel="subscribable">
<int:poller max-messages-per-poll="10" fixed-rate="5000"/>
</int:bridge>您可以使用与连接通道适配器类似的机制。
以下示例显示了stdin和stdout适配器来自 Spring Integration 的streamNamespace：
<int-stream:stdin-channel-adapter id="stdin"/>
<int-stream:stdout-channel-adapter id="stdout"/>
<int:bridge id="echo" input-channel="stdin" output-channel="stdout"/>类似的配置适用于其他（可能更有用的）通道适配器桥接器，例如文件到 JMS 或邮件到文件。 接下来的章节将介绍各种通道适配器。
| 如果在网桥上未定义“输出通道”，则使用入站消息提供的应答通道（如果可用）。 如果输出和应答通道都不可用，则会抛出异常。 |
使用 Java 配置配置网桥
以下示例显示如何使用@BridgeFrom注解：
@Bean
public PollableChannel polled() {
return new QueueChannel();
}
@Bean
@BridgeFrom(value = "polled", poller = @Poller(fixedDelay = "5000", maxMessagesPerPoll = "10"))
public SubscribableChannel direct() {
return new DirectChannel();
}以下示例显示如何使用@BridgeTo注解：
@Bean
@BridgeTo(value = "direct", poller = @Poller(fixedDelay = "5000", maxMessagesPerPoll = "10"))
public PollableChannel polled() {
return new QueueChannel();
}
@Bean
public SubscribableChannel direct() {
return new DirectChannel();
}或者，您可以使用BridgeHandler，如以下示例所示：
@Bean
@ServiceActivator(inputChannel = "polled",
poller = @Poller(fixedRate = "5000", maxMessagesPerPoll = "10"))
public BridgeHandler bridge() {
BridgeHandler bridge = new BridgeHandler();
bridge.setOutputChannelName("direct");
return bridge;
}使用 Java DSL 配置网桥
您可以使用 Java 域特定语言 （DSL） 来配置网桥，如以下示例所示：
@Bean
public IntegrationFlow bridgeFlow() {
return IntegrationFlow.from("polled")
.bridge(e -> e.poller(Pollers.fixedDelay(5000).maxMessagesPerPoll(10)))
.channel("direct")
.get();
}