MQTT客户端应该是单进程的吧,我以它为服务端订阅所有其他客户端的主题,并处理所有客户端的业务,当消息一多的时候肯定会面临阻塞的问题,这时候怎么办?怎么用多进程来处理呢? 需要自己实现多个进程的模型以及业务的分配吗
客户端收到后放入队列消费
客户端收到后放入队列消费