错误报告
使用jemeter-mqtt进行压测 发现一秒发送1000条消息服务端可以正好完全接收,而30秒发送6000条消息,emqx broker却丢弃了2000条消息好像后台消息消费不过来了,有点奇怪怎么解释呢。
环境
-
30秒6000条
-
1秒1000条
- EMQX 版本:
- 操作系统版本:
重现此问题的步骤
- xxx
- xxx
- xxx
使用jemeter-mqtt进行压测 发现一秒发送1000条消息服务端可以正好完全接收,而30秒发送6000条消息,emqx broker却丢弃了2000条消息好像后台消息消费不过来了,有点奇怪怎么解释呢。
30秒6000条
1秒1000条
这个丢弃是因为你的消费端接收不过来了,为了避免消息无限制在 EMQX 中堆积,所以会有一个最大堆积数量限制,达到限制后再有新消息进来就会丢弃旧消息然后让新消息入队。
我想问一下使用规则引擎webhook把某个主题的消息分发到web,可以提高整个系统的并发量嘛
你只是更换了消费的形式而已,最终还是要看消费能力的
您能提供一个解决思路嘛,确实经常会出现消息丢弃的现象,并且还会有收不到broker心跳响应包,导致主动断开无法重连的情况
解决方案在这个帖子里面我都跟你说了
奥奥 那我不得再弄一台服务器部署一下 如果两个服务部署在一台服务器那性能估计也没什么提升吧,提升消费端硬件性能指什么呢 带宽不
不好意思麻烦啦
你的性能瓶颈在哪里就提升哪里,CPU 不够就升级 CPU
16核 32g的应该没什么问题 需要部署在不同服务器不
16核的机器处理不了每秒1000的消息的话,你应该先优化代码
就是有点奇怪 我测试的时候1s1000条可以处理 8s8000条处理不了
不好意思我刚刚又看了一下 是8核32g