Trung tâm cá nhân
sách gpt4 ai đã đi

javascript - 发布/订阅

In lại 作者：行者123 更新时间：2023-12-03 10:53:22 32 4
mua khóa gpt4 Nike

我正在尝试在 Node 中实现发布/订阅模式，但不使用 Redis。功能应该是相同的；您可以发布到 channel ，订阅 channel 并收听数据(如果您已订阅)；以下是 Redis 功能:

pub.publish('channel1', myData1, function (err, data) {     
});


sub.subscribe('channel1', function (err, data) {
});


sub.on("message", function (channel, data) {
    //Now you are easily listening to data
});

我尝试了以下方法，这可能根本不是一个好方法(我只是展示我的尝试!)；我有自己的 channel 对象，其中保存了当我们将新数据发布到特定 channel 时需要触发的 channel 和函数；正如你所看到的，我正在订阅 channel 的功能；但是，我不知道是否有任何方法可以像redis提供的那样监听数据 sub.on("message",function(){...!所以请你帮忙如果我能像 Redis 那样做，但使用 eventEmitter 或...

var events = require('events');
var emitter = new events.EventEmitter;
var channels = {};
//channels ={"channelA": ["func1", "func2"], "channelB": []}

//publish data to a channel and emits all of the functions which are registered for listening to the channel
function publish(channel, data, callback) {
    if (channels[channel] && channels[channel].length > 0) {
        for (var i = 0; i < channels[channel].length; i++) {
            emitter.emit(channels[channel][i], data);
        }
    }
    callback();

}

//subscribe a function to a channel
function subscribe(channel, FuncName, next) {
    if (!channels[channel]) {
        channels[channel] = [];
    }
    channels[channel].push(FuncName);
    Kế tiếp();
}

//Subscribe a callback function from a channel
function unsubscribe(channel, FuncName) {
    if (channels[channel]) {
        var indx = channels[channel].indexOf(FuncName);
        if (indx != -1) {
            channels[channel].splice(indx, 1);
        }
    }
}

1 Câu trả lời

您可以为每个 channel 使用一个EventEmitter。另外，您可能希望保存对回调的引用，而不是对函数名称字符串的引用。

var events = require('events');
var channels = {};

//publish data to a channel and emits all of the functions which are registered for listening to the channel
function publish(channel, data, callback) {
  if (channels[channel]) {
    channels[channel].emit('message', channel, data);
  }
  callback();
}

//subscribe a function to a channel
function subscribe(channel, fn, next) {
  if (!channels[channel]) {
    channels[channel] = new events.EventEmitter();
  }
  channels[channel].addListener('message', fn);
  Kế tiếp();
}

//unsubscribe a callback function from a channel
function unsubscribe(channel, fn) {
  if (channels[channel]) {
    channels[channel].removeListener('message', fn);
  }
}

关于javascript - 发布/订阅，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/28351813/

32 4 0
Bài viết được đề xuất: javascript - 为什么以下 javascript 在 Internet Explorer 和 Mozilla 中不起作用，但在 google chrome 中工作正常？
Bài viết được đề xuất: javascript - 哪种方法可以将 PDF 放入 iframe 中？
Bài viết được đề xuất: javascript - 前导零是什么意思？
Bài viết được đề xuất: javascript - 模板内的条件元素？
行者123
Hồ sơ cá nhân

Tôi là một lập trình viên xuất sắc, rất giỏi!

Nhận phiếu giảm giá Didi Taxi miễn phí
Mã giảm giá Didi Taxi
Các bài viết nóng hổi trên toàn bộ trang web
Giấy chứng nhận ICP Bắc Kinh số 000000
Hợp tác quảng cáo: 1813099741@qq.com 6ren.com