最近项目使用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 框架，可实现快速开发。
地址：(jb51.net).rar。
1 采用DDD模式开发，充血模型 2 添加Dapper扩展，默认实现增删改查基本操作。利用AutoMapper 做实体转换，减少重复劳动。 3 依赖注入融合Autofac，仓储层和应用层自动注入 4 实现JWT验证 5 加入swagger 文档 6 单元测试添加了xunit,MyMvc 可以方便对webapi测试 7 数据库版本控制