GatewayWorker 底层和mqtt疑惑
1、在一个进程使用mqtt: 如果只开一个进程,在进程启动时订阅某个消息,如果接收到新消息时,上一条还没有处理完,是等上一条处理完成再处理下一条,还是会同时处理两个? 如果等待上一条处理完成之后才处理新的,那么堆积消息的最大数量是根据什么来的?或者最大堆积消息为多少条? 2、GatewayWorker的websocket接收消息处理: 如果出现客户端延迟高发来的消息丢包GatewayWorker是如何处理的? 如果...
嘿嘿嘿嘿
-15
积分
0
获赞数
0
粉丝数
2019-05-15 加入