@qingdao #1楼 看了下队列消息的原始内容，这个问题搞定了。按照queue扩展的思路去消费就好，没啥问题。谢谢了

@Fecshop #3楼 上cluster肯定不只是用replicas，也需要sharding功能的，并且sharding功能是主要的。自己也找了一圈，目前打算直接用predis了