我每秒从服务器连续接收 50 笔交易,我想使用一个名为processTransaction
.
主进程接收事务,但现在我想在所有子进程之间负载平衡事务处理(我有 16 个子进程与核心数相同)。我无法使用集群模块在nodejs上实现它,请你帮忙。
这里我的代码使用单线程:
listenToTransactions = async function () {
server.on("transaction", async (tx) => {
processTransaction(tx); // heavy work is done here
});
}