一个GatewayWorker作为路由模块,一个GatewayWorker作为获取用户信息模块 用户连接路由模块,发送请求,然后通过路由模块再发送到用户信息模块,通过用户信息模块再发送给客户端. 内部应该如何通讯呢?mqtt是否合适呢?...
1、在一个进程使用mqtt: 如果只开一个进程,在进程启动时订阅某个消息,如果接收到新消息时,上一条还没有处理完,是等上一条处理完成再处理下一条,还是会同时处理两个? 如果等待上一条处理完成之后才处理新的,那么堆积消息的最大数量是根据什么来的?或者最大堆积消息为多少条? 2、GatewayWorker的websocket接收消息处理: 如果出现客户端延迟高发来的消息丢包GatewayWorker是如何处理的? 如果...