Как получить значение redis для данного ключа redis, используя Nodejs + Redis - PullRequest
Новая
       37

Как получить значение redis для данного ключа redis, используя Nodejs + Redis

1 голос
/ 28 октября 2019

Я использую Nodejs + redis для установки и получения ключа: пары значений. Я написал пример кода, чтобы установить пару ключ: значение, а затем извлечь его, используя readme по умолчанию из плагина npm redis.

Моя цель - получить значение с сервера redis, используя любой данный ключ. Я выполнил шаги, описанные плагином npm redis. Я могу войти в него, но так как плагин является асинхронным, я не могу найти способ получить синхронный client.get запрос.

Мой код 

var redis = require("redis"),
    client = redis.createClient();
const bluebird = require("bluebird");

bluebird.promisifyAll(redis.RedisClient.prototype);
bluebird.promisifyAll(redis.Multi.prototype);

const redisKey = "redis-set-key";
const redisValue = "hello-world";

client.set(redisKey, redisValue);

function getData(key) {
    return client.get(key, function(err, result) {
        console.log("1. Get key from redis - ", result.toString());
        return result.toString();
    });
}

const getRedisdata = getData(redisKey);
console.log("2. getRedisdata", getRedisdata);

Результат 

2. getRedisdata false
1. Get key from redis -  hello-world

Моя цель - получить такой результат 

1. Get key from redis -  hello-world
2. getRedisdata hello-world

Пожалуйста, помогите мне решитьэто.

Нашел решение, вот мой разрешенный код 

const redis = require("redis");
const client = redis.createClient();
const bluebird = require("bluebird");

bluebird.promisifyAll(redis.RedisClient.prototype);
bluebird.promisifyAll(redis.Multi.prototype);

const redisKey = "redis-set-key";
const redisValue = "hello-world";
client.set(redisKey, redisValue);

async function setKey(key, value, expire = "EX", time = 300) {
    return new Promise((resolve, reject) => {
        return client.set(key, value, function(err, result) {
            if (result === null) {
                reject("set key fail promise");
            } else {
                resolve(result);
            }
        });
    });
}

async function getKey(key) {
    return new Promise((resolve, reject) => {
        return client.getAsync(key).then(function(res) {
            if (res == null) {
                reject("fail promise");
            } else {
                resolve(res);
            }
        });
    });
}

async function hashGetKey(hashKey, hashvalue) {
    return new Promise((resolve, reject) => {
        return client.hget(hashKey, hashvalue, function(err, res) {
            if (res == null) {
                reject("hash key fail promise");
            } else {
                resolve(res.toString());
            }
        });
    });
}

async function hashGetAllKey(hashKey) {
    return new Promise((resolve, reject) => {
        return client.hgetall(hashKey, function(err, res) {
            if (res == null) {
                reject("hash key all fail promise");
            } else {
                resolve(res);
            }
        });
    });
}

async function delKey(key) {
    return new Promise((resolve, reject) => {
        return client.del(key, function(err, result) {
            if (result === null) {
                reject("delete fail promise");
            } else {
                resolve(result);
            }
        });
    });
}

(async () => {
    // get single key value
    try {
        const keyData = await getKey("string key");
        console.log("Single key data:-", keyData);
    } catch (error) {
        console.log("Single key data error:-", error);
    }

    // get single hash key value
    try {
        const hashKeyData = await hashGetKey("hashkey", "hashtest 1");
        console.log("Single hash key data:-", hashKeyData);
    } catch (error) {
        console.log("Single hash key data error:-", error);
    }

    // get all hash key values
    try {
        const allHashKeyData = await hashGetAllKey("hashkey");
        console.log("All hash key data:-", allHashKeyData);
    } catch (error) {
        console.log("All hash key data error:-", error);
    }

    // delte single key
    try {
        const checkDel = await delKey("XXYYZZ!!!!");
        console.log("Check key delete:-", checkDel);
    } catch (error) {
        console.log("Check key delete error:-", error);
    }

    // set single key
    try {
        const checkSet = await setKey("XXYYZZ", "AABBCC");
        console.log("Check data setkey", checkSet);
    } catch (error) {
        console.log("Check data setkey error", error);
    }
})();

//  hget hashkey "hashtest 1"
client.hset("hashkey", "hashtest 1", "some value", redis.print);
client.hset(["hashkey", "hashtest 2", "some other value"], redis.print);
...