/** * 消息队列,基于 Redis 提供: * 1. 基于 Pub/Sub 实现广播消费 * 2. 基于 Stream 实现集群消费 */ package com.iailab.framework.mq.redis;