HiSocket下載 - HiSocket源代碼下載

HiSocket

其他類別

3.0.0

下載

hisocket

這是一種輕巧的客戶端套接字解決方案，您可以在Unity3D或C＃項目中使用它

中文說明

如何使用

使用源代碼：源代碼
從發行路徑下載DLL：GitHub版本
使用Nuget：Hisocket Nuget軟件包

快速開始：

        //tcp example
        private IPackage package = new PackageExample ( ) ;
        private TcpConnection tcp ;
        void Init ( )
        {
            tcp = new TcpConnection ( package ) ;
            tcp . OnConnected += OnConnected ;
            tcp . OnReceive += OnReceive ;
            //...
            //...
            tcp . Connect ( "127.0.0.1" , 999 ) ;
        }
        void OnConnected ( )
        {
            //connect success
            tcp . Send ( new byte [ 10 ] ) ; //send message
        }

        void OnReceive ( byte [ ] bytes )
        {
            //get message from server
        }

更多示例：

C＃項目示例：示例
Unity項目示例：示例

一般的

該項目包含：

TCP
- TCPConnection
- tcpsocket
- 插件
  - ping
  - 統計
訊息
- 二進制消息
- Protobuf消息
- AES加密
大片

特徵

支持TCP插座
可擴展字節數組
高性能字節塊緩衝區
消息註冊並回電
支持字節消息
支持Protobuf消息
AES加密

細節

在主線程中使用異步連接（避免線程阻塞）。
使用Circular_Buffer每次避免記憶分配，並減少垃圾收集。
您可以通過添加事件的偵聽器來獲取當前的連接狀態和消息。
如果使用TCP套接字，則應實現iPackage接口以打包或解開消息。
ping：您可以使用一個ping插件，但是如果您由於單聲道的錯誤而在Unity3d中使用，它將在.net2.0上丟下錯誤（.net 4.6（.NET 4.6），也可以使用Unity的API獲取PING時間）

框架

先進的

如果您對套接字有清楚的態度，也可以使用TCPSOCKETCOCK來實現邏輯，無論如何建議是TCPConnection。
您可以使用API獲取套接字並執行額外的邏輯，例如修改套接字的時間
您可以使用API獲取發送和接收緩衝區，例如，斷開連接時如何處理緩衝區的數據？只需清除或重新發送到服務器即可。
Onsocketreceive和OnReceive是不同的，例如，sockeTreceive尺寸為100字節，如果用戶在Uppack Onceeive大小為100時什麼都不做。但是，當用戶做一些zip/unzip/uncript.etc（encription.etc）時，oneceive onreceive大小不再100。
您可以根據TCPConnection添加許多不同的插件，以實現不同的功能。
有消息登記冊基類幫助用戶快速註冊ID和回調（基於反射）
加密是使用AE，如果要使用加密，則可以使用API來加密字節。
。ETC

指示

TCP傳輸控制協議

TCP提供了一個字節流的可靠，有序和錯誤檢查的交付。您必須自己拆分字節，在此框架中，您可以實現iPackage接口以實現此目標。

由於TCP是Bytes協議的AA流，因此用戶應將字節拆分以獲取正確的消息包。創建TCP套接字通道時，必須有一個包裝實例來打包和解開消息。

包裝和解開郵件：一開始，我們定義一個包裝器以拆分字節，當發送消息時，我們在每個消息的頭部添加長度，當接收消息時，我們使用此長度來獲得消息的時間。

UDP用戶數據報協議

UDP提供了數據完整性的校驗和端口號，用於在數據報的源和目的地上解決不同的功能。這意味著您不知道當前的連接狀態，但是包裝已集成。

如果使用UDP連接shold shold dewine send和接收緩衝區大小。

ping：由於.NET 2.0上有一個單聲道的錯誤，並且在Unity3D中有子集，因此您可以使用以下邏輯。

 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 ( ) ) ;
}

例子

Hisocketexample項目或Hisocket.unitypackage中有許多例子，這裡有一些：

示例：

 public class PackageExample : PackageBase
    {
        protected override void Pack ( BlockBuffer < byte > bytes , Action < byte [ ] > onPacked )
        {
            //Use int as header
            int length = bytes . WritePosition ;
            var header = BitConverter . GetBytes ( length ) ;
            var newBytes = new BlockBuffer < byte > ( length + header . Length ) ;
            //Write header and body to buffer
            newBytes . Write ( header ) ;
            newBytes . Write ( bytes . Buffer ) ;
            //Notice pack funished
            onPacked ( newBytes . Buffer ) ;
        }

        protected override void Unpack ( BlockBuffer < byte > bytes , Action < byte [ ] > onUnpacked )
        {
            //Because header is int and cost 4 byte
            while ( bytes . WritePosition > 4 )
            {
                int length = BitConverter . ToInt32 ( bytes . Buffer , 0 ) ;
                //If receive body
                if ( bytes . WritePosition >= 4 + length )
                {
                    bytes . MoveReadPostion ( 4 ) ;
                    var data = bytes . Read ( length ) ;
                    //Notice unpack finished
                    onUnpacked ( data ) ;
                    bytes . ResetIndex ( ) ;
                }
            }
        }
    }

 TcpConnection tcp ;
        void Connect ( )
        {
            tcp = new TcpConnection ( new PackageExample ( ) ) ;
            tcp . OnDisconnected += OnDisconnect ;
            tcp . Connect ( "127.0.0.1" , 999 ) ;
            tcp . Socket . NoDelay = true ;
            tcp . Socket . SendTimeout = 100 ;
            tcp . Socket . ReceiveTimeout = 200 ;
            //...


            // you can add plugin sub from IPlugins
            tcp . AddPlugin ( new StatisticalPlugin ( "Statistical" ) ) ; //this plugin calculate how many send
        }

        void OnDisconnect ( )
        {
            var length = tcp . SendBuffer . WritePosition ;
            Console . WriteLine ( "Still have {0} not send to server when abnormal shutdown" ) ;
            var data = tcp . SendBuffer . Read ( length ) ;
            tcp . SendBuffer . ResetIndex ( ) ;

            //use can handle these data, for example maybe can send next time when connect again
            //tcp.Send(data);
        }

 /// <summary>
    /// The recommend is use TcpConnection 
    /// </summary>
    class Example3
    {
        TcpSocket tcp ; //The recommend is use TcpConnection 
        void Connect ( )
        {
            tcp = new TcpSocket ( 1024 ) ; //set buffer size
            tcp . OnReceiveBytes += OnReceive ;
            tcp . Connect ( "127.0.0.1" , 999 ) ;
        }

        void OnReceive ( byte [ ] bytes )
        {
            //split bytes here
        }
    }