【发布时间】:2019-01-01 14:52:09
【问题描述】:
我正在尝试使用 Redis 制作自己的简单消息队列。
但是,我在使用 Redis 创建队列时遇到问题。
我在项目的其他部分使用 Redis 进行缓存,所以我确信 redis 连接很好(+ 我尝试打印出实例,看起来很好)。
message_queue.js
const redis = require("./redis.js");
var sendMessage = async (queue) => {
var result = await redis.rpush(queue,5);
console.log(result);
var arr = await redis.lrange(queue,0,-1);
console.log(arr);
};
redis.js
const redis = require('redis');
const redisinfo = require('../secret/redisinfo.js');
const client = redis.createClient(redisinfo);
client.on("error",function(err){
console.log("Error " + err);
});
module.exports = client;
当我从 message_queue.js 运行 sendMessage 函数时, 它打印 false 和 false。
将项目推入队列并打印它我做错了什么?在此过程之前我是否需要做一些事情,例如声明一个列表?
附言 我不知道这是否是使用这个包的正确方法,但似乎我需要使用回调函数来访问结果......
以下代码按预期工作
redis.lrange(queue,0,-1,function(err,res){
if(res.length != 0){
console.log(`Something is in queue`);
}
});
【问题讨论】: