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, p
Node.js uses an event-driven, non-blocking I/O model that makes it lightweight and efficient.
在nodejs的官方文档中,明确写出了node的一个特性是event-driven(事件驱动),可见其非常重要。查看源码,我们可知其事件机制为用js写的EventEmitter类,写得非常优雅且应用了发布/订阅模式。
通过实现一个简易的、具有发布/订阅模式的事件机制,以此来理清EventEmitter类的实现
什么是Pub-Sub
发布订阅是一种设计模式,它允许应用程序组件之间进行松散耦合。
其实订阅发布设计中主要是发布者生成事件通道,用于在不了解任何订阅者存在的情况下通知订阅者。
当然委托EventHandlers和Event关键字在此事件处理机制中担任着重要的角色。下面我们来看看如何使用它们。
Pub和Sub的使用
首先我们看一个简单地订阅发布模式.
定义一个Action委托,无返回值.
namespace PubSubPattern
{
public class Pub
{
p