无法将 Redis 服务器与快速节点 js 应用程序集成

Question

我是 Node 的新手.js我一直在尝试创建一个与 KUE 库集成的小应用程序，用于任务队列。

当我尝试运行该应用程序时，即 node app.js 我收到以下错误：

{ ReplyError: ERR wrong number of arguments for 'set' command
    at parseError (.......node_modulesredis-parserlibparser.js:193:12)
    at parseType (........node_modulesredis-parserlibparser.js:303:14)
  command: 'SET',
  args: [ 'promotion:lock', 'H5BCCsomeRandomString==', 'PX', 2000, 'NX' ],
  code: 'ERR' }

我

确实在很多地方看到了这个错误，但它们似乎都不是我问题的解决方案。

这是我的app.js

var express = require('express');
var path = require('path');
var logger = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');
var session = require('express-session');
var dotenv = require('dotenv');
dotenv.load();
var queue = require('./routes/queueJob');
var app = express();
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'jade');
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(session({
  secret: 'secret',
  resave: true,
  saveUninitialized: true
}));
app.use(express.static(path.join(__dirname, 'public')));
app.use('/jobs', queue);
app.use(function(req, res, next) {
  var err = new Error('Not Found');
  err.status = 404;
  next(err);
});
app.use(function(err, req, res, next) {
  res.status(err.status || 500);
  res.render('error', {
    message: err.message,
    error: err
  });
});
app.listen(3000);

这是路由/队列作业.js

var express = require('express');
var router = express.Router();
var kue = require('kue'),
  jobs = kue.createQueue();
var env = {};

jobs.on('ready', () => {
  console.info('Queue is ready!');
});
jobs.on('error', (err) => {
  console.error('There was an error in the main queue!');
  console.error(err);
  console.error(err.stack);
});
router.get('/addnewjob', function(req, res) {
  let callback = function() {
    console.log('Callback has been triggered');
  }
  newJob('Request Job', callback);
  res.end('Successfully added a new job');
});
function newJob(name, callback) {
  name = name || 'Default_Name';
  var job = jobs.create('new job', {
    name: name
  });
  job
    .on('complete', function() {
      console.log('Job', job.id, 'with name', job.data.name, 'is done');
      callback();
    })
    .on('failed', function() {
      console.log('Job', job.id, 'with name', job.data.name, 'has failed');
      callback();
    })
  job.save();
}
jobs.process('new job', function(job, done) {
  setTimeout(function() {
    console.log('Job Processing finished');
  }, 5000);
  done();
});
module.exports = router;

由于错误消息中没有太多内容，因此我不确定如何解决此问题。我真的很感激在这方面的一些帮助。

Answer 1

Redis 中的 SET 命令具有以下格式：

SET key value [EX seconds] [PX milliseconds] [NX|XX]

在您的错误中，您似乎正在尝试使用带有许多与格式不匹配的参数的 SET 命令：

  command: 'SET',
  args: [ 'promotion:lock', 'H5BCCsomeRandomString==', 'PX', 2000, 'NX' ],