活版印字

npm init -y
npm install --save-dev babel-cli
npm install --save-dev babel-preset-es2015
npm install --save-dev  babel-preset-stage-0
npm install --save babel-polyfill
npm install --save-dev koa@2
npm install --save rsmq
npm install --save rsmq-worker

import RedisSMQ from "rsmq";

const rsmq = new RedisSMQ({
  host: process.env.REDIS_HOST || '127.0.0.1',
  port: process.env.REDIS_PORT || 6379
});

function send(qname, message) {
  rsmq.sendMessage({
    qname: qname,
    message: message
  }, function(error, resp) {
    if (error) return console.error(error);
    if (resp) return console.log("ID:", resp);
  });
}

send(channelName, '098765 test');

import RSMQWorker from "rsmq-worker";
var channelName = 'myqueue';
var worker = new RSMQWorker(channelName);

worker.on("message", function(msg, next, id) {
  console.log("Message id : " + id);
  console.log(msg);
  next()
});

worker.on('error', function(err, msg) {
  console.log("ERROR", err, msg.id);
});
worker.on('exceeded', function(msg) {
  console.log("EXCEEDED", msg.id);
});
worker.on('timeout', function(msg) {
  console.log("TIMEOUT", msg.id, msg.rc);
});

worker.start();