vert.x redis 客户端对 stream 订阅应避免使用连接池，而推荐为每个订阅独占一个长生命周期连接；若必须复用池化连接，则需显式扩大 `maxpoolsize` 与 `maxwaitinghandlers` 配置，但性能无增益且易引发资源争抢。

在 Vert.x 应用中集成 Redis Stream（如 XREADGROUP 或 XSUBSCRIBE）时，一个常见误区是将“通用命令连接池”直接用于长期阻塞型订阅操作。Redis 的流订阅本质是单连接、长生命周期、服务端推送驱动的行为——一旦调用 XREAD BLOCK 或 XGROUP READGROUP，该连接即进入等待状态，无法再处理其他请求。若将其纳入共享连接池（默认 maxPoolSize = CPU 核心数），不仅会迅速耗尽连接，还会导致后续普通命令（如 GET、INCR）因无空闲连接而排队甚至超时。

✅ 推荐方案：为订阅使用独立、非池化连接
这是 Vert.x Redis 客户端官方隐含的最佳实践（虽未在文档显式强调）。每个 Stream 订阅应独占一个 RedisConnection 实例，由 Redis.createClient(...).connect() 直接创建，不经过连接池：

Redis.createClient(vertx, "redis://localhost:6379")
  .connect()
  .onSuccess(conn -> {
    // ✅ 此连接专用于流订阅，可安全执行 XREADGROUP BLOCK
    conn.send(Request.cmd(Command.XREADGROUP)
        .arg("mygroup").arg("consumer1")
        .arg("STREAMS").arg("mystream").arg(">")
        .arg("COUNT").arg("1")
        .arg("BLOCK").arg("5000"))
      .onSuccess(reply -> {
        // 处理消息...
        // 注意：需循环调用以持续监听（或结合 vertx-eventbus 封装）
      });
  })
  .onFailure(err -> log.error("Failed to connect for stream subscription", err));

⚠️ 不推荐方案：强行扩池支持高并发订阅
虽然可通过 RedisOptions 提升连接池容量（如设 setMaxPoolSize(1000)），但这违背设计初衷：

• Redis 连接是昂贵资源（内存、文件描述符、TCP 状态）；
• Vert.x Redis 客户端内部对 Pub/Sub 和 Stream 订阅不支持连接复用——每个 XREADGROUP 必须独占连接；
• 池中连接被订阅长期占用后，普通命令被迫排队（maxWaitingHandlers 仅缓解，不根治）；
• 10k 连接既超出 Redis 默认 maxclients（通常 10k，但实际受 OS 限制），也极易触发 OOM 或 TIME_WAIT 泛滥。

? 进阶建议：分层连接管理
Vert.x 本身不提供“按用途划分连接池”的原生能力，但可通过多客户端实例 + 显式配置隔离实现逻辑分离：

// 专用订阅客户端（大连接数 + 低超时）
RedisClient subscriberClient = RedisClient.create(
  vertx,
  new RedisOptions()
    .setConnectionString("redis://localhost:6379")
    .setMaxPoolSize(256)           // 仅用于订阅，容忍高连接数
    .setConnectTimeout(30_000)
);

// 通用命令客户端（小连接数 + 高复用率）
RedisClient commandClient = RedisClient.create(
  vertx,
  new RedisOptions()
    .setConnectionString("redis://localhost:6379")
    .setMaxPoolSize(Runtime.getRuntime().availableProcessors()) // 默认推荐值
    .setIdleTimeout(60)            // 主动回收空闲连接
);

? 关键总结

• 不要将 Stream 订阅塞入默认连接池；
• 应当为每个稳定订阅任务创建独立 RedisConnection（connect() 而非 getConnection()）；
• 若需动态扩缩订阅规模（如按租户分组），建议封装 RedisConnection 生命周期管理（自动重连、错误恢复）；
• 监控 Redis 的 client list 和 info clients，确认无大量 idle 连接堆积或 omem 异常增长；
• 对于超大规模场景（>1k 并发订阅），应评估是否改用 Redis Cluster 的分片订阅，或引入 Kafka 等专业流平台解耦。