Socket 服务器设计核心——发送消息的缓存

服务器对全局发送消息必须有个缓存。原因如下:

假设服务器的运算瓶颈是每秒钟发送100个信息;如果这个时候服务器本身产生的发送消息数据远远大于了这个数量,会导致服务器宕机,即使不宕机也运行出现异常。

而且有可能突然间访问量暴增,如果在socket这一层面可以阻止过高的访问量,那么剩下的就是运算瓶颈。 这2点相互制约。因此理论上要获取信息的过程快,同时检查运算瓶颈,防止服务器宕机。

根据这个思路,所有接收的消息都会被放入一个全局队列,这结构如下:

GlobalMessageQueueController

:Queue<ServerIoSession> queue; 

这个队列可以设置一个无限循环,例如只要有数据while(hasdata),就立刻取出发送;如果没有数据,则进入等待x秒钟。

ServerIoSession的结构:

:Queue<Message> 

这样每次发送消息,先缓存入session的queue,然后交给 GlobalMessageQueueController

原文地址:https://www.cnblogs.com/zc22/p/1763845.html