java - 如何创建 LIFO 队列 channel

Question

目前，我在集成流程中使用队列 channel ，但它使用 FIFO 提取方式。有没有办法将其更改为 LIFO？

另外，有没有办法根据属性从队列中删除消息？

我怀疑我需要使用 PriorityChannel 从 FIFO 切换到 LIFO，但我不知道它是如何完成的。

@Bean
    fun notificationChannel(): MessageChannel {
        return MessageChannels.queue().get()
    }

例如，我的 QueueChannel 将填充包含 userId 的消息。由于我只对 userId 消息的最新状态感兴趣，因此我想使用 LIFO 并删除与最新消息具有相同 userId 的所有消息。

Answer 1

听起来您并不真正想要 LIFO，您只想要给定条件的最新信息。

但是，无论如何，Queue是一个非常简单的界面；它只有几种方法和 QueueChannel仅使用 poll() , offer()和 size() .

因此，创建自定义队列应该很简单，例如基于线程安全的 ConcurrentHashMap<String, Message<?>>关键是你的条件。