MiniSocket 采用socket tcp方式通訊，自動處理分包合并，性能高，使用簡單，非常容易進行二次開發
https://blog.csdn.net/weixin_45785782/article/details/102694934
uj5u.com熱心網友回復：
服務端使用：打開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;
}
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/106050.html
標籤：C#
上一篇：關于static的使用