怎样在OpenResty中使用 redis2模块与Redis进行交互？

1. 当OpenResty遇见Redis的化学反应

在这个万物互联的时代，咱们做后端开发的经常要面对高并发的挑战。OpenResty作为基于Nginx的强力选手，配合Redis这种内存数据库简直是黄金搭档。但就像泡面需要热水，咱们需要一座稳固的"桥梁"来连接它们——这就是redis2模块。

你可能想问："为什么不用更常见的lua-resty-redis？"问得好！redis2模块最大的特点是直接支持Redis协议，能像原生命令行一样操作。想象一下在Lua代码里直接拼接Redis命令字符串，就像当面跟Redis对话一样亲切。

2. 环境搭建：给你的OpenResty装上"红宝石"

2.1 基础环境准备

确保你的服务器上有以下装备：

• OpenResty 1.19+（推荐使用官方最新稳定版）
• Redis 5.0+（建议开启持久化）
• 开发工具包（gcc、make等）

# 安装OpenResty
wget https://openresty.org/package/centos/openresty.repo
sudo mv openresty.repo /etc/yum.repos.d/
sudo yum install -y openresty

# 安装Redis
sudo yum install -y redis

2.2 启用redis2模块

OpenResty默认就带着这个宝贝，咱们只需要在nginx.conf里召唤它：

http {
    # 加载redis2模块
    lua_package_path "/usr/local/openresty/lualib/?.lua;;";
    
    server {
        listen 80;
        location /redis {
            content_by_lua_block {
                -- 咱们的Lua代码将在这里施展魔法
            }
        }
    }
}

3. 实战演练：从零开始玩转redis2

3.1 基础操作四重奏

场景1：简单SET/GET操作

local redis = require "resty.redis2"
local red = redis:new()

-- 连接配置（生产环境建议用连接池）
local ok, err = red:connect("127.0.0.1", 6379)
if not ok then
    ngx.say("连接失败: ", err)
    return
end

-- 执行Redis命令（注意命令全大写）
local res, err = red:query("SET my_key 'Hello_OpenResty'")
if not res then
    ngx.say("SET操作失败: ", err)
    return
end

-- 获取数据
local value, err = red:query("GET my_key")
ngx.say("获取到的值是: ", value) --> 输出 Hello_OpenResty

-- 记得关闭连接（实际生产建议用连接池复用）
red:close()

场景2：处理哈希表

-- 创建用户信息哈希
red:query("HSET user:1001 name '张三' age 28 profession '工程师'")

-- 获取指定字段
local name = red:query("HGET user:1001 name") --> 返回 "张三"

-- 获取全部字段
local user_data = red:query("HGETALL user:1001")
-- 返回结果是Lua数组形式：{"name", "张三", "age", "28"...}

3.2 高级技巧：让性能飞起来

技巧1：管道操作（Pipeline）

-- 开启管道模式
red:init_pipeline()

-- 打包多个命令
red:query("INCR page_view")
red:query("EXPIRE page_view 60")
red:query("LPUSH recent_visits "..ngx.time())

-- 批量执行
local results, err = red:commit_pipeline()
if not results then
    ngx.say("管道操作失败: ", err)
    return
end

-- results是包含所有结果的数组
ngx.say("当前浏览量: ", results[1]) --> 输出递增后的数值

技巧2：连接池管理

# nginx.conf配置连接池
lua_shared_dict redis_pool 10m;

local function get_redis()
    local red = redis:new()
    red:set_timeout(1000) -- 1秒超时
    
    -- 从连接池获取连接
    local ok, err = red:connect("127.0.0.1", 6379, {
        pool = "my_redis_pool",
        pool_size = 100  -- 最大连接数
    })
    
    if not ok then
        return nil, err
    end
    return red
end

-- 使用后自动归还到连接池
local red = get_redis()
-- ...执行操作...
red:set_keepalive(10000, 100) -- 10秒空闲时间，最大100连接

4. 深入原理：为什么选择redis2？

4.1 性能对比测试

我们在4核8G云服务器上做压力测试（ab -n 10000 -c 100）：

虽然优势不算巨大，但在超高并发场景下，redis2的协议级优化优势会更明显。

4.2 适用场景分析

推荐使用场景：

• 需要原生Redis命令支持
• 已存在大量Redis命令行脚本需要移植
• 要求极致性能的批量操作
• 需要与旧系统保持协议兼容

可能需要三思的场景：

• 需要高级数据结构支持
• 对连接管理要求极高
• 需要SSL/TLS加密连接
• 需要Redis集群支持

5. 避坑指南：前人踩过的雷

5.1 常见错误代码示例

-- 危险！未处理的空值
local user = red:query("HGETALL non_exist_key")
for i=1, #user, 2 do  -- 当user为nil时会报错
    ngx.say(user[i], ": ", user[i+1])
end

-- 正确姿势
if type(user) == "table" then
    -- 处理数据
else
    -- 处理空值情况
end

5.2 事务处理的正确打开方式

-- 错误的事务使用
red:query("MULTI")
red:query("SET a 1")
red:query("INCR b")
red:query("EXEC") -- 这里返回的是QUEUED状态的数组

-- 正确的事务流程
red:init_pipeline()
red:query("MULTI")
red:query("SET a 1")
red:query("INCR b")
red:query("EXEC")
local results = red:commit_pipeline()
-- results[4]才是真正的执行结果

6. 扩展延伸：与其他模块的配合

虽然本文聚焦redis2，但我们可以结合其他OpenResty模块打造超级工具链：

6.1 配合限流模块

local limit_req = require "resty.limit.req"

-- 先做限流判断
local limiter = limit_req.new("my_limit", 100, 50) -- 100req/s, 50突发
local delay, err = limiter:incoming("key", true)

if not delay then
    -- 触发限流时快速返回缓存
    local cached = red:query("GET cached_response")
    if cached then
        ngx.say(cached)
        return
    end
end

7. 总结：选择适合自己的工具

经过这番深度探索，相信你已经get到redis2模块的精髓。它的优势就像瑞士军刀——简单直接，但在复杂场景下可能需要更多手工操作。记住，没有最好的工具，只有最合适的场景。

当你在这些场景时，请优先考虑redis2：

• 需要执行复杂Redis命令组合
• 已有大量现成的Redis脚本
• 追求极限性能的批量操作
• 需要与命令行操作保持高度一致

下次当你面对OpenResty与Redis的集成需求时，不妨先问自己：这次需要的是灵活的原生操作，还是更高级的抽象封装？想清楚这一点，就能在技术选型时游刃有余了。