nodejs redis 发布订阅机制封装实现方法及实例代码_网络技术

nodejs redis 发布订阅机制封装实现方法及实例代码

发布时间 - 2026-01-10 21:51:00 点击率：次

nodejs redis 发布订阅机制封装

最近项目使用redis，对publish 和 subscribe的使用进行了了解，并进行了封装。

var config = require('../config/config');
var log = require("./loghelp");
var redis = require("redis");
function initialclient(param) {
  var option={ host: config.redis.host, port: config.redis.port};
  if(param)
  {
    option=Object.assign(option,param);
  }
  redis.print
  let client = redis.createClient(option);
  client.on("error", function(err) {
    log.error(err);
  });
  return client;
}

/*example:
* let channel="ryan";
 redis.pubSub.registerHandlers("ryan",msg=> console.log(msg));
 redis.pubSub.subscribe(channel);

 redis.pubSub.publish(channel,"hello from chen");*/
class PubSub
{
  constructor(){
    this.sub=initialclient();
    this.handlers=new Map();
    this.subAction=(channle,message)=>{
      let actions= this.handlers.get(channle)||new Set();
      for(let action of actions)
      {
        action(message);
      }
    }
    this.alredyPublishs=[];
    this.subConnected=false;
  }

  publish(channel,message)
  {
    let action=()=>{
      let pub=initialclient();
      pub.publish(channel,message);
    };
    if(this.subConnected===false)
    {
      this.alredyPublishs.push(action);
    }
    else
      action();
  }
  registerHandlers(channel,action)
  {
    var actions=this.handlers.get(channel)||new Set();
    actions.add(action);
    this.handlers.set(channel,actions);
  }
  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);
    });
  }

  tearDown()
  {
    this.sub.quit();
  }
}

然后通过exports.pubsub=new PubSub() 将其暴漏，可保证是单例。在程序启动时，调用

registerHandlers 注册特定通道的处理逻辑，然后调用
subscribe 订阅通道。

在合适时机调用publish，这个机制可以实现分布式下所有客户端watch 同一个数据的更改。

本人全手工打造的dotnetcore webapi 框架，可实现快速开发。

地址：http://xiazai./201612/yuanma/WebApiCore-master().rar。

1 采用DDD模式开发，充血模型 2 添加Dapper扩展，默认实现增删改查基本操作。利用AutoMapper 做实体转换，减少重复劳动。 3 依赖注入融合Autofac，仓储层和应用层自动注入 4 实现JWT验证 5 加入swagger 文档 6 单元测试添加了xunit,MyMvc 可以方便对webapi测试 7 数据库版本控制

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

# nodejs # redis # 封装 # 封装实例详解 # 封装如何实现 # 基于 Node.js 实现前后端分离 # Nodejs全栈框架StrongLoop推荐 # 在nodejs中使用swagger方式 # 进行了 # 将其 # 希望能 # 可以实现 # 谢谢大家 # 启动时 # 客户端 # 单元测试 # 应用层 # 文档 # 全手工 # error # err # return # print # assign # createClient # client # channel # constructor

相关栏目：【网站优化151355 】【网络推广146373 】【网络技术251811 】【 AI营销90571 】

上一篇：微信公众帐号开发教程之图文消息全攻略

下一篇：邀请函制作网站有哪些,有没有做年会邀请函的网站啊？在线制作

相关栏目网站优化
网络推广
网络技术
AI营销

最新文章 Sublime怎么一键压缩JS代码 Su sublime如何在搜索中使用正则表达式 Sublime如何设置透明窗口效果 Su mysql如何设计商品表结构_mysql css属性背景图不显示怎么办_通过检查路如何使用Golang实现排序_Golan 农历闰月是怎么回事_为合回归年加一月调整塑造《刺客信条》艾吉奥传奇的编剧离开育碧 1英里等于多少公里 1mile和km的换 css grid布局中行和列是如何定义的 PS批量旋转和翻转图片，快速校正图片方向 C# Swagger UI自定义方法 C OPPO手机九宫格和全键盘怎么切换_OP Go语言如何实现用户登录注册_Golan 1节飞行速度多少公里每小时 1节是多少公纸嫁衣8千子树第五章庙门怎么开启庙门 Laravel 多行数据编辑表单中实现逐明日之后如何提升钓鱼等级明日之后提升钓支付宝怎样查年度账单_支付宝年度账单查看 C# 多线程UI更新Dispatcher

上一篇：微信公众帐号开发教程之图文消息全攻略

下一篇：邀请函制作网站有哪些,有没有做年会邀请函的网站啊？在线制作