c#tcp多線程伺服器實例代碼

来源:http://www.cnblogs.com/liyu3519/archive/2017/05/22/6889076.html
-Advertisement-
Play Games

using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;u ...


using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;

using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Diagnostics;
using System.Net.NetworkInformation;

namespace 黃炎培_伺服器
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}

/// <summary>
/// 伺服器傾聽客戶端連接線程
/// </summary>
Thread threadWatchs = null;

/// <summary>
/// 伺服器套接字
/// </summary>
Socket socketServer = null;

/// <summary>
/// 伺服器監控客戶端連接情況的線程
/// </summary>
Thread MonitoThread = null;

/// <summary>
/// 客戶端ip與套接字的集合
/// </summary>
Dictionary<string, Socket> dictSocket = new Dictionary<string, Socket>();

/// <summary>
/// 客戶端ip與線程的集合
/// </summary>
Dictionary<string, Thread> dictThread = new Dictionary<string, Thread>();

/// <summary>
/// 客戶端連接線程的數量
/// </summary>
long numThreadVal = 0;

/// <summary>
/// 伺服器ip
/// </summary>
string strServerIP = "192.168.4.3";

/// <summary>
/// 伺服器埠
/// </summary>
int serverPort = 8080;

/// <summary>
/// 緩存數據長度
/// </summary>
int receiveDataValLengt = 1024;//緩存區長度

/// <summary>
/// 用於Ping客戶端
/// </summary>
Ping monitoPing = new Ping();

/// <summary>
/// 異常斷開的客戶端
/// </summary>
Dictionary<string, string> dictBodClient = new Dictionary<string, string>();

/// <summary>
/// 指示釋放釋放線程
/// </summary>
bool isClearThread = false;

ulong numDataFlow;

private void Form1_Load(object sender, EventArgs e)
{
//開啟伺服器
openServer(strServerIP, serverPort);
//開啟伺服器監控線程
MonitoThread = new Thread(monitoThreadsDynamic);
//後臺線程
MonitoThread.IsBackground = true;
//啟動線程
MonitoThread.Start();
}

/// <summary>
/// 開始實時監控客戶端的連接情況
/// </summary>
void monitoThreadsDynamic()
{
delegateShowMseeage("開始實時監控客戶端連接情況");
while (true)
{
Thread.Sleep(3000);
try
{
foreach (var vv in dictSocket)
{
PingReply reply = monitoPing.Send(vv.Key.Split(':')[0],1000);
//如果Ping通
if (reply.Status == IPStatus.Success)
{
//表示客戶端連接正常
delegateShowMseeage("客戶端" + vv.Key + "連接正常");
}
else
{
delegateShowMseeage("客戶端" + vv.Key + "連接異常");
//添加異常客戶端連接到集合dictBodClient
dictBodClient.Add(vv.Key, "old");

}
}

//釋放異常連接的線程
foreach (var vvv in dictThread)
{
isClearThread = false;
foreach (var vvvv in dictBodClient)
{
if (vvv.Key == vvvv.Key)
{
isClearThread = true;
break;
}
}
if (isClearThread)
{
vvv.Value.Abort();
delegateShowMseeage("客戶端" + vvv.Key + "占用的線程已釋放");
}
}

//從集合合中移除異常連接的客戶端
foreach (var vvv in dictBodClient)
{
//從集合中移除客戶端套接字
dictSocket.Remove(vvv.Key);
//從集合中移除客戶端線程
dictThread.Remove(vvv.Key);
//從列表中移除客戶端套接字的遠程終結點
deleteClientSocket(vvv.Key);
//跨線程顯示提示數據
delegateShowMseeage("客戶端" + vvv.Key + "斷開連接");
}
}
catch (Exception se)
{
//MessageBox.Show(se.Message);
delegateShowMseeage(se.Message);
}

dictBodClient.Clear();
//獲得當前程式運行的線程總數量
numThreadVal = Process.GetCurrentProcess().Threads.Count;
delegateShowMseeage("當前的線程總數量為：" + numThreadVal);
//獲得客戶端連接所占用的線程數量
numThreadVal = dictThread.LongCount();
//跨線程顯示消息
delegateShowMseeage("其中客戶端連接的線程數量為：" + numThreadVal);
}
}

/// <summary>
/// 開啟伺服器
/// </summary>
/// <param name="serverIP"></param>
/// <param name="serverPort"></param>
void openServer(string serverIP, int serverPort)
{
//實例化伺服器套接字
socketServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//配置網路端點
IPEndPoint ipAndPort = new IPEndPoint(IPAddress.Parse(serverIP), serverPort);
try
{
//設置伺服器套接字的連接參數
socketServer.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
//將網路端點綁定到伺服器套接字
socketServer.Bind(ipAndPort);
}
catch (SocketException se)
{
MessageBox.Show("異常：" + se.Message);
return;
}
//伺服器開始傾聽，指定最多客戶端數量為10000
socketServer.Listen(10000);
//實例化伺服器傾聽客戶端連接的線程
threadWatchs = new Thread(WatchClientConnecting);
//後臺運行線程
threadWatchs.IsBackground = true;
//啟動線程
threadWatchs.Start();
//顯示提示消息
showMesssge("伺服器啟動成功");
}

/// <summary>
/// 開始傾聽客戶端
/// </summary>
void WatchClientConnecting()
{
//跨線程顯示提示消息
delegateShowMseeage("伺服器開始傾聽客戶端連接");
while (true)
{
//傾聽新的客戶端連接請求
Socket newClientConnecting = socketServer.Accept();
//添加客戶端套接字的遠程終結點到列表
addClientSocket(newClientConnecting.RemoteEndPoint.ToString());
//新建一條新的客戶端線程
Thread newClinetThread = new Thread(receiveData);
//後臺運行客戶端
newClinetThread.IsBackground = true;
//啟動線程，並將 新客戶端的套接字 綁定到線程執行的方法
newClinetThread.Start(newClientConnecting);
//添加客戶端套接字到集合
dictSocket.Add(newClientConnecting.RemoteEndPoint.ToString(), newClientConnecting);
//添加客戶端接受數據的線程到集合
dictThread.Add(newClientConnecting.RemoteEndPoint.ToString(), newClinetThread);
//跨線程顯示提示信息
delegateShowMseeage("新客戶端：" + newClientConnecting.RemoteEndPoint.ToString());
}
}

/// <summary>
/// 接受數據
/// </summary>
/// <param name="socketConnecting"></param>
void receiveData(object socketConnecting)
{
//獲取該線程綁定的客戶端套接字
Socket socketClient = socketConnecting as Socket;
while (true)
{
//新建一個緩存區
byte[] receiveDataVal = new byte[receiveDataValLengt];
//數據長度
int receiveDataLength = -1;
try
{
//接受數據填入緩存區並獲得數據長度
receiveDataLength = socketClient.Receive(receiveDataVal);
//接受到數據
if (receiveDataLength > 0)
{
//跨線程顯示接受到的數據
delegateShowReceiveData(socketClient, receiveDataVal, receiveDataLength);
//綜合處理接受到的數據
receiveDataIntegratedProcessing(receiveDataVal, receiveDataLength);
numDataFlow += (uint)receiveDataLength;
showDataFlow();
}
else
{
//從集合中移除客戶端套接字
dictSocket.Remove(socketClient.RemoteEndPoint.ToString());
//從集合中移除客戶端線程
dictThread.Remove(socketClient.RemoteEndPoint.ToString());
//從列表中移除客戶端套接字的遠程終結點
deleteClientSocket(socketClient.RemoteEndPoint.ToString());
//跨線程顯示提示數據
delegateShowMseeage("客戶端" + socketClient.RemoteEndPoint.ToString() + "斷開連接");
//釋放該線程
return;
}
}
catch
{
//從集合中移除客戶端套接字
dictSocket.Remove(socketClient.RemoteEndPoint.ToString());
//從集合中移除客戶端線程
dictThread.Remove(socketClient.RemoteEndPoint.ToString());
//從列表中移除客戶端套接字的遠程終結點
deleteClientSocket(socketClient.RemoteEndPoint.ToString());
//跨線程顯示提示數據
delegateShowMseeage("異常:" + "客戶端" + socketClient.RemoteEndPoint.ToString() + "斷開連接");
//釋放該線程
return;
}
}
}

/// <summary>
/// 綜合處理接受到的數據
/// </summary>
/// <param name="datas"></param>
/// <param name="length"></param>
void receiveDataIntegratedProcessing(byte[] datas, int length)
{
//if (length == 5)
//{
// if (datas[0] == 0x11 && datas[4] == 0x11)
// {
// foreach (var clients in dictSocket)
// {
// newOneThreadSendDataToClient(clients.Value, datas, length);
// }
// }
// else if (datas[0] == 0x12 && datas[4] == 0x12)
// {
// foreach (var clients in dictSocket)
// {
// newOneThreadSendDataToClient(clients.Value, datas, length);
// }
// }
//}

//*******************************************************************
//將接受的數據發送給所有客戶端
//*******************************************************************
//遍歷客戶端套接字的集合
foreach (var clients in dictSocket)
{
//新建一條線程發送數據到客戶端
newOneThreadSendDataToClient(clients.Value, datas, length);
}
}

void newOneThreadSendDataToClient(Socket clientSocket, byte[] datas, int length)
{
//跨線程顯示提示消息
delegateShowMseeage("新建一條線程準備開始發送數據");
//新建發送數據的參數模型
dataSendArgsMode sendDataArgs = new dataSendArgsMode();
//將客戶端套接字綁定到模型
sendDataArgs.sockets = clientSocket;
//將數據綁定到模型
sendDataArgs.datas = datas;
//將數據長度綁定到模型
sendDataArgs.length = length;
//新建發送數據到客戶端的線程
Thread threadSendDataToClient = new Thread(sendDataToClient);
//後臺運行線程
threadSendDataToClient.IsBackground = true;
//啟動線程，並將 發送數據的參數模型 綁定到線程執行的方法
threadSendDataToClient.Start(sendDataArgs);


}

/// <summary>
/// 發送數據到客戶端
/// </summary>
/// <param name="obj"></param>
void sendDataToClient(object obj)
{
//獲取用於發送數據的參數模型
dataSendArgsMode args = obj as dataSendArgsMode;

try
{
//從數據參數模型中提取數據發送到模型中的客戶端
args.sockets.Send(args.datas, 0, args.length, SocketFlags.None);
//跨線程顯示提示消息
delegateShowMseeage("數據：" + getStringFormByte(args.datas, args.length) + "發送到了客戶端:" + args.sockets.RemoteEndPoint.ToString());
delegateShowMseeage("數據發送完畢，關閉線程");
//釋放該線程
numDataFlow += (uint)args.length;
showDataFlow();
return;
}
catch
{
//從集合中移除客戶端套接字
dictSocket.Remove(args.sockets.RemoteEndPoint.ToString());
//從集合中移除客戶端線程
dictThread.Remove(args.sockets.RemoteEndPoint.ToString());
//從列表中移除客戶端套接字的遠程終結點
deleteClientSocket(args.sockets.RemoteEndPoint.ToString());
//跨線程顯示提示消息
delegateShowMseeage("異常:" + "客戶端" + args.sockets.RemoteEndPoint.ToString() + "斷開連接" + ",關閉該線程");
//釋放該線程
return;
}

}

/// <summary>
/// 從列表中刪除客戶端
/// </summary>
/// <param name="socket"></param>
void deleteClientSocket(string strClientSocket)
{
//封裝一個方法進行委托
Action<string> actionDelegate = (x) =>
{
//從列表中移除指定客戶端套接字的遠程終結點
lbOnlineClient.Items.Remove(x.ToString());
};
//將參數委托到指定方法執行
txtMessage.Invoke(actionDelegate, strClientSocket);
}

/// <summary>
/// 添加客戶端到列表
/// </summary>
/// <param name="clientSocket"></param>
void addClientSocket(string strClientSocket)
{
//封裝一個方法進行委托
Action<string> actionDelegate = (x) =>
{
//向列表中添加指定客戶端套接字的遠程終結點
lbOnlineClient.Items.Add(x.ToString());
};
//將參數委托到指定方法執行
txtMessage.Invoke(actionDelegate, strClientSocket);
}

/// <summary>
/// 跨線程顯示接受到的數據
/// </summary>
/// <param name="socket"></param>
/// <param name="datas"></param>
/// <param name="length"></param>
void delegateShowReceiveData(Socket socket, Byte[] datas, int length)
{
//封裝一個方法進行委托
Action<string> actionDelegate = (x) =>
{
//向文本框追加文本
txtMessage.AppendText(System.DateTime.Now.ToString()+ " -> "+ x.ToString() + "\r\n");
txtMessage.ScrollToCaret();
};
//將參數委托到指定方法執行
txtMessage.Invoke(actionDelegate, "收到來自 " + socket.RemoteEndPoint.ToString() + " 的數據：" + getStringFormByte(datas, length));
}


/// <summary>
/// 跨線程顯示數據
/// </summary>
/// <param name="message"></param>
void delegateShowMseeage(string message)
{
//封裝一個方法進行委托
Action<string> actionDelegate = (x) =>
{
if (txtMessage.Text.Length > 2000000)
txtMessage.Text = string.Empty;
//向文本框追加文本
txtMessage.AppendText(System.DateTime.Now.ToString()+" -> " + x.ToString() + "\r\n");
txtMessage.ScrollToCaret();
};
//將參數委托到指定方法執行
txtMessage.Invoke(actionDelegate, message);

}

/// <summary>
/// 顯示數據流量
/// </summary>
void showDataFlow()
{
//封裝一個方法進行委托
Action<string> actionDelegateShowFlow = (x) =>
{
lblDataFlow.Text = x.ToString();
};
//將參數委托到指定方法執行
lblDataFlow.Invoke(actionDelegateShowFlow, numDataFlow.ToString());
}

/// <summary>
/// 顯示數據
/// </summary>
/// <param name="message"></param>
void showMesssge(string message)
{
//向文本框追加文本
txtMessage.AppendText(System.DateTime.Now.ToString() + " -> " + message + "\r\n");
txtMessage.ScrollToCaret();
}


/// <summary>
/// 16進位的字元串形式
/// </summary>
/// <param name="data"></param>
/// <param name="length"></param>
/// <returns></returns>
string getStringFormByte(byte[] data, int length)
{
string str = "";
for (int i = 0; i < length; i++)
{
str += data[i].ToString("X").PadLeft(2, '0') + ' ';
}
return str;
}
}

/// <summary>
/// 發送數據的參數
/// </summary>
class dataSendArgsMode
{
/// <summary>
/// 套接字
/// </summary>
public Socket sockets;

/// <summary>
/// 數據
/// </summary>
public byte[] datas;

/// <summary>
/// 長度
/// </summary>
public int length;
}
}


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • C# 關於操作datatable的列名和刪除某一列的數據
    1.獲取一個數據集表 DataTable dt = selectDEGS(type, words, KUser); 2.刪除某一列 dt.Columns.Remove("TaskID");//TaskID為列名稱 3.替換某一列名稱 dt.Columns["TaskState"].ColumnNam ...
  • 微服務框架下的思維變化-OSS.Core基礎思路
    如今框架兩字已經爛大街了，xx公司架構設計隨處可見，不過大多看個熱鬧，這些框架如何來的，細節又是如何思考的，相互之間的隔離依據又是什麼...相信很多朋友應該依然存在自己的疑惑，特別是越來越火熱的微服務以及衍生的微服務網關產品，正好最近打算寫一個小開源框架OSS.Core，過程中有一點思考，通過這篇文 ...
  • c# .net core 下的網路請求
    本文章是在VS2017的環境下，.net core 1.1版本以上。 在這期間，由於.net core 並不基於IIS，我們的過去的網路請求代碼在.net core框架下，有可能會出現不相容，報錯的現象。這裡大致介紹下在.net core 下如何進行http請求，主要仍然是GET和POST方法，有錯 ...
  • 輕量級的.NET對象查找服務和AOP開發框架Netop.Core源碼解說(5)--其它
    Netop.Core主要提供的服務是類工廠服務及AOP服務，當然還其它一些小服務： 一、對話上下文Netop.Core.Context.SessionContext 此對話上下文可用在桌面程式和ASP.NET程式，可用SetData和GetData在上下文中傳遞數據。方法有： public stat ...
  • Quartz.NET
    參考文章：http://www.cnblogs.com/zhuyongblogs/p/5752638.html http://www.cnblogs.com/knowledgesea/p/5145239.html ...
  • Quartz.net 定時任務之簡單任務
    一、概述 1、quartz.net 是一款從java quartz 上延伸出來的定時任務框架。 2、我在網上看到很多大神寫過關於quartz.net 的博客、文章等，在這些博客文章里也學會了很多關於quartz的知識。今天博主也想寫一篇關於quartz的文章（不足之處望大神斧正），希望能幫助正在學習 ...
  • log4net 獨立配置文件設置
    1. 新建一個配置文件log4net.config,配置方法同成web.config或app.config一致; <?xml version="1.0" encoding="utf-8"?><configuration> <configSections> <section name="log4net ...
  • .net 企業管理系統快速搭建框架
    簡言 本人在博客園註冊也2年多了，一直沒有寫自己的博客，因為才疏學淺一直跟著園子里的大哥們學習這.net技術。一年之前跳槽到現在的公司工作，由於公司沒有自己一套的開發框架，每次都要重新搭建，於是本人就用業餘時間寫了一個簡單開發框架，我也不知道叫“框架”是否符合，大家對付著看吧，希望可以幫助一些新人學 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類