轉自：https://blog.csdn.net/hiramtan/article/details/72621787

HiSocket_unity

如何使用

可以從此連結下載最新的unity package: 

功能

• Tcp socket
• Udp socket
• 可伸縮位元組表
• 高效能位元組塊緩衝區
• 訊息註冊和回撥
• 二進位制位元組訊息封裝
• Protobuf訊息封裝
• AES訊息加密

詳情

• Tcp和Udp都是採用主執行緒非同步連線的方式(避免主執行緒阻塞).
• 啟動傳送執行緒和接收執行緒處理資料傳輸(提高效能).
• 供使用者呼叫傳送或接受資料的API在主執行緒中(方便直接操作unity的元件)
• 監聽連線事件獲得當前的連線狀態.
• 監聽接收事件獲得接收的資料.
• 存在位元組陣列佇列,方便用來測試和資料重發.
• 高效能位元組緩衝區避免記憶體空間重複申請,減少GC.
• 如果使用Tcp協議需要實現IPackage介面處理粘包拆包.
• Ping介面因為mono底層的bug會在.net2.0平臺報錯(.net 4.6 沒有問題,或者也可以使用unity的介面獲得Ping,工程中有示例程式碼)

細節

• • Tcp connection 
    Tcp協議傳輸位元組流,使用者需要分割位元組流獲得正確的資料包,當建立一個tcp協議的socket時,需要傳入一個Package物件來封包和解包.

    private IPackage _packer = new Packer();
    void Test()
    {
     _tcp = new
     
     TcpConnection(_packer);
    }
    
    public class Packer : IPackage
    {
        public void Unpack(IByteArray reader, Queue<byte[]> receiveQueue)
        {
           //add your unpack logic here
       }
    
       public void Pack(Queue<byte[]> sendQueue, IByteArray writer)
       {
           // add your pack logic here
       }
    }

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18

  • 連線

    _tcp.Connect("127.0.0.1", 7777);

    • 1

  • 斷開連線 
    當不再執行時需要主動呼叫介面斷開與伺服器的連線(比如響應unity的onapplicationquit執行時)

    void OnApplicationQuit()
    {
        _tcp.DisConnect();
    }

    • 1
    • 2
    • 3
    • 4

  • 連線狀態變化 
    如果想獲取當前的連線狀態,可以訂閱連線狀態事件.

    void Test()
    {
        _tcp.StateChangeEvent += OnState;
    }
    void OnState(SocketState state)
    {
        Debug.Log("current state is: " + state);
        if (state == SocketState.Connected)
        {
            Debug.Log("connect success");
            //can send or receive message
        }
        else if (state == SocketState.DisConnected)
        {
            Debug.Log("connect failed");
        }
        else if (state == SocketState.Connecting)
        {
            Debug.Log("connecting");
        }
    }

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21

  • 傳送訊息

    void Test()
    {
        var bytes = BitConverter.GetBytes(100);
        _tcp.Send(bytes);
    }

    • 1
    • 2
    • 3
    • 4
    • 5

  • 接受訊息 
    You can regist receiveevent and when message come from server, this event will be fire.

        void Test()
        {
            _tcp.ReceiveEvent += OnReceive;
        }
        void OnReceive(byte[] bytes)
        {
            Debug.Log("receive msg: " + BitConverter.ToInt32(bytes, 0));
        }

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8

  • 封包和解包 
    最初建立連線時我們定義了一個packer來分割資料包,當傳送訊息時我們在資料頭部插入訊息長度/當接收到訊息時我們根據頭部的訊息長度獲得資料包的大小.

    private bool _isGetHead = false;
    private int _bodyLength;
    public void Unpack(IByteArray reader, Queue<byte[]> receiveQueue)
    {
        if (!_isGetHead)
        {
            if (reader.Length >= 2)//2 is example, get msg's head length
            {
                var bodyLengthBytes = reader.Read(2);
                _bodyLength = BitConverter.ToUInt16(bodyLengthBytes, 0);
            }
            else
            {
                if (reader.Length >= _bodyLength)//get body
                {
                    var bytes = reader.Read(_bodyLength);
                    receiveQueue.Enqueue(bytes);
                    _isGetHead = false;
                }
            }
        }
    }
    public void Pack(Queue<byte[]> sendQueue, IByteArray writer)
    {
        var bytesWaitToPack = sendQueue.Dequeue();
        UInt16 length = (UInt16)bytesWaitToPack.Length;//get head lenth
        var bytesHead = BitConverter.GetBytes(length);
        writer.Write(bytesHead);//write head
        writer.Write(bytesWaitToPack);//write body
    }

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30

• Udp

  • Udp connection 
    如果建立upd連線,需要指定傳送接收緩衝區大小.

    _udp = new UdpConnection(1024);

    • 1

• Ping

  public int PingTime;
  private Ping p;
  private float timeOut = 1;
  private float lastTime;
  void Start()
  {
      StartCoroutine(Ping());
  }
  IEnumerator Ping()
  {
      p = new Ping("127.0.0.1");
      lastTime = Time.realtimeSinceStartup;
      while (!p.isDone && Time.realtimeSinceStartup - lastTime < 1)
      {
          yield return null;
      }
      PingTime = p.time;
      p.DestroyPing();
      yield return new WaitForSeconds(1);
      StartCoroutine(Ping());
  }

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
• 訊息註冊
• Protobuf
• 位元組訊息
• 加密

Tcp Example

Tcp 協議提供可靠有序的流位元組傳輸,使用者需要自己分割資料,在這個框架中可以繼承IPackage介面來實現.

    private ITcp _tcp;
    private IPackage _packer = new Packer();
    // Use this for initialization
    void Start()
    {
        _tcp = new TcpConnection(_packer);
        _tcp.StateChangeEvent += OnState;
        _tcp.ReceiveEvent += OnReceive;
        Connect();
    }
    void Update()
    {
        _tcp.Run();
    }

    void Connect()
    {
        _tcp.Connect("127.0.0.1", 7777);
    }
    // Update is called once per frame

    void OnState(SocketState state)
    {
        Debug.Log("current state is: " + state);
        if (state == SocketState.Connected)
        {
            Debug.Log("connect success");
            Send();
        }
        else if (state == SocketState.DisConnected)
        {
            Debug.Log("connect failed");
        }
        else if (state == SocketState.Connecting)
        {
            Debug.Log("connecting");
        }
    }
    void OnApplicationQuit()
    {
        _tcp.DisConnect();
    }
    void Send()
    {
        for (int i = 0; i < 10; i++)
        {
            var bytes = BitConverter.GetBytes(i);
            Debug.Log("send message: " + i);
            _tcp.Send(bytes);
        }
    }
    void OnReceive(byte[] bytes)
    {
        Debug.Log("receive msg: " + BitConverter.ToInt32(bytes, 0));
    }
    public class Packer : IPackage
    {
        public void Unpack(IByteArray reader, Queue<byte[]> receiveQueue)
        {
            //add your unpack logic here
            if (reader.Length >= 1024)//1024 is example, it's msg's length
            {
                var bytesWaitToUnpack = reader.Read(1024);
                receiveQueue.Enqueue(bytesWaitToUnpack);
            }
        }

        public void Pack(Queue<byte[]> sendQueue, IByteArray writer)
        {
            var bytesWaitToPack = sendQueue.Dequeue();
            // add your pack logic here
            //

            writer.Write(bytesWaitToPack);
        }
    }

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24
• 25
• 26
• 27
• 28
• 29
• 30
• 31
• 32
• 33
• 34
• 35
• 36
• 37
• 38
• 39
• 40
• 41
• 42
• 43
• 44
• 45
• 46
• 47
• 48
• 49
• 50
• 51
• 52
• 53
• 54
• 55
• 56
• 57
• 58
• 59
• 60
• 61
• 62
• 63
• 64
• 65
• 66
• 67
• 68
• 69
• 70
• 71
• 72
• 73
• 74
• 75
• 76

Udp Example

Udp協議提供不可靠的報文訊息,使用者無法知道當前連線狀態,但是訊息包時完整的.

    private UdpConnection _udp;
    // Use this for initialization
    void Start()
    {
        _udp = new UdpConnection(1024);
        _udp.ReceiveEvent += OnReceive;
        Connect();
        Send();
    }
    void Connect()
    {
        _udp.Connect("127.0.0.1", 7777);
    }
    // Update is called once per frame
    void Update()
    {
        _udp.Run();
    }
    void Send()
    {
        for (int i = 0; i < 10; i++)
        {
            var bytes = BitConverter.GetBytes(i);
            _udp.Send(bytes);
            Debug.Log("send message: " + i);
        }
    }
    private void OnApplicationQuit()
    {
        _udp.DisConnect();
    }
    void OnReceive(byte[] bytes)
    {
        Debug.Log("receive bytes: " + BitConverter.ToInt32(bytes, 0));
    }

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24
• 25
• 26
• 27
• 28
• 29
• 30
• 31
• 32
• 33
• 34
• 35

Message Registration Example

    void RegistMsg()
    {
        MsgRegister.Regist("10001", OnMsg_Bytes);
        MsgRegister.Regist("10002", OnMsg_Protobuf);
    }

    void OnMsg_Bytes(IByteArray byteArray)
    {
        var msg = new MsgBytes(byteArray);
        int getInt = msg.Read<int>();
    }

    void OnMsg_Protobuf(IByteArray byteArray)
    {
        var msg = new MsgProtobuf(byteArray);
        GameObject testClass = msg.Read<GameObject>();//your class's type
        var testName = testClass.name;
    }