lnet

go ゲームサーバーネットワークライブラリ

階層

各層は抽象インターフェイスを定義しており、対応するインターフェイスが実装されていれば、各層を簡単に拡張できます。各インターフェイスは基本クラスの実装を提供しており、これを継承して、変更するメソッドをオーバーライドできます。

• トランスポート層はネットワーク関連の機能を担当し、現在 TCP と WebSocket をサポートしています。

      type ITransport interface {
          GetId () uint32
          GetLocalAddr () string
          GetRemoteAddr () string
          Listen () error
          Connect () error
          OnNewConnect ( transport ITransport )
          Read ()
          Write ()
          Send ( msgPkg IMessagePackage ) error
          Close ()
          OnClosed ()
          IsStop () bool
          IsTimeout ( tick * time. Timer ) bool
      }

• プロトコル層はプロトコル分析を担当し、現在 ProtoBuff および Gob エンコーディング プロトコルをサポートしています。

      type IProtocol interface {
      	Marshal ( msg interface {}) ([] byte , error )
      	Unmarshal ( data [] byte , v interface {}) error
      }

• MsgHandle 層はメッセージの配布を担当します

      type IMsgHandle interface {
          RegisterMsg ( tag uint32 , msg interface {})
          NewMsg ( tag uint32 ) interface {}
          GetMsgTag ( msg interface {}) uint32
          SetProtocol ( protocol IProtocol )
          GetProtocol () IProtocol
          CreateMessage ( msgPkg IMessagePackage ) interface {}
          CreateMessagePackage ( msg interface {}) IMessagePackage
          Process ( transport ITransport , msgPackage IMessagePackage )
          SetOnTransportClose ( f func ( transport ITransport ))
          OnTransportClose ( transport ITransport )
      }

サンプル

サービスを構築するには、上記の 3 つのレベルの構造を組み合わせて、必要なサービスをカスタマイズするだけです。

 //服务器逻辑
func serverStart () {
    //选择协议
    protocol := & lprotocol. PbProtocol {}
    //选择消息处理函数
    msgHandle := lmsghandle . NewBaseMsgHandle ( protocol )
    //注册消息
    msgHandle . RegisterMsg ( 12 , pb. GameItem {})
    msgHandle . RegisterMsg ( 13 , pb. RpcReqData {})
    msgHandle . RegisterMsg ( 14 , pb. RpcRspData {})
    //启动服务
    server := lserver . NewTcpServer ( "127.0.0.1:9000" , msgHandle )
    server . Start ()
}

//客户端逻辑
func clientStart () {
    //选择协议
    protocol := & lprotocol. PbProtocol {}
    //选择消息处理函数
    msgHandle := lmsghandle . NewBaseMsgHandle ( protocol )
    //注册消息
    msgHandle . RegisterMsg ( 12 , pb. GameItem {})
    msgHandle . RegisterMsg ( 13 , pb. RpcReqData {})
    msgHandle . RegisterMsg ( 14 , pb. RpcRspData {})

    client := lclient . NewTcpClient ( "127.0.0.1:9000" , msgHandle )
    client . Connect ()

    msg := & pb. GameItem { Id : 1 , Type : 2 , Count : 3 }
    for {
        client . Send ( msg )
        time . Sleep ( 1 * time . Second )
    }
}