并发400收发成功,但是java在处理的时候会只能收到大概是200条

环境信息

  • EMQX 版本:4.3.10
  • 操作系统及版本:ubuntu 20.04
  • 其他

问题描述

并发400收发成功,但是java在处理的时候会只能收到大概是200条,
在主题监控流入和流出中发现,数值没问题正常,
java这边有涉及一些业务处理,(抓拍图上传之类),只能收到前200条左右,后面的直接抛弃了
测试了一下只要加上延时之类的,就会丢失消息
有小伙伴遇到这种问题吗~

配置文件及日志

首先并发400是指同一个消费端在消费吗?如果是仅一个设备在消费,一般来说都没有这么强的处理能力,消息处理不过来就丢弃了。
推荐使用共享订阅的方式来做消息处理,看下这个文档

一般情况下单机消费一秒在多少条消息左右?按150K算的话,纯接受

看你的带宽,还有设备SDK,以及业务处理的能力,不推荐单线程消费。共享订阅就是为了解决这个问题的,会有一个消费池,多个设备轮流处理业务。
但是设备消费能力需要自己做一下压力测试才知道。每个SDK能力都不一样,设备硬件资源也不一样