当前位置: 首页 > 工具软件 > dyno > 使用案例 >

dyno-queue shard对push及pop的影响

云骏奇
2023-12-01

dyno-queue (基于2.0.22)提供V1/V2两种queue管理,无论哪种都需要注意如果连接的dynomite归属不同Shard

  • push 是 将批量数据发送到不同shard,即不同队列中的
  • pop 只取localrack 对应的shard中数据

PUSH/POP分析

因此如果有多个shard,默认pop是只能取到部分数据的,如果local rack没有找到对应shard,pop会报错,即需要注意以下启动参数:
-DLOCAL_RACK=rack1-dc1 -DLOCAL_DATACENTER=dc1

V1使用的是RedisDynoQueue类,对应的push代码如下:

@Override
    public List<String> push(final List
 类似资料: