10万设备批量离线,几秒内完成,如何处理

你好,10万设备批量离线,JMETER模拟,订阅上下线信息的服务重连后,后面的数据直接丢掉了,即平台后面显示的还是在线的,这类大批量离线或者在线的,如何处理比较好,EMQX能控制平稳投递给订阅者吗

connection congested: #{buffer => 4096,clientid => <<“mqtt_14420”>>,conn_state => connected,connected_at => 1721296248024,high_msgq_watermark => 8192,high_watermark => 1048576,memory => 21141952,message_queue_len => 22860,peername => <<“192.168.2.1:23432”>>,pid => <<“<0.20522.7>”>>,proto_name => <<“MQTT”>>,proto_ver => 4,recbuf => 369280,recv_cnt => 9,recv_oct => 651,reductions => 163440316,send_cnt => 17951,send_oct => 8576791,send_pend => 12744,sndbuf => 252416,sockname => <<“192.8.0.2:1883”>>,socktype => tcp,username => <<“root”>>}
这是订阅服务挂了的时候的报错信息,表示什么含义

是客户端收到太多的消息,消费不过来了。具体可以看一下这一片文章,推荐使用 webhook 方式:

https://segmentfault.com/a/1190000045059752