[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