服务器对全局发送消息必须有个缓存。原因如下:
假设服务器的运算瓶颈是每秒钟发送100个信息;如果这个时候服务器本身产生的发送消息数据远远大于了这个数量,会导致服务器宕机,即使不宕机也运行出现异常。
而且有可能突然间访问量暴增,如果在socket这一层面可以阻止过高的访问量,那么剩下的就是运算瓶颈。 这2点相互制约。因此理论上要获取信息的过程快,同时检查运算瓶颈,防止服务器宕机。
根据这个思路,所有接收的消息都会被放入一个全局队列,这结构如下:
GlobalMessageQueueController
:Queue<ServerIoSession> queue;
这个队列可以设置一个无限循环,例如只要有数据while(hasdata),就立刻取出发送;如果没有数据,则进入等待x秒钟。
ServerIoSession的结构:
:Queue<Message>
这样每次发送消息,先缓存入session的queue,然后交给 GlobalMessageQueueController