Redis

一、高可用部署

redis-stack-sentinel

SENTINEL get-master-addr-by-name mymaster
SENTINEL masters
SENTINEL replicas mymaster
SENTINEL FAILOVER mymaster
SENTINEL slaves mymaster
INFO SENTINEL
ACL LIST

普通认证 √

# redis
requirepass qwe
masterauth qwe

# sentinel
sentinel auth-user mymaster default
sentinel auth-pass mymaster qwe

acl 认证 × 未验证通过

# redis
user sentinel on >{{ .Values.auth.password }} +client +subscribe +publish +ping +info +multi +slaveof +config +exec

# sentinel
sentinel auth-user mymaster sentinel
sentinel auth-pass mymaster qwe

二、基础使用

连接

redis-cli -h 127.0.0.1 -p 6379 --user redis -a infini_rag_flow_helm ping

REDISCLI_AUTH=qwe redis-cli --user default -p 6379 ping

redis-cli
127.0.0.1:6379> auth infini_rag_flow_helm
OK

键值操作

SET key "hello"   # 设置 key
GET key           # 获取 key
DEL key           # 删除 key
EXPIRE key 10     # 设置 key 10 秒后过期

主要类型

string → 代表是普通字符串（可用 GET 获取）。

list → 代表是列表（可用 LRANGE 获取）。

set → 代表是集合（可用 SMEMBERS 获取）。

hash → 代表是哈希表（可用 HGETALL 获取）。

zset → 代表是有序集合（可用 ZRANGE 获取）。

ZRANGE task_consumer_0 0 -1  # zset
LRANGE task_consumer_0 0 -1  # list
SMEMBERS task_consumer_0     # set
HGETALL task_consumer_0      # hash
XREVRANGE rag_flow_svr_queue + - COUNT 5 # stream  最新 5 条消息
XREAD COUNT 10 STREAMS rag_flow_svr_queue 0
XREAD BLOCK 0 STREAMS rag_flow_svr_queue $ # 持续监听新消息

三、常用命令

1.基础命令

2.字符串(String)

3.哈希(Hash)

4.列表(List)

5.集合(Set)

6.有序集合(Sorted Set)

7.发布订阅(Pub/Sub)

8.服务器相关

9.RedisJSON

基础操作

修改操作

$ 表示根节点

# 设置一个 JSON 对象
JSON.SET user:1 $ '{"name": "Alice", "age": 30, "tags": ["dev", "redis"]}'

# 获取整个对象
JSON.GET user:1

# 获取某个字段
JSON.GET user:1 $.name

# 数组追加
JSON.ARRAPPEND user:1 $.tags '"admin"'

# 删除某字段
JSON.DEL user:1 $.age

四、其他

# 直接搜索 checkpoints 索引中 @thread_id 为 1943868169984831490 的文档，返回全部字段和匹配结果。
FT.SEARCH checkpoints "@thread_id:{1943868169984831490}"
# 执行搜索但不返回任何文档，只返回匹配的文档数量
FT.SEARCH checkpoints "@thread_id:{1943840008152707073}" LIMIT 0 0
# 搜索并仅返回 1 个匹配的文档（只返回 document id，不返回字段内容）
FT.SEARCH checkpoints "@thread_id:{1943840008152707073}" LIMIT 0 1 RETURN 0

import redis

# 连接 Redis
r = redis.Redis(host='localhost', port=6379, decode_responses=True)

# 执行 FT.SEARCH 查询（thread_id 是 TAG 类型，需要加 {}）
query = '@thread_id:{1943868169984831490}'
result = r.execute_command('FT.SEARCH', 'checkpoints', query)

# 模糊查询 json key 所占用内存和每个key 占用内存
redis-cli --scan --pattern "checkpoint:*" | while read key; do
  redis-cli MEMORY USAGE "$key"
done | awk '
  {sum += $1; count += 1}
  END {
    printf "Total Keys: %d\n", count;
    printf "Total Memory: %.2f MB\n", sum / 1024 / 1024;
    printf "Average per Key: %.2f KB\n", sum / count / 1024;
  }'

五、优化

redis配置

# Redis 监听端口
port 6379

dir /tmp

# 监听所有网卡（用于 Kubernetes 或外部访问）
bind 0.0.0.0

# 启用 AOF 持久化机制（适合数据安全性要求高的业务）
appendonly yes

appendfsync no
no-appendfsync-on-rewrite yes

# 设置最大客户端连接数，防止连接耗尽资源
maxclients 10000

# 启用 TCP keepalive，单位为秒（建议开启以发现死连接）
tcp-keepalive 60

tcp-backlog 10240

timeout 300

hz 100

# 禁用 protected mode，适用于内网或 Kubernetes 环境
protected-mode no

# 限制 Redis 最大内存，防止系统 OOM（单位可为 kb, mb, gb）
maxmemory 8gb

# 内存淘汰策略：从所有键中优先淘汰最少使用的键（LRU）
maxmemory-policy allkeys-lru

# 启用主动碎片整理（默认关闭，建议开启以优化长期运行性能）
activedefrag yes

# Redis 7.x 的碎片整理参数（默认值即可，如需调优可参考以下）
# 当碎片率超过该值时触发整理
active-defrag-threshold-lower 10
# 达到更高碎片率后提升整理频率
active-defrag-threshold-upper 100
# 最小整理周期占 CPU 百分比
active-defrag-cycle-min 25
# 最大整理周期占 CPU 百分比
active-defrag-cycle-max 75

repl-backlog-size 128mb
client-output-buffer-limit normal 0 0 0
client-output-buffer-limit pubsub 32mb 8mb 60

# 设置密码（强烈建议设置强密码以保障安全）
requirepass yourStrongPasswordHere

# 设置数据库数量（默认 16；如业务只需一个，可设为 1 降低开销）
databases 1

# =========================
# 🧑 ACL 用户权限配置
# =========================

# 默认用户：允许所有命令和键
user default on >strongDefaultPass allcommands allkeys

# 只读用户（readonly）：只能读不能写
user readonly on >readonlyPass +@read -@write ~*

# 只写用户（writer）：只能写不能读
user writer on >writerPass +@write -@read ~*


# 主节点设置访问密码
requirepass yourStrongPasswordHere

# 从节点设置 masterauth，用于向主节点认证
masterauth yourStrongPasswordHere

# 从节点向主节点请求完整的 RDB 快照（全量同步）；
# 然后持续执行命令传播（增量同步）以保持数据一致性。
replicaof redis-0.redis-headless 6379

ACL SETUSER default on >yourStrongPassword allcommands allkeys

sentinel配置

port 26379
dir /tmp

# Sentinel 监控主节点（mymaster 是主集群名称）
sentinel monitor mymaster redis-0.redis-headless 6379 2

# 设置主节点密码（和 Redis 的 requirepass 保持一致）
# 设置用于连接主/从 Redis 的密码
sentinel auth-pass mymaster {{ .Values.redis.password }}

# 判断主节点“故障”需要 5 秒没有回应
sentinel down-after-milliseconds mymaster 6000

# 故障转移最多等待 10 秒
sentinel failover-timeout mymaster 10000

# 故障转移时最多同时对几个从节点同步新主节点数据
sentinel parallel-syncs mymaster 1

# 防止错误选主（主从未完全同步前不选）
sentinel deny-scripts-reconfig yes

# 控制 Redis 实例在 无密码保护时是否限制访问。
protected-mode no

# 启用后，Redis Sentinel 将动态解析主节点或从节点的主机名（DNS 名称），而不是只解析一次并缓存 IP 地址。
sentinel resolve-hostnames yes

六、测试

1.功能测试

redis-cli ping               # 应该返回 PONG
redis-cli set test_key 123   # 设置一个 key
redis-cli get test_key       # 应该返回 123

redis-cli --raw JSON.SET doc $ '{"name":"Alice","age":30}'
redis-cli --raw JSON.GET doc
redis-cli --raw JSON.DEL doc

或使用 redisinsight 工具图形化查看 JSON 结构。

2.性能测试

# 默认测试100000次请求，50并发，GET/SET
redis-benchmark -h <host> -p <port> -c 50 -n 100000

# 示例：测试 JSON 设置
redis-benchmark -t set,get -n 10000 -d 256

3.高可用测试

# 人为停掉 master 容器/进程
docker stop redis-master

# Sentinel 日志应该有主从切换
kubectl logs redis-sentinel-0

# 验证新的 master 是否生效
redis-cli -p 26379 sentinel get-master-addr-by-name mymaster

redis-cli -p 26379 sentinel masters

4.内存/稳定性/模块压力测试

memtier_benchmark：支持更复杂的数据模型、JSON 结构、TLS 等

redis-py 脚本测试：你可用 Python 写脚本循环写入、删除、并发测试

七、编码

import redis

r = redis.Redis(host='localhost', port=6379, decode_responses=True)

r.set("username", "Alice", ex=10)  # 10 秒后过期
print(r.get("username"))  # Alice

redis事务

MULTI
SET key "value"
INCR counter
EXEC

MULTI         # 开启事务
SET key1 "A"  # 设置 key1=A
SET key2 "B"  # 设置 key2=B
INCR counter  # 递增 counter
EXEC          # 执行事务

redis发布/订阅(Pub/Sub)

PUBLISH mychannel "Hello, World!"
SUBSCRIBE mychannel

redis分布式锁

SET mylock "locked" EX 10 NX  # 10 秒自动过期

lock = r.set("mylock", "1", ex=10, nx=True)
if lock:
    print("获取锁成功")
else:
    print("锁已被占用")

哨兵连接

redis:
  enable: true
  host: 127.0.0.1
  sentinel:
    - redis-sentinel-0.redis-sentinel-headless.default.svc.cluster.local
    - redis-sentinel-1.redis-sentinel-headless.default.svc.cluster.local
    - redis-sentinel-2.redis-sentinel-headless.default.svc.cluster.local
  port: 26379
  db: 0
  masterSet: mymaster
  max_connections: 1000
  default_ttl: 60
  socket_timeout: 3
  socket_keepalive: true
  health_check_interval: 30
  refresh_on_read: true
  retry_on_timeout: true


sentinels = [
    (host, port) for host in sentinel
]
sentinel_client = Sentinel(
    sentinels,
    socket_timeout=socket_timeout,
    retry_on_timeout=retry_on_timeout,
    health_check_interval=health_check_interval
)
redis_client = sentinel_client.master_for(master)
response = await redis_client.ping()