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
        }
    }