emqx 消费者端强行断开

环境信息

  • EMQ X 版本:4.3.8
  • 操作系统及版本:Linux version 3.10.0-1127.el7.x86_64 (centos 7)
  • 其他

问题描述

一个简单测试过程,
一个发布者,1s内发布50条信息,每条信息大约200k左右;一个消费者,仅仅接收数据并作计数;
问题: 消费者端会间断些提示断开连接;
emqx log日志显示:[MQTT] socket_error: busy

配置文件及日志

请问,这种现象或问题,怎么处理和规避

这个是客户端消费能力不够,可能是你的带宽不够,也可能你发送的是QoS1/QoS2,但客户端没有及时确认

消费端能力不够,推荐解决方式为共享订阅或改为规则引擎来转发至消费能力强的服务,然后再做业务。如果你只是要计数器,可以通过规则引擎添加一个空动作,看规则的计数器即可。