[Redis] 进行发布、订阅
在Node.js上使用Redis进行发布、订阅的方法请写下来。
假设一切都在考虑之中,
redis = {};
redis.pub = function(){
var sys = require('sys');
var redis = require('redis');
var subscriber = redis.createClient(6379, 'localhost');
subscriber.subscribe('hoge channel');
subscriber.on("message", function(channel, message) {
sys.puts(channel + " :" + message);
});
publisher = redis.createClient(6379, 'localhost');
publisher.publish("hoge channel", "test message");
};
redis.sub = function(){
var sys = require('sys');
var redis = require('redis');
var subscriber = redis.createClient(6379, 'localhost');
subscriber.subscribe('hoge channel');
subscriber.on("message", function(channel, message) {
sys.puts(channel + " :" + message);
});
};
如果node.js是pub的情况下,可以在终端上先执行以下命令,以便显示发布的信息。
输入命令:redis-cli subscribe “hoge channel”
相反地,如果是node.js端进行订阅,当在终端上进行发布时,会在node.js端显示该消息。
redis-cli发布 “hoge channel” “Hello World”
以上 – the above