温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

如何理解socket tcp开发包MiniSocket

发布时间:2021-10-18 10:28:33 来源:亿速云 阅读:136 作者:柒染 栏目:大数据

本篇文章给大家分享的是有关如何理解socket tcp开发包MiniSocket,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。

MiniSocket 采用socket tcp方式通讯,自动处理分包合并,性能高,使用简单,非常容易进行二次开发

服务端使用:打开vs2017 新建.net core(2.1版本以上) 控制台应用,nuget搜索MiniSocket 下载

代码:

        static void Main(string[] args)
        {
            // 实际化服务端对象
            Network server = new Network();
            // 设置ip地址
            server.Ip = "127.0.0.1";
            // 设置端口号
            server.Port = 9123;
            // 设置客户端最大连接数
            server.ClientMaxCnt = 10;
            // 设置接收超时
            server.ReceiveTimeout = 1000 * 100;
            // 设置发送超时
            server.SendTimeout = 1000 * 100;
            // 设置接收缓冲区大小
            server.RecvBufferSize = 1024;
            // 设置工作线程数
            server.WorkThreadCnt = 20;
            // 设置客户端超时时间(秒)
            server.TimeOver = 30;
            // 设置接收完成事件
            server.RecvCompleted += RecvEventData;
            // 初始化
            bool bl =  server.Init();
            while(true)
            {
                Thread.Sleep(1000);
            }
        }

        /// <summary>
        /// 接收完成事件
        /// </summary>
        /// <param name="e"></param>
        /// <param name="sockArgs"></param>
        private static void RecvEventData(Network e,SocketParas sockArgs)
        {

            try
            {
                string str_head = Encoding.UTF8.GetString(sockArgs.HeadByt);
                string str_body = Encoding.UTF8.GetString(sockArgs.BodyByt);

                e.Send(sockArgs, Encoding.UTF8.GetBytes("this is header"), Encoding.UTF8.GetBytes("this is body"));
            }
            catch(Exception ex)
            {
                Print("RecvEventData "+ex.Message);
            }
        }

客户端使用:打开vs2017 新建.net framework(4.0版本以上) 控制台应用,nuget搜索MiniSocketClient 下载

代码:

       static void Main(string[] args)
        {
            // 实例化客户端对象
            Network client = new Network();
            // 设置ip地址
            client.Ip = "127.0.0.1";
            // 设置端口号
            client.Port = 9123;
            // 设置接收超时
            client.ReceiveTimeout = 1000 * 30;
            // 设置发送超时
            client.SendTimeout = 1000 * 30;
            // 设置接收缓冲区大小
            client.ReceiveBufferSize = 1024;
            // 接收完成事件
            client.RecvCompleted += RecvComplete;
            // 退出事件
            client.ExitCompleted += ExitCompleted;
            // 初始化
            client.Init();
            // 发送第一包数据
            client.Send(Encoding.UTF8.GetBytes("hello china"), Encoding.UTF8.GetBytes("hello world"));

            while (true)
            {
                Thread.Sleep(10);
            }

        }

/// <summary>
        /// 接收完成事件
        /// </summary>
        /// <param name="e"></param>
        /// <param name="sockArgs"></param>
        private static void RecvComplete(Network e, SocketParas sockArgs)
        {
            try
            {

                Console.WriteLine(Encoding.UTF8.GetString(sockArgs.HeadByt) + Encoding.UTF8.GetString(sockArgs.BodyByt));
                e.Send(Encoding.UTF8.GetBytes("hello world"), Encoding.UTF8.GetBytes("hello MiniSocket"));
            }
            catch (Exception ex)
            {
                Print("RecvComplete " + ex.Message);
            }
        }

        /// <summary>
        /// 发送完成事件
        /// </summary>
        /// <param name="e"></param>
        /// <param name="sock"></param>
        private static void SendComplete(Network e, SocketParas sock)
        {

        }

        /// <summary>
        /// 退出事件
        /// </summary>
        /// <param name="state"></param>
        /// <param name="msg"></param>
        private static void ExitCompleted(int state, string msg)
        {
            switch (state)
            {
                case 0: // 正常
                    break;
                case 1: // 连接异常
                    break;
                case 2: // 发送异常
                    break;
                case 3: // 接收异常
                    break;
                case 4: // 手动强制退出
                    break;
            }
        }

以上就是如何理解socket tcp开发包MiniSocket,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注亿速云行业资讯频道。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI