如何解决不使用 ES6 导入/导出和 worker_thread 的文件之间的事件发射器
我有两个文件,第一个是 state.js
,您可能会在下面看到:
import EventEmitter from "events";
import tasklist from 'tasklist';
export const stateManager = new EventEmitter();
//IIFE working every 10 seconds via cron task,from the file below
(async () => {
const processes = await tasklist();
const exist = processes.find(({imageName}) => imageName === 'process.exe');
if (!!exist) {
console.log(!!exist)
stateManager.emit('state',1);
} else {
console.log(!!exist)
stateManager.emit('state',0);
}
})();
第二个是 eventListener.js
文件,它无休止地运行。
//import stateManager from first file
import { stateManager } from "./src/controller.js";
/**
* Here is part of the code
* which starts the first file
* as a Worker cron-task every 10 seconds
* It doesn't block the thread.
*/
const bree = new Bree({
logger: logger,jobs: []
});
bree.add({
name: "state",interval: ms("10s")
})
bree.start();
// First listener
console.log('check');
stateManager.on('state',function firstListener(...args) {
console.log('State updated',args);
});
启动 eventListener.js
后,我在控制台中看到的输出如下:
check
false
State updated [ 0 ]
[LOGGER] 21-03-01 18:03:67 info : Worker for job "state" online
false
[LOGGER] 21-03-01 18:03:08 info : Worker for job "state" exited with code 0
//every 10 second then =>
[LOGGER] 21-03-01 18:13:69 info : Worker for job "state" online
false
[LOGGER] 21-03-01 18:13:06 info : Worker for job "state" exited with code 0
或者如果我从另一个(第三个文件)导出 export const stateManager = new EventEmitter()
而不是直接导出 state.js
。
check
[LOGGER] 21-03-01 18:03:23 info : Worker for job "state" online
false
[LOGGER] 21-03-01 18:03:63 info : Worker for job "state" exited with code 0
//every 10 second then =>
[LOGGER] 21-03-01 18:13:23 info : Worker for job "state" online
false
[LOGGER] 21-03-01 18:13:63 info : Worker for job "state" exited with code 0
所以任务工作正常,事件侦听器永远不会结束,但不知何故,它不会对 state
事件作出反应,或者在开始时只反应一次。为什么会出现这样的问题?由于我在控制台中没有其他错误?
如果有帮助,我使用 bree.js
作为作业队列管理器,它实际上运行 cron 任务本身。
解决方案
我想我已经找到了问题的解决方案,但我无法理解原因本身。
就我而言,最好不要使用 events
库,而是使用 worker_threads
,因此代码现在如下所示:
import { parentPort } from "worker_threads";
import tasklist from 'tasklist';
//IIFE working every 10 seconds via cron task,from the file below
(async () => {
const processes = await tasklist();
const exist = processes.find(({imageName}) => imageName === 'process.exe');
if (parentPort) parentPort.postMessage({ state: !!exist })
})();
和 eventListener
接收端看起来像:
bree.on('worker created',(name) => {
bree.workers[name].on('message',(message) => {
console.log(message); // Prints { state: !!exist }
})
});
所以来自第一个文件的消息已经成功传递。
但如果有人向我解释,为什么 events
库无法在不同作品之间传递消息,即使 eventListener
已正确导出,我会很高兴。
解决方法
Bree
基本上是启动一个新进程。你在那里得到的相当于做:
node eventListener.js
然后:
node state.js
每 10 秒一次。每 10 秒创建一个事件发射器,但没有附加侦听器,因为它位于未运行的 eventListener.js
文件中,每 10 秒仅 state.js
一次。
Bree 对此可能有点矫枉过正,您可以只使用 setInterval
或 setTimeout
循环。无论如何,这些都是 async
并且您没有在 JS 方面做任何繁重的事情,因此您不应该阻塞太多。虽然如果你确实想使用工人,你的解决方案对我来说似乎没问题。直接与工作人员合作并放弃 Bree
可能更容易。
另一种选择是在单独的文件上设置 Bree
和 eventListener
。您只需运行另一个文件(它将每 10 秒运行一次您的所有程序)。
似乎我理解这种行为的原因,但我不确定这是 Bree 问题本身。
只是不要将 IIFE 函数用作 Bree 的内置 cron 任务。取而代之的是,使用文件中的 cron-task。通过 await sleep(time)
和递归,或通过节点调度程序模块本身,您将如何执行它并不重要。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。