节点JS事件未启动

Node JS event not firing

本文关键字：启动 事件 JS 节点      更新时间：2023-09-26

我试图在我的节点JS代码中引发一个事件，但无法找出为什么没有。

我有一个模块如下：

var zookeeper = require('node-zookeeper-client'),
    events = require('events'),
    util = require('util');
var client;
var KafkaZookeeperMonitor = function(){
    events.EventEmitter.call(this);  
}
util.inherits(KafkaZookeeperMonitor, events.EventEmitter);
KafkaZookeeperMonitor.prototype.connectToZk = function(zookeepers){
    client = zookeeper.createClient(zookeepers);
    client.connect();
    client.once('connected', function () {
        console.log('Connected to ZooKeeper');
        this.emit('connected');
    });
}
module.exports = KafkaZookeeperMonitor;

我从我的index.js文件中调用它，如下所示：

var KafkaZookeeperMonitor = require('./kafkaZookeeperMonitor'),
    kafkaStatus = new KafkaZookeeperMonitor(),
    brokerPath = '/brokers/ids';
kafkaStatus.connectToZk('192.168.50.252:2181');
kafkaStatus.once('connected', function(){
    console.log('watcher connected to Zookeeper');
})

当我运行代码时，我会收到日志消息

"已连接到动物园管理员"

但是CCD_ 1似乎没有发射。

我在网上到处看了看，我想我设置的事件发射器是正确的。有人能帮我找出哪里可能出了问题吗？

感谢

回调函数的上下文不是KafkaZookeeperMonitorz对象，因此this实际上不是Object实例。

这应该有效：

KafkaZookeeperMonitor.prototype.connectToZk = function(zookeepers){
  var self = this;
  client = zookeeper.createClient(zookeepers);
  client.connect();
  client.once('connected', function () {
      console.log('Connected to ZooKeeper');
      self.emit('connected');
  });
}

它没有抛出错误的原因可能是client也在扩展EventEmitter

我不相信"这"是你认为的…

this.emit('connected');

调试并确保您的"this"是您要查找的。。。

http://javascriptplayground.com/blog/2012/04/javascript-variable-scope-this/

相关文章：