3. Redis 核心概念回顾：数据结构、单线程模型与连接池原理

在深入 Kafka 堆积导致 Redis 连接池耗尽之前，必须重新夯实 Redis 的三个核心基础：数据结构决定了业务数据的存储效率与内存开销；单线程模型决定了请求处理的上限与瓶颈位置；连接池原理则直接决定了客户端与 Redis 之间的并发通道是否会在高负载下崩溃。本节将逐一拆解，为后续的故障定位与调优提供理论支撑。

3.1 Redis 核心数据结构与适用场景

Redis 提供了多种数据结构，每种结构在内存布局、操作复杂度上差异显著。在 Kafka 堆积场景中，错误的数据结构选择会放大内存与 CPU 压力，间接导致连接池响应变慢。

3.2 单线程模型：瓶颈与误解

Redis 的核心处理逻辑是单线程的（6.0 之前完全单线程，6.0+ 网络 I/O 多线程但命令执行仍为单线程）。这意味着：所有客户端请求在 Redis 主线程中串行执行。一旦某个命令耗时过长（如 KEYS *、SMEMBERS 大集合、HGETALL 大 Hash），后续所有请求都会排队等待，连接池中的连接虽然保持 ESTABLISHED 状态，但无法获得响应，最终导致客户端连接池超时耗尽。

3.3 连接池原理：JedisPool 与 Lettuce

Java 生态中主流的 Redis 客户端连接池实现有两个：JedisPool（基于 Apache Commons Pool2）和 Lettuce（基于 Netty，支持异步与响应式）。两者在连接管理、线程模型、资源耗尽时的表现截然不同。

3.3.1 JedisPool：同步阻塞模型

• 核心机制： 基于 Commons Pool2 的 GenericObjectPool，维护一组 TCP 连接。每次 JedisPool.getResource() 从池中借用一个连接，使用完毕后调用 close() 归还。
• 关键参数： maxTotal（最大连接数）、maxIdle（最大空闲连接）、minIdle（最小空闲连接）、maxWaitMillis（获取连接的最大等待时间）。
• 耗尽表现： 当所有连接都被借出且未归还时，新请求会在 maxWaitMillis 内阻塞等待；超时后抛出 JedisConnectionException: Could not get a resource from the pool。

// JedisPool 典型配置
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(50);          // 最大连接数
config.setMaxIdle(20);           // 最大空闲连接
config.setMinIdle(5);            // 最小空闲连接
config.setMaxWaitMillis(3000);   // 获取连接超时 3s
config.setTestOnBorrow(true);    // 借出时验证连接可用性

JedisPool jedisPool = new JedisPool(config, "localhost", 6379);

try (Jedis jedis = jedisPool.getResource()) {
    jedis.set("key", "value");
} catch (JedisConnectionException e) {
    // 连接池耗尽或 Redis 不可用
    log.error("Redis 连接池耗尽或超时", e);
}

3.3.2 Lettuce：异步与多路复用模型

• 核心机制： 基于 Netty 的 连接多路复用，一个 TCP 连接可以承载多个并发请求（类似 HTTP/2 的 multiplexing）。默认情况下，Lettuce 甚至不需要连接池，单连接即可处理高并发。
• 关键参数： ioThreadPoolSize（Netty I/O 线程数）、commandTimeout（命令超时）、maxPendingRequests（最大等待请求数）。
• 耗尽表现： 当请求堆积超过 Netty 的写缓冲区高水位时，Lettuce 会抛出 RedisException: Request queue is full 或连接被重置。

// Lettuce 典型配置（无连接池，单连接多路复用）
RedisClient redisClient = RedisClient.create("redis://localhost:6379");
StatefulRedisConnection<String, String> connection = redisClient.connect();
RedisCommands<String, String> commands = connection.sync();
commands.set("key", "value");

// 如需连接池（通常不推荐）
GenericObjectPool<StatefulRedisConnection<String, String>> pool =
    ConnectionPoolSupport.createGenericObjectPool(() -> redisClient.connect(),
        new GenericObjectPoolConfig());

3.3.3 JedisPool vs Lettuce：关键对比