认识

2025年01月06日

柏拉文

越努力，越幸运

一、认识

---

Redis 的 Pipeline（管道）是一个技术，用于将多个命令批量发送到 Redis，而不需要等待每个命令的响应。通过将多个命令合并在一个请求中，可以显著减少网络延迟，提高效率。

1.1 为什么使用 Pipeline？

1. 减少网络延迟：在默认情况下，每个 Redis 命令的请求和响应需要两次网络往返。使用 Pipeline 可以一次性发送多个命令，从而大大减少延迟。

2. 提高吞吐量：对于大量简单的操作，Pipeline 可以大幅提高 Redis 的处理能力。

二、语法

---

2.1 Node.js

使用 Node.js 实现 Redis Pipeline: redis.pipeline()：创建一个 pipeline 对象。使用 pipeline.set() 和 pipeline.get() 等方法将命令添加到 pipeline 中。pipeline.exec() 会发送所有命令到 Redis，返回一个包含每个命令结果的数组。

const Redis = require('ioredis');
const redis = new Redis();

// 创建一个 pipeline
async function runPipeline() {
  try {
    const pipeline = redis.pipeline();

    // 将多个命令添加到 pipeline 中
    pipeline.set('key1', 'value1');
    pipeline.set('key2', 'value2');
    pipeline.get('key1');
    pipeline.get('key2');

    // 执行 pipeline
    const results = await pipeline.exec();

    // 输出每个命令的结果
    console.log(results);  // [[null, 'OK'], [null, 'OK'], [null, 'value1'], [null, 'value2']]
  } catch (error) {
    console.error('Error executing pipeline:', error);
  }
}

runPipeline();

结合 Lua 脚本和 Pipeline: 如果你需要在一个 Pipeline 中同时执行 Lua 脚本和其他命令，可以将 Lua 脚本与常规的 Redis 命令结合。pipeline.eval(luaScript, 1, 'mykey', 'default_value')：可以将 Lua 脚本添加到 pipeline 中。

const Redis = require('ioredis');
const redis = new Redis();

// Lua 脚本：检查键是否存在，如果存在则返回其值，否则设置为默认值
const luaScript = `
  if redis.call('exists', KEYS[1]) == 1 then
    return redis.call('get', KEYS[1])
  else
    redis.call('set', KEYS[1], ARGV[1])
    return ARGV[1]
  end
`;

async function runLuaInPipeline() {
  try {
    const pipeline = redis.pipeline();

    // 在 pipeline 中执行 Lua 脚本
    pipeline.eval(luaScript, 1, 'mykey', 'default_value');

    // 你还可以将其他命令添加到 pipeline
    pipeline.set('anotherKey', 'anotherValue');
    pipeline.get('anotherKey');

    // 执行 pipeline
    const results = await pipeline.exec();

    // 输出结果
    console.log(results);
  } catch (error) {
    console.error('Error executing Lua in pipeline:', error);
  }
}

runLuaInPipeline();