zoukankan      html  css  js  c++  java
  • Socket 服务器设计核心——发送消息的缓存

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

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

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

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

    GlobalMessageQueueController

    :Queue<ServerIoSession> queue; 

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

    ServerIoSession的结构:

    :Queue<Message> 

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

  • 相关阅读:
    Hive 使用问题集锦
    scala def/val/lazy val区别以及call-by-name和call-by-value
    spark学习流程
    Hadoop
    Hive
    Chrome快捷键
    Java API帮助文档
    Java 访问修饰符与非访问修饰符
    java 关键字
    Solr配置Ikanalyzer分词器
  • 原文地址:https://www.cnblogs.com/zc22/p/1763845.html
Copyright © 2011-2022 走看看