redis模块和ioredis的注意事项

---

---

前言

node.js在使用redis的时候有两个库可以选择，一个是redis、另一个是ioredis，我一直以来也没有太大关注这两个库有什么区别。直到今天写代码的时候发现一个令我困惑的问题。

---

一、ioredis和redis使用zrange的比较

有个需求，需要将任务按优先级进行排序，在redis是有一个有序集合的api：zadd可以直接完成这个功能的。在zadd中主要通过参数priority来完成数据的自动排序，排序规则是，priority的值越小，score越小，代码如下：

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

// 使用 zadd 命令
async function addToSortedSet() {
    try {
        const result = await redis1.zadd('mySortedSet', 1, 'value1');
        const result1 = await redis1.zadd('mySortedSet', 3, 'value12');
    } catch (err) {
        console.error('Error adding to sorted set:', err);
    }
}

addToSortedSet();

然后取数据

const result = await redis1.zrange('manager_processing', 0, 0);
console.log('取出result:', result);   //正常返回接结果

打印结果

这一切都没有什么问题，很正常。

---

BUT, 当我们用redis模块来实现时，问题就来了

const Redis = require('redis');
var client = Redis.createClient(6379,'127.0.0.1'); //端口号、主机

// 使用 zadd 命令
async function addToSortedSet() {
    try {
        const result = await client.zadd('mySortedSet', 1, 'value4');
        const result1 = await client.zadd('mySortedSet', 3, 'value5');
    } catch (err) {
        console.error('Error adding to sorted set:', err);
    }
}

addToSortedSet();

可以看出redis模块实现插入数据是没有问题的，如下图，数据成功插入。

但是当我们去取数据的时候，注意：

 try {
     const result = await client.zrange('manager_processing', 0, 0);
     console.log('取出result:', result);   //结果是true or flase
 }catch (e) {
     console.log(e);
 }

**返回结果竟然是false!!!!!!!**这是为什么？？？卖个关子，我们在下一节给出解释。

二、出现zrange结果不同的原因

redis (redis.createClient)：

• redis 库创建的 client 是基于回调的 Redis 客户端。要使用 await 关键字，它必须返回一个 Promise。redis 库的 zrange 方法是基于回调的，不直接支持 Promise。
• 在 client.zrange 中，虽然你使用了 await，但由于 client.zrange 返回的是回调模式的函数，这会导致 TypeError，因为 await 不能用于非 Promise 对象。

ioredis (new Redis())：

• ioredis 库创建的 redis1 客户端支持 Promise，所以可以直接使用 await 来处理异步操作。
• redis1.zrange 调用将正确返回 Promise 的结果，并可以被 await 使用。

明白了把，在redis模块中，redis的库的 zrange 方法是基于回调的，不直接支持 Promise，他不能使用await去获取返回值哦，原来真正的罪魁祸首是，redis的库是基于回调的，不支持promise。

找出原因，这下我们就可以修改redis的代码了：

const Redis = require('ioredis');
const redis1 = new Redis();
var redis = require('redis');
var client = redis.createClient(6379,'127.0.0.1'); //端口号、主机

async function testZrange() {
    client.zrange('manager_processing', 0, 0, (err, result)=> {
        if (err) {
            console.log(err);
        } else {
            console.log(result);
        }
    });
}

这样我们就可以取到结果了。完美解决。

当然还有另一种用法：

const result = await new Promise((resolve, reject) => {
    redisClient.zrange(manager_processing, 0, 0, (err, result) => {
        if (err) {
            reject(err);
        } else {
            resolve(result);
        }
    });
});

以上两种方法大家可以根据自己需求去选择使用。

---

总结

• redis 库创建的 client 是基于回调的 Redis 客户端。要使用 await 关键字，它必须返回一个 Promise。redis 库的 zrange 方法是基于回调的，不直接支持 Promise。

• ioredis 库创建的 redis1 客户端支持 Promise，所以可以直接使用 await 来处理异步操作。