1、在一个进程使用mqtt:
如果只开一个进程,在进程启动时订阅某个消息,如果接收到新消息时,上一条还没有处理完,是等上一条处理完成再处理下一条,还是会同时处理两个?如果等待上一条处理完成之后才处理新的,那么堆积消息的最大数量是根据什么来的?或者最大堆积消息为多少条?
2、GatewayWorker的websocket接收消息处理:
如果出现客户端延迟高发来的消息丢包GatewayWorker是如何处理的?如果出现客户端延迟高发来的消息出现一条数据分成两个消息( 如消息**{test:ceshi}**,第一条为**{test**,第二条为:**ceshi} **),这个时候 到Event里是会合并成一条信息还是两条呢