dyno-queue (基于2.0.22)提供V1/V2两种queue管理,无论哪种都需要注意如果连接的dynomite归属不同Shard
因此如果有多个shard,默认pop是只能取到部分数据的,如果local rack没有找到对应shard,pop会报错,即需要注意以下启动参数:
-DLOCAL_RACK=rack1-dc1 -DLOCAL_DATACENTER=dc1
V1使用的是RedisDynoQueue类,对应的push代码如下:
@Override
public List<String> push(final List