Devops
和微前端已经写得差不多,开始复习下后端相关知识,之前想写的这篇文章,终于落地redis
,并且启动redis`redis-server`
yarn add redis --save
const redis = require('redis');
const client = redis.createClient(6379, '127.0.0.1');
❝这里普及下消息队列的使用,跟redis一样,都是属于进程外的服务,就是单独要占用一个端口起服务的 ❞
`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 () {
client.publish('testFirst', 'hi! first!');
client.publish('testSecond', 'hi! second!');
client.publish('message', 'hi! message!');
});`
`const client = require('redis').createClient(6379, '127.0.0.1');
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) {
console.log('message channel:' + channel + ', msg:' + message);
});
client.on('unsubscribe', function (channel, count) {
console.log('unsubscribe channel:' + channel + ', count:' + count);
});`
`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);
});`
❝这样,我们使用redis发布订阅模式,实现了简单的消息队列 ❞
`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)`
https://github.com/JinJieTan/MQ