发布于 2016-10-15 01:01:35 | 142 次阅读 | 评论: 0 | 来源: 网友投递
Spring Integration Spring消息通信
Spring Integration能在基于Spring的应用中进行简单的消息通信，并通过简单的适配器与外部系统集成。这些适配器提供了一个更高级别的抽象，超越 了Spring对远程调用、消息和调度的支持。其主要目标是在保持关注点分离的同时，为构建企业集成解决方案提供一个简单的模型，该模型对产出可维护、可 测试的代码来说是必不可少的。
Java DSL for Spring Integration 1.2 正式版发布了，用于集成Spring的Java DSL。
值得关注的更新：
支持Thread Barrier
private static final String BARRIER = "barrier";
@Bean
public IntegrationFlow barrierFlow() {
return f -> f
.barrier(10000, b -> b
.correlationStrategy(
new HeaderAttributeCorrelationStrategy(BARRIER))
.outputProcessor(g ->
g.getMessages()
.stream()
.skip(1)
.findFirst()
.get()))
.channel(c -> c.queue("barrierResults"));
}
@Bean
public IntegrationFlow releaseBarrierFlow(
MessageTriggerAction barrierTriggerAction) {
return IntegrationFlows.from((Channels c) -> c.queue("releaseChannel"))
.trigger(barrierTriggerAction,
e -> e.poller(p -> p.fixedDelay(100)))
.get();
}
Poller
文件分割器的改进
下载地址：