将对象数组传入Redis Lua脚本的最佳实践与高效方式

阿华AIGC实验室

2026-5-14

关于Redis Lua脚本传入对象数组的最佳实践

首先要肯定你的核心观点：将事件列表批量传入单个Lua脚本，绝对比每个事件单独调用一次脚本高效。因为每次脚本调用都涉及客户端与Redis的网络往返，批量处理能把100次RTT（网络往返时间）压缩成1次，这在每秒5-100个事件的场景下，性能提升会非常明显，而且Lua脚本本身具备原子性，和你之前用multi/exec实现的事务效果一致，甚至更高效——毕竟所有逻辑都在Redis服务器端一次性执行，没有客户端先攒命令再提交的额外开销。

接下来聊聊传入事件列表的最佳方式，分两种场景推荐：

1. 优先选择：扁平化参数列表（性能最优）

如果你的Event结构固定（比如只有userId、actionId、impact三个字段），最推荐的方式是把每个事件的字段按顺序“平铺”到Lua脚本的ARGV参数数组里，完全不需要序列化/反序列化，性能拉满。

Lua脚本示例

-- 计算事件总数：每个事件占3个参数，所以用总参数数除以3
local event_count = #ARGV // 3

for i = 1, event_count do
    -- 计算当前事件的参数起始索引
    local base_idx = (i - 1) * 3 + 1
    local user_id = ARGV[base_idx]
    local action_id = ARGV[base_idx + 1]
    local impact = tonumber(ARGV[base_idx + 2])

    -- 执行你的业务逻辑
    redis.call('SADD', 'users', user_id)
    redis.call('SADD', 'actions', action_id)
    redis.call('INCRBYFLOAT', 'users:' .. user_id, impact)
end

return 'Processed ' .. event_count .. ' events'

Java调用示例

把所有事件的字段按顺序拼接成参数列表即可：

RedisCommands<String, String> cmd = getOrCreateRedisClient();
List<String> args = new ArrayList<>();

for (Event event : listOfEvents) {
    args.add(event.getUserId());
    args.add(event.getActionId());
    args.add(String.valueOf(event.getImpact()));
}

// 执行Lua脚本，KEYS为空，参数用ARGV
String result = cmd.eval(scriptContent, Collections.emptyList(), args);

这种方式的优势：

完全避免序列化/反序列化的开销，性能最高
不需要依赖Redis的cjson模块，兼容性更好
脚本逻辑简单直接，调试也方便

2. 备选方案：JSON序列化（适合复杂结构）

如果你的Event字段多变、结构复杂，扁平化参数会让代码变得繁琐，这时候可以把整个事件序列转成JSON字符串，作为单个参数传入Lua脚本，再用cjson解析。

Lua脚本示例

-- 确保Redis服务器启用了cjson模块（大多数默认配置都有）
local cjson = require('cjson')
local events = cjson.decode(ARGV[1])

for _, event in ipairs(events) do
    redis.call('SADD', 'users', event.userId)
    redis.call('SADD', 'actions', event.actionId)
    redis.call('INCRBYFLOAT', 'users:' .. event.userId, event.impact)
end

return 'Processed ' .. #events .. ' events'

Java调用示例

用JSON库把事件数组转成字符串：

RedisCommands<String, String> cmd = getOrCreateRedisClient();
ObjectMapper mapper = new ObjectMapper();
String eventsJson = mapper.writeValueAsString(listOfEvents);

String result = cmd.eval(scriptContent, Collections.emptyList(), eventsJson);

这种方式的注意点：