emq向多个topic发送数据,触发的规则引擎为同一个,如果实现消息并行流出

问题描述

并行向多个topic发送数据,触发的规则引擎为同一个,通过主题监控发现消息流出有先后顺序,尝试对不同topic分别建立规则引擎,依旧存在消息流出有先后顺序的问题,请问有什么解决办法吗?

不同的主题下是异步执行的,所以消息顺序无法保证

你好,请问不同主题是异步执行的 是说消息流入吗,还是流出?通过主题监控目前消息流出呈现的效果好像是单队列,并没有并行的效果

消息流出的顺序一般是按照消息流入的顺序。向多个主题发送数据,其实并不能保证消息是完全同一时间到达的(因为不能保证线程执行时间是完全一致的,取决于线程调度)。即使完全一致的消息到达时间,流出通道也会按照处理的顺序发送。
PS:建议看下CPU时间片相关知识