您好，想请教一个问题，恳请赐教，我现在也在学习java开发mqtt服务，项目是这样的，智能终端监测数据发送到emqx服务器，另外开发一个服务端从emqx服务器订阅消息，并进行业务处理，我现在遇到的问题是，如果我的智能终端设备多，发送的数据量大，我开发的服务接收数据量也就大，怎样进行合理处理？谢谢！
只要你的 EMQX 集群撑得住，那么你只管部署更多的消费者进程就可以了。而消费者进程内部会要用线程池来并行处理收到的消息。
可以将你的处理数据的类写成单例。
用生产消费者模式 处理你不间断的数据传输。