javascript - 如何每 X 毫秒只执行一次函数?
问题描述
我对javascript和node很陌生,目前正在开发一个node.js应用程序,该应用程序使用express和mongoDB,这个想法是通过webhook、websocket和mqtt监听一些第三方服务并将所有数据存储到mongoDB中。
但我有一个小问题,一些第三方应用程序向我发送数据过于频繁,例如,mqtt 流每秒发送大约 2 条消息,我每分钟只需要存储其中一条消息。
这就是我将 mqtt 实例化到 app.js 中的方式
var mqttHandler = require('./mqtt/mqtt_handler'); //mqtt
var mqttClient = new mqttHandler(); //mqtt
mqttClient.connect(); //mqtt
这是我的 mqttHandler.js:
onst mqtt = require('mqtt');
class MqttHandler {
constructor() {
this.mqttClient = null;
this.host = 'mqtts://host';
this.username = 'foo'; // mqtt credentials if these are needed to connect
this.password = 'mypassqword';
this.port = 8083;
this.protocol = 'MQTTS';
this.client = 'bar'
}
connect() {
// Connect mqtt with credentials (in case of needed, otherwise we can omit 2nd param)
this.mqttClient = mqtt.connect(this.host, {password : this.password, username : this.username, port: this.port});
// Mqtt error calback
this.mqttClient.on('error', (err) => {
console.log(err);
this.mqttClient.end();
});
// Connection callback
this.mqttClient.on('connect', () => {
//console.log(`mqtt client connected`);
});
// mqtt subscriptions
this.mqttClient.subscribe('/the_subscription');
// When a message arrives, console.log it
this.mqttClient.on('message', function (topic, message) {
console.log(message.toString())
});
this.mqttClient.on('close', () => {
//console.log(`mqtt client disconnected`);
});
}
// Sends a mqtt message to topic: mytopic
sendMessage(message) {
this.mqttClient.publish('mytopic', message);
}
}
module.exports = MqttHandler;
我正在阅读有关 setInterval 和 setTimeout 的信息,但我不知道如何实现这些以强制给定函数每 X 秒运行一次(不知道它被调用了多少次)
是否有类似/通用的方式来为 mqtt、webhooks 和/或 websocket 实现此功能?
我举了一个关于如何从教程中实现 mqtt 的例子,正如我所说,它的工作完美,我对 javascript 很陌生。
解决方案
使用 setInterval 的一种简单方法是定期设置一个标志,并在发布消息后将其清除。忽略任何其他消息,直到间隔函数再次设置该标志。
let readyToPost = false;
setInterval(function(){ readyToPost = true; }, 1000);
在您的功能中:
function connect() {
if (!readyToPost) return; // do nothing
readyToPost = false;
// rest of your code
}
推荐阅读
- c - 我在使用 OPENGL 时遇到 LoadTexBPM 错误
- glassfish - 将 MultiValued Map 与 Glassfish jersey jar 一起使用
- python-3.x - 在 Python 中使用字典将数字转换为字母
- apache-spark - 如何解析和分解在pyspark中存储为字符串的字典列表?
- openssl - 如何在同一进程中从不同路径两次加载到同一库?
- html - 在 html 中使用行跨度绘制表格
- python - Discord py - 'id': target.id AttributeError: 'NoneType' object has no attribute 'id' - in version 1.5.1
- google-cloud-platform - 使用 gsutil 访问 google adwords 存储桶
- react-native - 如何使用地址中的位置图钉创建可点击的地图
- firebase - 使用 Mockito 为 Firebase 用户身份验证设置单元测试