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
  • WPF 已知問題 監聽 WMI 事件導致觸摸失效
    示例項目結構 在 Visual Studio 中創建一個 WinForms 應用程式後，項目結構如下所示： MyWinFormsApp/ │ ├───Properties/ │ └───Settings.settings │ ├───bin/ │ ├───Debug/ │ └───Release/ ...
  • [STAThread]特性
    [STAThread] 特性用於需要與 COM 組件交互的應用程式，尤其是依賴單線程模型（如 Windows Forms 應用程式）的組件。在 STA 模式下，線程擁有自己的消息迴圈，這對於處理用戶界面和某些 COM 組件是必要的。 [STAThread] static void Main(stri ...
  • UWP WinUI3 傳入 AddHandler 的 RoutedEventHandler 類型與事件所需不匹配將拋出參數異常
    在WinForm中使用全局異常捕獲處理 在WinForm應用程式中，全局異常捕獲是確保程式穩定性的關鍵。通過在Program類的Main方法中設置全局異常處理，可以有效地捕獲並處理未預見的異常，從而避免程式崩潰。 註冊全局異常事件 [STAThread] static void Main() { / ...
  • .NET 多版本 WinForm 開源控制項庫 SunnyUI
    前言 給大家推薦一款開源的 Winform 控制項庫，可以幫助我們開發更加美觀、漂亮的 WinForm 界面。 項目介紹 SunnyUI.NET 是一個基於 .NET Framework 4.0+、.NET 6、.NET 7 和 .NET 8 的 WinForm 開源控制項庫，同時也提供了工具類庫、擴展 ...
  • .net core8 使用Swagger（附當前源碼）
    說明 該文章是屬於OverallAuth2.0系列文章，每周更新一篇該系列文章（從0到1完成系統開發）。 該系統文章，我會儘量說的非常詳細，做到不管新手、老手都能看懂。 說明：OverallAuth2.0 是一個簡單、易懂、功能強大的許可權+可視化流程管理系統。 有興趣的朋友，請關註我吧(*^▽^*) ...
  • WPF 什麼時候 VisualTreeHelper.GetDescendantBounds 將返回無窮大
    一、下載安裝 1.下載git 必須先下載並安裝git，再TortoiseGit下載安裝 git安裝參考教程：https://blog.csdn.net/mukes/article/details/115693833 2.TortoiseGit下載與安裝 TortoiseGit，Git客戶端，32/6 ...
  • C# 開源教程帶你輕鬆掌握數據結構與演算法
    前言 在項目開發過程中，理解數據結構和演算法如同掌握蓋房子的秘訣。演算法不僅能幫助我們編寫高效、優質的代碼，還能解決項目中遇到的各種難題。 給大家推薦一個支持C#的開源免費、新手友好的數據結構與演算法入門教程：Hello演算法。 項目介紹 《Hello Algo》是一本開源免費、新手友好的數據結構與演算法入門 ...
  • 第22篇 生成proto文件bat腳本
    1.生成單個Proto.bat內容 @rem Copyright 2016, Google Inc. @rem All rights reserved. @rem @rem Redistribution and use in source and binary forms, with or with ...
  • 記一次 .NET某上位機視覺程式 卡死分析
    一：背景 1. 講故事 前段時間有位朋友找到我，說他的窗體程式在客戶這邊出現了卡死，讓我幫忙看下怎麼回事？dump也生成了，既然有dump了那就上 windbg 分析吧。 二：WinDbg 分析 1. 為什麼會卡死 窗體程式的卡死，入口門檻很低，後續往下分析就不一定了，不管怎麼說先用 !clrsta ...
  • 醫學DICOM文件與PACS系統進行數據傳輸
    前言 人工智慧時代，人臉識別技術已成為安全驗證、身份識別和用戶交互的關鍵工具。 給大家推薦一款.NET 開源提供了強大的人臉識別 API，工具不僅易於集成，還具備高效處理能力。 本文將介紹一款如何利用這些API，為我們的項目添加智能識別的亮點。 項目介紹 GitHub 上擁有 1.2k 星標的 C# ...
所有分類