/** * 消æ¯é˜Ÿåˆ—,基于 Redis æä¾›ï¼š * 1. 基于 Pub/Sub å®žçŽ°å¹¿æ’æ¶ˆè´¹ * 2. 基于 Stream 实现集群消费 */ package com.iailab.framework.mq.redis;