Node.js中Redis的rpush/lrange函数未触发问题求助

问题场景 #

在Node.js中使用Redis的rpush存储列表、lrange获取元素时遇到以下问题：

• 最初调用小写rpush/lrange时报错提示不是函数，改用大写RPUSH/LRANGE后程序能运行，但回调逻辑异常
• rpush确实把数据存入了Redis（redis-cli可查），但回调内的日志没打印，也没有返回响应
• lrange无法获取redis-cli中可见的列表元素

用户代码：

const redis = require('redis');
const client = redis.createClient({
    host: '127.0.0.1',
    port: 6379
});

client.on('error', err => console.log('Redis Client Error', err));

// Pushing data into the list using rpush
client.rpush("mylist2", "Hello3", (error, reply) => {
    console.log("Hello from inside client .rpush");
    if (error) {
        console.error('Error pushing data:', error);
    } else {
        console.log('Pushed data:', reply);

        // Once data is pushed, perform lRange operation
        performLRANGE();
    }
});

performLRANGE();

function performLRANGE() {
    // Replace 'mylist' with your actual list key
    const listKey = 'mylist2';
    const startIndex = 0;
    const endIndex = -1; // -1 retrieves all elements

    console.log("Hello from inside performLrange function");
    // Using the lrange command
    client.lrange(listKey, startIndex, endIndex, (error, result) => {
        console.log("Hello from inside LRANGE");
        if (error) {
            console.error('Error:', error);
        } else {
            console.log('Elements in the list:', result);
        }

        // Close the Redis connection
        client.quit();
    });
}

解决步骤 #

问题根源是Redis客户端版本差异——v4+版本采用Promise API，不再支持v3及以前的回调模式，同时命令统一为小写，且需要手动确保客户端连接成功。

1. 修复客户端连接逻辑

v4+版本的createClient不会自动连接，需手动调用client.connect()，且要等待连接成功后再执行命令：

const redis = require('redis');
const client = redis.createClient({
    host: '127.0.0.1',
    port: 6379
});

client.on('error', err => console.log('Redis Client Error', err));

// 新增连接逻辑
async function initRedis() {
    await client.connect();
    console.log('Redis client connected');
}

initRedis();

2. 改用Promise/async-await替代回调

v4+版本不再支持回调参数，必须使用Promise或async-await：

// 重写rpush和lrange逻辑
async function pushAndGetList() {
    try {
        // 执行rpush
        const pushReply = await client.rPush('mylist2', 'Hello3');
        console.log('Pushed data:', pushReply);

        // 执行lrange
        const listElements = await client.lRange('mylist2', 0, -1);
        console.log('Elements in the list:', listElements);
    } catch (error) {
        console.error('Operation failed:', error);
    } finally {
        // 关闭连接
        await client.quit();
    }
}

// 连接成功后执行
initRedis().then(pushAndGetList);

3. 移除提前调用的performLRANGE()

原代码在rpush回调执行前就调用了performLRANGE()，会导致先执行一次空的lrange操作，且提前关闭连接，影响后续的rpush回调执行。

4. 版本兼容方案（可选）

如果坚持使用回调模式，需安装v3版本的Redis客户端：

npm install redis@3

此时可继续使用小写rpush/lrange+回调的写法，无需手动调用connect()。

内容的提问来源于stack exchange，提问作者Ahsan Ali