服务端消费mqtt消息并发量问题

错误报告

使用jemeter-mqtt进行压测 发现一秒发送1000条消息服务端可以正好完全接收,而30秒发送6000条消息,emqx broker却丢弃了2000条消息好像后台消息消费不过来了,有点奇怪怎么解释呢。

环境

  1. 30秒6000条



  2. 1秒1000条


  • EMQX 版本:
  • 操作系统版本:

重现此问题的步骤

  1. xxx
  2. xxx
  3. xxx

预期行为

实际行为


功能请求

描述你需要的功能

为什么你需要这个功能


其他

这个丢弃是因为你的消费端接收不过来了,为了避免消息无限制在 EMQX 中堆积,所以会有一个最大堆积数量限制,达到限制后再有新消息进来就会丢弃旧消息然后让新消息入队。

我想问一下使用规则引擎webhook把某个主题的消息分发到web,可以提高整个系统的并发量嘛

你只是更换了消费的形式而已,最终还是要看消费能力的

您能提供一个解决思路嘛,确实经常会出现消息丢弃的现象,并且还会有收不到broker心跳响应包,导致主动断开无法重连的情况

解决方案在这个帖子里面我都跟你说了

奥奥 那我不得再弄一台服务器部署一下 如果两个服务部署在一台服务器那性能估计也没什么提升吧,提升消费端硬件性能指什么呢 带宽不

不好意思麻烦啦

你的性能瓶颈在哪里就提升哪里,CPU 不够就升级 CPU

16核 32g的应该没什么问题 需要部署在不同服务器不

16核的机器处理不了每秒1000的消息的话,你应该先优化代码

就是有点奇怪 我测试的时候1s1000条可以处理 8s8000条处理不了 :sweat_smile:

不好意思我刚刚又看了一下 是8核32g