nodejs redis的发布与订阅

/* 
* redis发布订阅
 */
"use strict";

let configFile = require(‘../../include/commons‘).CONFIG_FILE;
let config = require(‘../../resources/config/‘ + configFile);

let RedisModel = require(‘./../redis.model‘);
let RedisSubClient = require(‘./redisSubClient‘);
let RedisPubClient = require(‘./redisPubClient‘);
let redisPubConn = RedisPubClient.redisClient().connection;
let redisSubConn = RedisSubClient.redisClient().connection;

class PubSub{
    constructor(){
        this.sub=redisSubConn;
        this.handlers=new Map();
        this.subAction=(channle,message)=>{
            console.log("接收消息："+message);
　　　　　　　message = JSON.parse(message);
　　　　　　　//消息处理。。。
      }
        this.alredyPublishs=[];
        this.subConnected=false;
    }

    publish(channel,message)
    {
        let action=()=>{
            let pub=redisPubConn;
            pub.publish(channel,message);
            console.log("发布消息:channel:"+channel+",message:"+message);
        };
        if(this.subConnected===false)
        {
            this.alredyPublishs.push(action);
        }
        else{
            action();
        }
    }

    subscribe(channel)
    {
        let self=this;
        this.sub.subscribe(channel,function (err,reply) {
            if(err){
                log.error(err);
            }
            self.subConnected=true;
            for(let publish of self.alredyPublishs){
                publish();
            }
            console.log("订阅成功:"+reply);
        });

        this.sub.on("message", function (channel, message) {
　　　　　　　　//接收消息
            self.subAction(channel,message);
        });
    }
}
// Expose class
module.exports = new PubSub();