看到很多關(guān)于redis的例子,但是都是基于客戶端命令行的,比如如下這種:
127.0.0.1:6379> publish channel message
那如果我現(xiàn)在不要用shell, 要用不同的瀏覽器訂閱消息,然后在服務(wù)端發(fā)布消息,這個又怎么做呢? 我用的是node.js.
哪位大神可以放上瀏覽器客戶端和服務(wù)端的訂閱發(fā)布消息的例子,謝謝!
我自己琢磨出了一種辦法,不知道可行否。
我生成3個客戶端:
處理正常req,res請求的
發(fā)布消息的
訂閱消息的
我本來想用訂閱消息的redis客戶端來處理正常req,res請求但是報錯:
ReplyError: ERR only (P)SUBSCRIBE / (P)UNSUBSCRIBE / PING / QUIT
allowed in this context
后來才知道,原來如果客戶端用于訂閱消息就不能下其他命令進行CRUD。
所以才要再建一個客戶端處理正常的req, res請求。
下面是代碼:
var redis = require('redis');
var express = require('express');
var app = express();
var clientSub = redis.createClient(6379, 'localhost');
var clientPub = redis.createClient(6379, 'localhost');
var clientRes = redis.createClient(6379,'localhost');
clientRes.on('ready', function(err){
console.log('hello, i handle req/res');
});
clientPub.on('ready', function (err) {
console.log('hello, i publish');
});
clientSub.on('ready', function (err) {
console.log('hello, i subscribe');
});
clientSub.subscribe('channel1');
clientSub.on('subscribe', function (channel, count) {
console.log(`got subscribe event: ${channel} and count is ${count}`);
setInterval(()=>{
clientPub.publish('channel1', `hi, i am channel one, message at ${new Date()}`);
}, 2000);
});
clientSub.on('connect', function () {
clientSub.on('message', function (channel, message) {
var response = `received message from ${channel}:${message}`;
clientRes.lpush('myResponse', response,redis.print);
});
});
app.get('/', function (req, res) {
clientRes.lrange('myResponse',0,-1, function(err, result){
console.log(result[result.length])
res.send(typeof result);
})
})
app.listen(1338, function () {
console.log('App listening on port 1338!');
});
北大青鳥APTECH成立于1999年。依托北京大學(xué)優(yōu)質(zhì)雄厚的教育資源和背景,秉承“教育改變生活”的發(fā)展理念,致力于培養(yǎng)中國IT技能型緊缺人才,是大數(shù)據(jù)專業(yè)的國家
達內(nèi)教育集團成立于2002年,是一家由留學(xué)海歸創(chuàng)辦的高端職業(yè)教育培訓(xùn)機構(gòu),是中國一站式人才培養(yǎng)平臺、一站式人才輸送平臺。2014年4月3日在美國成功上市,融資1
北大課工場是北京大學(xué)校辦產(chǎn)業(yè)為響應(yīng)國家深化產(chǎn)教融合/校企合作的政策,積極推進“中國制造2025”,實現(xiàn)中華民族偉大復(fù)興的升級產(chǎn)業(yè)鏈。利用北京大學(xué)優(yōu)質(zhì)教育資源及背
博為峰,中國職業(yè)人才培訓(xùn)領(lǐng)域的先行者
曾工作于聯(lián)想擔(dān)任系統(tǒng)開發(fā)工程師,曾在博彥科技股份有限公司擔(dān)任項目經(jīng)理從事移動互聯(lián)網(wǎng)管理及研發(fā)工作,曾創(chuàng)辦藍懿科技有限責(zé)任公司從事總經(jīng)理職務(wù)負責(zé)iOS教學(xué)及管理工作。
浪潮集團項目經(jīng)理。精通Java與.NET 技術(shù), 熟練的跨平臺面向?qū)ο箝_發(fā)經(jīng)驗,技術(shù)功底深厚。 授課風(fēng)格 授課風(fēng)格清新自然、條理清晰、主次分明、重點難點突出、引人入勝。
精通HTML5和CSS3;Javascript及主流js庫,具有快速界面開發(fā)的能力,對瀏覽器兼容性、前端性能優(yōu)化等有深入理解。精通網(wǎng)頁制作和網(wǎng)頁游戲開發(fā)。
具有10 年的Java 企業(yè)應(yīng)用開發(fā)經(jīng)驗。曾經(jīng)歷任德國Software AG 技術(shù)顧問,美國Dachieve 系統(tǒng)架構(gòu)師,美國AngelEngineers Inc. 系統(tǒng)架構(gòu)師。