消息组队列用例库建议

问题描述

在对可用队列库进行了大量研究之后,没有找到任何合适的解决方案,我正在写这篇文章以寻求一些建议。

我有多个小型IoT设备,每隔几秒钟就会将数据发送到服务器,并且每个设备的数据处理应按顺序进行。一台设备的数据不能比其他设备优先执行。

要使用当前解决方案按顺序执行,我必须为每个设备创建一个队列,并将使用者连接到每个队列。设备的数量将会增加,因此创建多个队列和使用者不是一个可扩展的解决方案。

我试图找到一种解决方案,在该解决方案中,单个队列将具有可以为每个设备分配的消息分组/主题,并且很少有使用者以一定的执行能力X jobs/second附加到队列。 队列应该管理每个设备的顺序执行,而且还应通过给使用者分配不同设备的并行作业来利用使用者的最大容量。 如果发生故障,应在设备的数据队列的最前面重新排队,并在一段时间后重试。

类似于以下内容

enter image description here

数据本质上是时间序列的,并且处理是时间敏感的。

我不确定该模式是否有名称。但是我在message grouping in Apache ActiveMQ处找到了类似我的用例的东西,但没有确切的解决方案。而且,它对node.js的支持有限。

请建议满足此用例的任何队列库(具有良好的node.js支持)或模式。 此外,还可以在主题中引入优先级或时间序列优先级。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)