Spring Integration DSL：如何制作单线程缓存通道？

Question

我有以下流程配置：

@Bean
public IntegrationFlow setupDatabaseFlow() {
    return IntegrationFlows.from(pubSubDatabaseRabbitOutput)
          // WHAT CHANNEL
            .handle((p, h) -> databaseActivator.recordToDatabase(p, h))
            .get();
}

我愿意在“WHAT CHANNEL”中插入一些频道，即

• 缓存
• 单线程
• 在单独的线程中运行

在这里使用的最佳通道规范是什么？

Answer 1

不确定用例是什么，但可以通过QueueChannel 和PollingConsumer 以及fixedDelay 策略来实现。

1. QueueChannel 使用队列缓冲区（持久或内存中）来保存消息，直到它们被使用。用你的话说是 A-la 缓存。

2. PollingConsumer 使用TaskScheduler 从队列中进行轮询，因此是单独的线程。

3. 使用fixedDelay 策略可以确保下一个轮询任务在前一个完成之前不会开始。因此是单线程模型。

如果你不喜欢在轮询任务之间休眠，最终使用事件驱动模型，你可以使用fixedDelay(-1)，这样下一个轮询任务不会在前一个轮询任务之后休眠。当前轮询任务确实阻塞线程，直到队列中的值。

更新

关于此事的一些代码：

.channel(c -> c.queue())
.<Object>handle((p, h) -> databaseActivator.recordToDatabase(p, h), 
            e -> e.poller(p -> p.fixedDelay(0).maxMessagesPerPoll(1)))