在ES6类中停止setInterval

我只是想测试多个MQTT客户端在Node v8.9.1应用程序内以不同的间隔发送消息。目前，即使只有一个客户端，此代码也会失败。我无法理解为什么clearInterval不在这个班级内工作：

const mqtt = require('mqtt');

export default class MQTTClient {
constructor(url, conf, period) {
    this.url = url;
    this.conf = conf;
    this.period = period;
    this.messages = 0;
    this.client = null;
    this.interval = null;
}

getTotalMessages() {
    return this.messages;
}

connect() {
    this.client = mqtt.connect(this.url, this.conf);

    this.client.on('connect', () => {
        this.interval = setInterval(() => {
            this.client.publish(`u${this.conf.clientId}`, 'Hello mqtt');
            this.messages += 1;
            if (this.messages === 3) {
                clearInterval(this.interval);
                console.log(this.interval);
                this.client.end();
            }
        }, this.period);
    });

    this.client.on('error', (error) => {
        console.error(`${this.conf.clientId} error`, error);
    });
}
}

console.log语句实际上打印的内容如下：

Timeout {
    '0': null,
    _called: false,
    _idleTimeout: -1,
    _idlePrev: null,
    _idleNext: null,
    _idleStart: 5580,
    _onTimeout: null,
    _timerArgs: undefined,
    _repeat: null,
    _destroyed: false,
    [Symbol(asyncId)]: 134,
    [Symbol(triggerAsyncId)]: 123 }

为了更完整，我将这个类称为使用Jest进行的单元测试：

test('Multiple MQTT messages', (done) => {
    const mqttURL = `mqtt://localhost:${config.moscaSettings.port}`;
    expect(config.moscaSettings.port).toBe(1883);
    const conf = {
        clientId: concurrencyTokens[0].value,
        username: concurrencyTokens[0].owner,
        password: concurrencyTokens[0].value,
    };

    const mqttClient = new MQTTClient(mqttURL, conf, 1000);
    mqttClient.connect();

    // terminates the test after five seconds
    setTimeout(async () => {
        const res = await Messages.remove({ userName: user }).exec();
        expect(mqttClient.getTotalMessages()).toBe(3);
        expect(res.result.n).toBe(3);
        done();
    }, 5000);
}, 10000);

所以我无法理解为什么它不起作用。使用箭头函数可以保证this指的是类，但是间隔不会停止。有任何想法吗？

你正在做的简化版本工作正常。验证对this.property的每个引用都是正确的。还要验证您没有登陆OnError。

var c = (function(){
    let interval;
    let count = 0;
    let express = () => {
        interval = setInterval(() => {
	        count++;
            if (count === 3) {
                clearInterval(interval);
            }
            console.log(interval);
        }, 100);
    };
    return {onThing:express};
})();
c.onThing();