所以我拿了头然后开始处理。问题如果要对其进行缩放，并在系统突然关闭时使用每个pod/示例8个线程的executor服务，“消息”将被视为已被接收/使用。我猜有一种策略是使用一个单独的分布式redisson list/map-per-queue/dequeue来表示这些元素/消息正在被处理。我想那会管用的，但是跟踪这个列表也不容易。有没有一种方法可以先使用live对象，然后将队列中的一个元素标记为被管理，然后在完成o（1）后以某种方式将其删除？
hfsqlsce1#
所以我拿了头然后开始处理。问题如果要对其进行缩放，并在系统突然关闭时使用每个pod/示例8个线程的executor服务，“消息”将被视为已被接收/使用。您需要使用rstream对象，它允许跟踪每个使用者的未使用元素。
1条答案
按热度按时间hfsqlsce1#
所以我拿了头然后开始处理。问题如果要对其进行缩放，并在系统突然关闭时使用每个pod/示例8个线程的executor服务，“消息”将被视为已被接收/使用。
您需要使用rstream对象，它允许跟踪每个使用者的未使用元素。