版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/kaw19950302/article/details/88963307
场景描述:
每个 HTTP 请求对应一个 MQTT 主题发布和消息监听。
场景模拟:
mqtt (msg){
let promise = new Promise((resolve, reject) =>{
this.app.emqtt.on('message', (topic, message) => {
if(topic === listeningTopic){
msg = message
console.log(topic)
msg = JSON.parse(msg.toString())
resolve(msg)
}
})
})
}
这是基于 MQTT 封装的一个方法,业务要求每次接收到 HTTP 请求都要执行一次 mqtt()
,这样写之后遇到一个警告⚠️:
(node:3275) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 message listeners added. Use emitter.setMaxListeners() to increase limit
意思是:添加了 11 个监听器,可能导致内存泄漏,可以使用 setmaxlistener()
来增加限制
但是,如果增加限制,是有多少个 HTTP 请求,我就要设置多少个限制,显然不符合我的业务需要,去查了下 Event 模块,发现有个 eventEmitter.once()
可以使用, eventEmitter.once()
是为指定事件注册一个单次监听器,即监听器最多只会触发一次,触发后立刻解除该监听器。
正好我的也是需求也是,这样就保证每一个完整的 HTTP 请求只有一个 MQTT 消息监听器,且只触发一次就被移除。
完整代码如下:
mqtt (msg){
let promise = new Promise((resolve, reject) =>{
this.app.emqtt.once('message', (topic, message) => {
if(topic === listeningTopic){
msg = message
console.log(topic)
msg = JSON.parse(msg.toString())
resolve(msg)
}
})
})
}