使用Node.js与Redis,实现消息队列！-有何不可

使用Node.js与Redis,实现消息队列！

Davidvivi
2020-06-23 20:03:10
随心写
node redis

电脑环境：win10

node：v8.11.1

yarn：v1.22.1

redis: v5.0.9

白俊遥博客

生产者每隔一秒发送一次消息（producer）：

const redis = require('redis');const client = redis.createClient(6379, '127.0.0.1');

client.on('error', function (err) {  console.log('err' + err);
});

client.on('ready', function () {
  setInterval(() => {
    client.publish('testSecond', 'hi! second!');
    client.publish('message', 'hi! message!');
  },1000);
});

实现流量削峰，限流

目前我们生产是1S一条消息，控制成2S消费一次（consumer）

const client = require('redis').createClient(6379, '127.0.0.1');const ArrayList = [];
client.on('error', function (err) {  console.log('err' + err);
});
client.subscribe('testSecond');
client.subscribe('message');
client.on('subscribe', function (channel, count) {  console.log('subscribe channel:' + channel + ', count:' + count);
});
client.on('message', function (channel, message) {
  ArrayList.push({ channel, message });
});
client.on('unsubscribe', function (channel, count) {  console.log('channel:' + channel + ', count:' + count);
});

setInterval(()=>{    console.log(ArrayList,'ArrayList')
},2000)

本文为Davidvivi原创文章,转载无需和我联系,但请注明来自Davidvivi博客weixia.xin 本人微信：ww646904527,备注博客

打赏,支持一下