如何按顺序处理 websocket 消息

大佬教程收集整理的这篇文章主要介绍了如何按顺序处理 websocket 消息，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决如何按顺序处理 websocket 消息？

开发过程中遇到如何按顺序处理 websocket 消息的问题如何解决？下面主要结合日常开发的经验，给出你关于如何按顺序处理 websocket 消息的解决方法建议，希望对你解决如何按顺序处理 websocket 消息有所启发或帮助；

我在每个 WebSocket 中收到数十条消息，这些消息可能会以几毫秒的差异到达。我需要使用有时需要一点时间的操作来处理这些数据（例如在 DB 中插入）。 为了处理收到的新消息，必须先处理完前一个消息。

我的第一个想法是用 node.Js Bull ( with redis ) 准备一个队列，但我担心它运行时间太长了。这些消息的处理必须保持快速。

我尝试使用 Js 迭代器/生成器（直到现在我从未使用过）并且我测试了这样的东西：

const ws = new WebSocket(`${this.baseUrl}${this.path}`)
const duplex = WebSocket.createWebSocketStream(ws,{ enCoding: 'utf8' })
    
const messageGenerator = async function* (dupleX) {
    for await (const message of dupleX) {
      yIEld message
    }
  }


for await (let msg of messageGenerator(socketAPI.dupleX)) {
    console.log('start process')
    await this.messageHandler.handlemessage(msg,user)
    console.log('end process')
}

日志：

1. 启动进程
2. 启动进程
3. 结束进程
4. 结束进程

不幸的是，如您所见，消息会继续处理，而无需等待前一消息完成。你有解决这个问题的方法吗？ 我最终应该使用 redis 队列来处理消息吗？

谢谢

解决方法

大佬总结

以上是大佬教程为你收集整理的如何按顺序处理 websocket 消息全部内容，希望文章能够帮你解决如何按顺序处理 websocket 消息所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。