redis 通过单线程架构下的原子性操作保证并发安全性，涉及多 key 或读写操作时可使用事务或 lua 脚本确保原子性。1. pipeline 批量操作减少网络往返提升吞吐量；2. lua 脚本在服务端执行复杂逻辑，保障操作原子性；3. 数据分片将数据分散存储至多个实例提升性能；4. redis 集群提供自动分片与故障转移增强可用性；5. 合理选择数据结构如集合、有序集合优化不同场景性能。可通过监控 qps、延迟、连接数、内存等指标了解运行状态并及时优化。
Redis 处理并发，关键在于其单线程架构下的高效数据操作。 它主要依赖于高效的内存操作、多路复用 I/O 模型以及一系列优化策略来应对高并发场景。
Redis 在高并发场景下表现出色，但并非万能。要充分发挥其性能，需要结合具体应用场景进行优化。
Redis 如何保证并发安全性？
Redis 虽然是单线程，但其命令执行是原子性的，这意味着在执行一个命令时，不会被其他命令中断。这保证了在并发场景下，对共享数据的操作是安全的。然而，复杂的操作，例如涉及多个 key 的操作，或者需要先读取再写入的操作，就需要使用 Redis 的事务或者 Lua 脚本来保证原子性。 简单来说，Redis 的并发安全性依赖于其原子性操作和额外的并发控制机制。
举个例子，假设我们需要对一个用户的积分进行增加操作。如果简单地使用
GET获取当前积分，然后
INCRBY增加积分，在高并发下可能会出现问题。因为在
GET和
INCRBY之间，可能有其他客户端也进行了相同的操作。这时，就可以使用 Redis 的事务或者 Lua 脚本来保证这个操作的原子性。
Redis 高并发处理的 5 个最佳实践
-
Pipeline 批量操作： 减少网络往返时间是提升性能的关键。Pipeline 允许客户端一次性发送多个命令，服务器执行完后一次性返回结果。这大大减少了客户端与服务器之间的交互次数，提升了吞吐量。 想象一下，你要给 100 个用户发送邮件，如果一封一封发，那效率肯定很低。但如果把 100 封邮件打包一起发，效率就会高很多。Pipeline 就是类似的作用。
import redis r = redis.Redis(host='localhost', port=6379, db=0) pipe = r.pipeline() for i in range(100): pipe.set(f'key:{i}', i) pipe.execute() # 一次性发送 100 个 set 命令 -
使用 Lua 脚本： 将复杂的逻辑放在 Redis 服务器端执行，可以减少网络传输，并且保证操作的原子性。Lua 脚本可以用来实现复杂的业务逻辑，例如秒杀、限流等。 Redis 内嵌 Lua 解释器，可以直接执行 Lua 脚本。
-- 脚本：原子性地增加积分 local key = KEYS[1] local increment = tonumber(ARGV[1]) local current = redis.call("GET", key) if not current then current = 0 end current = tonumber(current) + increment redis.call("SET", key, current) return current在 Python 中调用：
import redis r = redis.Redis(host='localhost', port=6379, db=0) script = """ local key = KEYS[1] local increment = tonumber(ARGV[1]) local current = redis.call("GET", key) if not current then current = 0 end current = tonumber(current) + increment redis.call("SET", key, current) return current """ incr_script = r.register_script(script) result = incr_script(keys=['user:123:points'], args=[10]) # 原子性地增加 10 积分 print(result) -
数据分片 (Sharding)： 当单个 Redis 实例无法承受高并发时，可以将数据分散存储到多个 Redis 实例上。常见的分片策略包括哈希取模、一致性哈希等。 数据分片可以显著提升系统的吞吐量和可用性。
假设你有 1000 万个用户，一个 Redis 实例放不下，你可以将用户 ID 对 10 取模，然后将数据存储到 10 个 Redis 实例上。
-
使用 Redis 集群 (Cluster)： Redis 集群是 Redis 官方提供的分布式解决方案，它自动将数据分片存储到多个节点上，并且具有自动故障转移功能。Redis 集群可以提供更高的可用性和扩展性。
Redis 集群使用 Gossip 协议进行节点间的通信，可以自动发现新节点、检测故障节点。
合理选择数据结构： Redis 提供了多种数据结构，例如字符串、列表、哈希、集合、有序集合等。不同的数据结构适用于不同的场景。选择合适的数据结构可以显著提升性能。 例如，如果需要存储用户的好友列表，使用集合 (Set) 是一个不错的选择，因为集合可以高效地进行添加、删除、查找操作。 如果需要存储用户的文章列表，并且需要按照发布时间排序，使用有序集合 (Sorted Set) 是一个不错的选择。
如何监控 Redis 的并发性能？
监控 Redis 的并发性能至关重要，可以帮助我们及时发现瓶颈并进行优化。 常见的监控指标包括：
- QPS (Queries Per Second)： 每秒查询次数，反映了 Redis 的吞吐量。
- 延迟 (Latency)： 命令执行的平均时间，反映了 Redis 的响应速度。
- 连接数 (Connected Clients)： 当前连接到 Redis 服务器的客户端数量。
- 内存使用 (Memory Usage)： Redis 实例使用的内存大小。
可以使用
redis-cli info命令获取 Redis 的状态信息，也可以使用专业的监控工具，例如 Prometheus + Grafana，对 Redis 进行更全面的监控。 监控的目的是为了了解 Redis 的运行状态，及时发现问题，并采取相应的措施。 例如，如果发现 QPS 很高，但延迟也很高，可能需要考虑增加 Redis 实例的数量，或者优化数据结构。
总而言之，Redis 处理并发的能力很强，但需要结合实际场景进行优化。 掌握这些最佳实践，可以帮助我们更好地利用 Redis，构建高性能、高可用的应用。
