python模拟500个客户端往5个topic中传入数据，每个客户端2s发一次（qos=0），java这边开启多线程，在每个线程都会订阅这5个topic（qos=2），消费入库，流出速率为什么会比消息流入速率多很多，会一直产生告警
你应该是开了100个线程，每个都会收到 python 的客户端发的所有消息。然后 324*100 就是 32400，差不多就是 32661.
消费的时候，我是每个主题都开了五个线程做共享订阅，一共有五个主题，消费时候也打印了日志，并没有重复消费
还有能请教下，最开始设计是五百个客户端往同一个topic里面发消息，然后java这边只有一个单线程订阅这个topic，python那边还是每个客户端2秒发一次数据，运行一段时间后就会产生类似告警，然后python那边客户端都会断开，是因为订阅消费这块处理不过来吗
如果是必现的，你可以在 emqx 这里对一个客户端做 logtrace，看是什么原因。