GServer

G服务器

关于GServer

• 什么是GServer
• 什么是可靠的udp
• 为什么可靠的udp比tcp更好

用法

课程

• 主持人
• 信息
• 数据存储
• 插件

示例

• 启动服务器
• 处理消息
• 添加插件

什么是GServer

GServer是可靠的 UDP 网络库，专为游戏而设计。其主要优点是：

• 可靠的UDP协议
• 提供高度灵活性的插件架构
• 使用起来非常简单

什么是可靠的UDP

可靠的 udp (RUDP) 是一种传输层协议，专为 TCP 增加过多开销的情况而设计，但尽管如此，我们仍然需要保证顺序的数据包传送。

RUDP 模组

RUDP 支持 3 个 mod 及其组合。 GServer 实现了其中一些最有用的功能：

• 无模式 - 与标准 UDP 一样工作
• 可靠 - 提供递送检查并保证所有包裹都将递送
• 可靠排序 - 保证所有交付的包裹都将按照正确的顺序进行处理，但并不意味着交付所有包裹
• 可靠的订购 - 保证所有包裹都将交付并按正确的顺序进行处理

为什么可靠的udp比tcp更好

• 可靠的 udp 由于其模式而比 udp 提供更多的灵活性
• 可靠有序模式模拟 TCP 行为，但工作速度更快，因为它不需要等待丢失的包。

课程

主持人

Host 是GServer中的主类。它提供了接收、发送和处理消息的方法。消息在监听线程中自动接受。

消息使用“Send”方法发送并使用处理程序进行处理，处理程序由用户使用“AddHandler”方法注册。请参阅示例。

信息

消息用于将数据从一台主机发送到另一台主机。它有3个参数：

• type ：短消息类型，用于向特定消息添加处理程序。
• mode ：模式 - 可靠模式（参见 RUDP mods）
• body : byte[] - 字节数组中的序列化数据

数据存储

DataStorage 用于将数据序列化为字节数组。它有 2 个模组：

• 调用不带参数的构造函数将启用只写模式。
• 使用 byte[] 或 MemoryStream 参数调用构造函数可启用只读模式。

在只读模式下，您可以仅使用从缓冲区读取数据的 Read 方法。在只写模式下，您可以仅使用将数据写入缓冲区的 Write 方法。

插件

处理中...

示例

启动服务器

服务器

 Host host = new Host ( portNumber ) ; //instantiate host on portNumber port
host . StartListen ( numberOfThreads ) ; //StartListen on numberOfThreads threads

Timer timer = new Timer ( o => host . Tick ( ) ) ;
timer . Change ( 10 , 10 ) ; // enables timer tick every 10 milliseconds

客户

 Host host = new Host ( portNumber ) ; //instantiate host on portNumber port
host . StartListen ( numberOfThreads ) ; //StartListen on numberOfThreads threads

Timer timer = new Timer ( o => host . Tick ( ) ) ;
timer . Change ( 10 , 10 ) ; // enables timer tick every 10 milliseconds

host . OnConnect = ( ) => Console . WriteLine ( "Connected" ) ; // connect handler 

host . BeginConnect ( serverEndpoint ) ; // connecting to server endpoint 

处理消息

 /* host inicialization here */

//add handler to message with id == messageId
//when message with that id will arrive callback will be invoked
//connection - connection associated with sender
host . AddHanlder ( messageId , ( message , connection ) => 
{
    /* deserialize message buffer */
    /* process message buffer */
    /* send response if needed */
} ) ; 

数据存储

 class SimpleClass : ISerializable , IDeserializable 
{
     public int IntField { get ; set ; }
     public byte [ ] ByteArray { get ; set } // arraySize = IntField
     public byte [ ] Serialize ( ) 
     {
          var ds = DataStorage . CreateForWrite ( ) ;
          ds . Push ( IntField ) ;
          ds . Push ( ByteArray ) ;
          return ds . Serialize ( ) ;
     }
     public void FillDeserialize ( byte [ ] buffer )
     {
          var ds = DataStorage . CreateForRead ( buffer ) ;
          IntField = ds . ReadInt32 ( ) ;
          ByteArray = ds . ReadBytes ( IntField ) ;
     }
}