千家信息网

如何理解socket tcp开发包MiniSocket

发表于:2024-12-01 作者:千家信息网编辑
千家信息网最后更新 2024年12月01日,本篇文章给大家分享的是有关如何理解socket tcp开发包MiniSocket,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。MiniS
千家信息网最后更新 2024年12月01日如何理解socket tcp开发包MiniSocket

本篇文章给大家分享的是有关如何理解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);
}
}

///


/// 接收完成事件
///

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

}

///


/// 接收完成事件
///

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

///


/// 发送完成事件
///

///
///
private static void SendComplete(Network e, SocketParas sock)
{

}

///


/// 退出事件
///

///
///
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,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注行业资讯频道。

0