C#如何使用Socket實現(xiàn)服務(wù)器與多個客戶端通信
這篇文章主要介紹C#如何使用Socket實現(xiàn)服務(wù)器與多個客戶端通信，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！
成都創(chuàng)新互聯(lián)公司始終堅持【策劃先行，效果至上】的經(jīng)營理念，通過多達十年累計超上千家客戶的網(wǎng)站建設(shè)總結(jié)了一套系統(tǒng)有效的營銷推廣解決方案，現(xiàn)已廣泛運用于各行各業(yè)的客戶，其中包括：戶外休閑椅等企業(yè)，備受客戶稱贊。
擴展：由于server端是存儲了所有server與client的連接對象，因此我們是可以基于此demo的基礎(chǔ)上實現(xiàn)聊天系統(tǒng)：
* 每當一個與用戶發(fā)言時，是由server接收到的某個用戶的發(fā)言信息的，此時服務(wù)器端可以通過循環(huán)發(fā)送該用戶發(fā)送的信息給每個已經(jīng)連接連接的用戶（排除發(fā)送者）。
Server端代碼：
class Program{ //創(chuàng)建一個和客戶端通信的套接字 static Socket SocketWatch = null; //定義一個集合，存儲客戶端信息 static Dictionary<string, Socket> ClientConnectionItems = new Dictionary<string, Socket> { }; static void Main(string[] args) { //端口號（用來監(jiān)聽的） int port = 6000; //string host = "127.0.0.1"; //IPAddress ip = IPAddress.Parse(host); IPAddress ip = IPAddress.Any; //將IP地址和端口號綁定到網(wǎng)絡(luò)節(jié)點point上 IPEndPoint ipe = new IPEndPoint(ip, port); //定義一個套接字用于監(jiān)聽客戶端發(fā)來的消息，包含三個參數(shù)（IP4尋址協(xié)議，流式連接，Tcp協(xié)議） SocketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //監(jiān)聽綁定的網(wǎng)絡(luò)節(jié)點 SocketWatch.Bind(ipe); //將套接字的監(jiān)聽隊列長度限制為20 SocketWatch.Listen(20); //負責監(jiān)聽客戶端的線程:創(chuàng)建一個監(jiān)聽線程 Thread threadwatch = new Thread(WatchConnecting); //將窗體線程設(shè)置為與后臺同步，隨著主線程結(jié)束而結(jié)束 threadwatch.IsBackground = true; //啟動線程 threadwatch.Start(); Console.WriteLine("開啟監(jiān)聽......"); Console.WriteLine("點擊輸入任意數(shù)據(jù)回車退出程序......"); Console.ReadKey(); SocketWatch.Close(); //Socket serverSocket = null; //int i=1; //while (true) //{ // //receive message // serverSocket = SocketWatch.Accept(); // Console.WriteLine("連接已經(jīng)建立！"); // string recStr = ""; // byte[] recByte = new byte[4096]; // int bytes = serverSocket.Receive(recByte, recByte.Length, 0); // //recStr += Encoding.ASCII.GetString(recByte, 0, bytes); // recStr += Encoding.GetEncoding("utf-8").GetString(recByte, 0, bytes); // //send message // Console.WriteLine(recStr); // Console.Write("請輸入內(nèi)容："); // string sendStr = Console.ReadLine(); // //byte[] sendByte = Encoding.ASCII.GetBytes(sendStr); // byte[] sendByte = Encoding.GetEncoding("utf-8").GetBytes(sendStr); // //Thread.Sleep(4000); // serverSocket.Send(sendByte, sendByte.Length, 0); // serverSocket.Close(); // if (i >= 100) // { // break; // } // i++; //} //sSocket.Close(); //Console.WriteLine("連接關(guān)閉！"); //Console.ReadLine(); } //監(jiān)聽客戶端發(fā)來的請求 static void WatchConnecting() { Socket connection = null; //持續(xù)不斷監(jiān)聽客戶端發(fā)來的請求 while (true) { try { connection = SocketWatch.Accept(); } catch (Exception ex) { //提示套接字監(jiān)聽異常 Console.WriteLine(ex.Message); break; } //客戶端網(wǎng)絡(luò)結(jié)點號 string remoteEndPoint = connection.RemoteEndPoint.ToString(); //添加客戶端信息 ClientConnectionItems.Add(remoteEndPoint, connection); //顯示與客戶端連接情況 Console.WriteLine("\r\n[客戶端\"" + remoteEndPoint + "\"建立連接成功！ 客戶端數(shù)量：" + ClientConnectionItems .Count+ "]"); //獲取客戶端的IP和端口號 IPAddress clientIP = (connection.RemoteEndPoint as IPEndPoint).Address; int clientPort = (connection.RemoteEndPoint as IPEndPoint).Port; //讓客戶顯示"連接成功的"的信息 string sendmsg = "[" + "本地IP：" + clientIP + " 本地端口：" + clientPort.ToString() + " 連接服務(wù)端成功！]"; byte[] arrSendMsg = Encoding.UTF8.GetBytes(sendmsg); connection.Send(arrSendMsg); //創(chuàng)建一個通信線程 Thread thread = new Thread(recv); //設(shè)置為后臺線程，隨著主線程退出而退出 thread.IsBackground = true; //啟動線程 thread.Start(connection); } } /// <summary> /// 接收客戶端發(fā)來的信息，客戶端套接字對象 /// </summary> /// <param name="socketclientpara"></param> static void recv(object socketclientpara) { Socket socketServer = socketclientpara as Socket; while (true) { //創(chuàng)建一個內(nèi)存緩沖區(qū)，其大小為1024*1024字節(jié) 即1M byte[] arrServerRecMsg = new byte[1024 * 1024]; //將接收到的信息存入到內(nèi)存緩沖區(qū)，并返回其字節(jié)數(shù)組的長度 try { int length = socketServer.Receive(arrServerRecMsg); //將機器接受到的字節(jié)數(shù)組轉(zhuǎn)換為人可以讀懂的字符串 string strSRecMsg = Encoding.UTF8.GetString(arrServerRecMsg, 0, length); //將發(fā)送的字符串信息附加到文本框txtMsg上 Console.WriteLine("\r\n[客戶端：" + socketServer.RemoteEndPoint + " 時間：" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")+ "]\r\n" + strSRecMsg); //Thread.Sleep(3000); //socketServer.Send(Encoding.UTF8.GetBytes("[" + socketServer.RemoteEndPoint + "]："+strSRecMsg)); //發(fā)送客戶端數(shù)據(jù) if (ClientConnectionItems.Count > 0) { foreach (var socketTemp in ClientConnectionItems) { socketTemp.Value.Send(Encoding.UTF8.GetBytes("[" + socketServer.RemoteEndPoint + "]：" + strSRecMsg)); } } } catch (Exception) { ClientConnectionItems.Remove(socketServer.RemoteEndPoint.ToString()); //提示套接字監(jiān)聽異常 Console.WriteLine("\r\n[客戶端\"" + socketServer.RemoteEndPoint + "\"已經(jīng)中斷連接！ 客戶端數(shù)量：" + ClientConnectionItems.Count+"]"); //關(guān)閉之前accept出來的和客戶端進行通信的套接字 socketServer.Close(); break; } } }}Client端代碼：
class Program{ //創(chuàng)建1個客戶端套接字和1個負責監(jiān)聽服務(wù)端請求的線程 static Thread ThreadClient = null; static Socket SocketClient = null; static void Main(string[] args) { try { int port = 6000; string host = "127.0.0.1";//服務(wù)器端ip地址 IPAddress ip = IPAddress.Parse(host); IPEndPoint ipe = new IPEndPoint(ip, port); //定義一個套接字監(jiān)聽 SocketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); try { //客戶端套接字連接到網(wǎng)絡(luò)節(jié)點上，用的是Connect SocketClient.Connect(ipe); } catch (Exception) { Console.WriteLine("連接失??！\r\n"); Console.ReadLine(); return; } ThreadClient = new Thread(Recv); ThreadClient.IsBackground = true; ThreadClient.Start(); Thread.Sleep(1000); Console.WriteLine("請輸入內(nèi)容<按Enter鍵發(fā)送>：\r\n"); while(true) { string sendStr = Console.ReadLine(); ClientSendMsg(sendStr); } //int i = 1; //while (true) //{ // Console.Write("請輸入內(nèi)容："); // string sendStr = Console.ReadLine(); // Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); // clientSocket.Connect(ipe); // //send message // //byte[] sendBytes = Encoding.ASCII.GetBytes(sendStr); // byte[] sendBytes = Encoding.GetEncoding("utf-8").GetBytes(sendStr); // //Thread.Sleep(4000); // clientSocket.Send(sendBytes); // //receive message // string recStr = ""; // byte[] recBytes = new byte[4096]; // int bytes = clientSocket.Receive(recBytes, recBytes.Length, 0); // //recStr += Encoding.ASCII.GetString(recBytes, 0, bytes); // recStr += Encoding.GetEncoding("utf-8").GetString(recBytes, 0, bytes); // Console.WriteLine(recStr); // clientSocket.Close(); // if (i >= 100) // { // break; // } // i++; //} //Console.ReadLine(); //return; //string result = String.Empty; } catch (Exception ex) { Console.WriteLine(ex.Message); Console.ReadLine(); } } //接收服務(wù)端發(fā)來信息的方法 public static void Recv() { int x = 0; //持續(xù)監(jiān)聽服務(wù)端發(fā)來的消息 while (true) { try { //定義一個1M的內(nèi)存緩沖區(qū)，用于臨時性存儲接收到的消息 byte[] arrRecvmsg = new byte[1024 * 1024]; //將客戶端套接字接收到的數(shù)據(jù)存入內(nèi)存緩沖區(qū)，并獲取長度 int length = SocketClient.Receive(arrRecvmsg); //將套接字獲取到的字符數(shù)組轉(zhuǎn)換為人可以看懂的字符串 string strRevMsg = Encoding.UTF8.GetString(arrRecvmsg, 0, length); if (x == 1) { Console.WriteLine("\r\n服務(wù)器：" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff") + "\r\n" + strRevMsg+"\r\n"); } else { Console.WriteLine(strRevMsg + "\r\n"); x = 1; } } catch (Exception ex) { Console.WriteLine("遠程服務(wù)器已經(jīng)中斷連接！" + ex.Message + "\r\n"); break; } } } //發(fā)送字符信息到服務(wù)端的方法 public static void ClientSendMsg(string sendMsg) { //將輸入的內(nèi)容字符串轉(zhuǎn)換為機器可以識別的字節(jié)數(shù)組 byte[] arrClientSendMsg = Encoding.UTF8.GetBytes(sendMsg); //調(diào)用客戶端套接字發(fā)送字節(jié)數(shù)組 SocketClient.Send(arrClientSendMsg); } }以上是“C#如何使用Socket實現(xiàn)服務(wù)器與多個客戶端通信”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對大家有幫助，更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！
新聞標題：C#如何使用Socket實現(xiàn)服務(wù)器與多個客戶端通信
當前URL：http://www.muchs.cn/article6/ihpeog.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供關(guān)鍵詞優(yōu)化、網(wǎng)頁設(shè)計公司、App開發(fā)、自適應(yīng)網(wǎng)站、移動網(wǎng)站建設(shè)、品牌網(wǎng)站建設(shè)
聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)
