C#利用伺服器實現客戶端之間通信

来源:http://www.cnblogs.com/sylvialucy/archive/2016/08/04/5736862.html
-Advertisement-
Play Games

這兩天在學習C#,C#高級編程真的是厚厚的一本書QAQ。 昨天看了一下裡面的通信部分(其實還沒怎麼看),看了網上一些人的博客,自己在他們的博客基礎上寫了一個通信。 先來講述下我自己對於整個Socket通信過程的理解,畢竟初學,說錯見諒,知道錯了會改正~ 首先在服務端新建一個serverSocket, ...


這兩天在學習C#,C#高級編程真的是厚厚的一本書QAQ。

昨天看了一下裡面的通信部分(其實還沒怎麼看),看了網上一些人的博客,自己在他們的博客基礎上寫了一個通信。

先來講述下我自己對於整個Socket通信過程的理解,畢竟初學,說錯見諒,知道錯了會改正~

首先在服務端新建一個serverSocket,對其進行初始化(一般包含AddressFamily:IP地址類型,SocketType:Socket傳輸數據方式,ProtoType:傳輸協議);

接著我們要設置server端要綁定的IP:port;然後開始監聽,並設置最多同時監聽多少個Client.

 

這時,服務端就在等待狀態,直到某一個Client連接到這個ip:port上,這時serverSocket.Accept()工作,獲得這個連接。(此時的連接是有地址信息的哦!記得保存)

獲得連接之後,server就可以和這個Client進行通信了,當加入第二個Client(我們稱其為ClientB)時,Server接收到ClientB的消息,可以將這個消息轉發給前一個Client(我們稱其為ClientA),當受到ClientA的消息,也可以轉發給ClientB。這樣就實現了Clients之間的通信了。(重點在保存連接信息!!

 

那麼現在貼上代碼講解:

Server端代碼

  1 namespace SocketServer
  2 {
  3     class Program
  4     {
  5         private static byte[] result = new byte[1024];
  6       
  7         static Socket serverSocket;
  8         private static string client;
  9         private static Socket clientSocket;
 10         //我這裡存了兩個Client,因為自己電腦開了兩個Client,不會有多的
 11         //理論上應該開一個Socket[]來保存信息,最好用一個二元組將client的信息和連接綁定起來
 12         //這樣就可以實現斷開連接後下次登陸還是可以識別是這個Client
 13         private static Socket clientSocketA=null;
 14         private static Socket clientSocketB=null;
 15         
 16         static void Main(string[] args)
 17         {
 18             Program.SetPort(8885);
 19         }
 20         private static void SetPort(int port)
 21         {
 22             IPAddress ip = IPAddress.Parse("127.0.0.1");//set ip
 23             serverSocket = new Socket(AddressFamily.InterNetwork,
 24                 SocketType.Stream, ProtocolType.Tcp);//initialize
 25             serverSocket.Bind(new IPEndPoint(ip, port));//bind
 26             serverSocket.Listen(10);
 27             //進入監聽狀態
 28             Console.WriteLine("監聽{0}成功", serverSocket.LocalEndPoint.ToString());
 29             //開啟一個線程來監聽客戶端連接
 30             Thread myThread = new Thread(ListenClientConnect);
 31             myThread.Start();
 32             Console.ReadLine();
 33 
 34         }
 35         /// <summary>
 36         /// 監聽客戶端連接
 37         /// </summary>
 38         private static void ListenClientConnect()
 39         {
 40             while (true)
 41             {
 42                 //Client連接上後 得到這個連接
 43                 clientSocket = serverSocket.Accept();
 44 
 45                 //這裡我因為只有兩個Client,所以就簡單寫了
 46                 if (clientSocketA == null)
 47                 {
 48                     clientSocketA = clientSocket;
 49                 }
 50                 else if (clientSocketB == null)
 51                 {
 52                     clientSocketB = clientSocket;
 53                 }
 54                 else
 55                 {
 56                     //當其中一個斷開了,又重新連接時,需要再次保存連接
 57                     if (clientSocketB.IsBound)
 58                     {
 59                         clientSocketA = clientSocketB;
 60                         clientSocketB = clientSocket;
 61                     }
 62                     else
 63                     {
 64                         clientSocketB = clientSocketA;
 65                         clientSocketA = clientSocket;
 66                     }
 67                     
 68                 }
 69                 clientSocket.Send(Encoding.ASCII.GetBytes("say hello"));
 70                 //開個線程接收Client信息
 71                 Thread receivedThread = new Thread(ReceiveMessage);
 72                 receivedThread.Start(clientSocket);
 73 
 74             }
 75         }
 76      
 77         private static void ReceiveMessage(object clientSocket)
 78         {
 79             Socket myClientSocket = (Socket) clientSocket;
 80             
 81             while (true)
 82             {
 83                 try
 84                 {
 85                     int revceiveNumber = myClientSocket.Receive(result);
 86                     //Console.WriteLine("接受客戶端{0}消息{1}", myClientSocket.RemoteEndPoint.ToString()
 87                     //    , Encoding.ASCII.GetString(result, 0, revceiveNumber));
 88                     Console.WriteLine(Encoding.ASCII.GetString(result, 0, revceiveNumber));
 89                     if (myClientSocket == clientSocketA)
 90                     {
 91                         Console.WriteLine("receive from A");
 92                         if (clientSocketB!=null&&clientSocketB.IsBound)
 93                         {
 94                             Console.WriteLine("a IS BOUND");
 95                             clientSocketB.Send(result, 0, revceiveNumber, SocketFlags.None);
 96                         }
 97                         else
 98                         {
 99                             myClientSocket.Send(Encoding.ASCII.GetBytes("the people is not online! Send Failed!"));
100                             Console.WriteLine("對方不線上上,發送失敗!");
101                         }
102                     }
103                     else
104                     {
105                         Console.WriteLine("receive from B");
106                         if (clientSocketA != null && clientSocketA.IsBound)
107                         {
108                             Console.WriteLine("a IS BOUND");
109                             clientSocketA.Send(result, 0, revceiveNumber, SocketFlags.None);
110                         }   
111                         else
112                         {
113                             myClientSocket.Send(Encoding.ASCII.GetBytes("the people is not online! Send Failed!"));
114                             Console.WriteLine("對方不線上上,發送失敗!");
115                         }
116 
117                     }
118                     
119                 }
120                 catch(Exception ex)
121                 {
122                     Console.WriteLine(ex.Message);
123                     myClientSocket.Shutdown(SocketShutdown.Both);
124                     myClientSocket.Close();
125                     break;
126 
127                 }
128             }
129 
130         }
131     }
132 }

Client端代碼(因為都差不多 就只貼一個了)

 1 namespace SocketClient
 2 {
 3     class Program
 4     {
 5         private static byte[] result = new byte[1024];
 6         private static Socket clientSocket;
 7         private static void ListenServer()
 8         {
 9             while (true)
10             {
11                 result = new byte[1024];
12                 int receiveLength = clientSocket.Receive(result);
13                 
14                 Console.WriteLine("{0}", Encoding.ASCII.GetString(result, 0, receiveLength));
15             }
16            
17         }
18         static void Main(string[] args)
19         {
20 
21             IPAddress ip = IPAddress.Parse("127.0.0.1");
22             clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
23             try
24             {
25                 clientSocket.Connect(ip, 8885);
26                 Console.WriteLine("連接成功!");
27 
28             }
29             catch (Exception e)
30             {
31                 Console.WriteLine("連接失敗!");
32                 return;
33             }
34             Thread threadRead = new Thread(ListenServer);
35             threadRead.Start();
36            
37 
38             while(true)
39             {
40                 try
41                 {
42                     Thread.Sleep(1000);
43                     string sendMessage = Console.ReadLine();
44                     clientSocket.Send(Encoding.ASCII.GetBytes("Sylvia:"+sendMessage));
45                     
46                 }
47                 catch (Exception ex)
48                 {
49                     clientSocket.Shutdown(SocketShutdown.Both);
50                     clientSocket.Close();
51                     break;
52                 }
53 
54             }
55             Console.WriteLine("發送完畢 按回車退出");
56             Console.ReadKey();
57         }
58     }
59 }

 

寫的時候要特別註意一下Send信息的時候,註意byte[]的傳輸大小,很容易變成byte[]數組的大小而不是內容的大小。

這個大家就自己嘗試吧


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

-Advertisement-
Play Games
更多相關文章
  • 1.Hibernate框架簡述 Hibernate的核心組件在基於MVC設計模式的JAVA WEB應用中,Hibernate可以作為模型層/數據訪問層。它通過配置文件(hibernate.properties或hibernate.cfg.xml)和映射文件(***.hbm.xml)把JAVA對象或P ...
  • 一、Jenkins介紹 jenkins是一個廣泛用於持續構建的可視化web工具,持續構建說得更直白點,就是各種項目的”自動化”編譯、打包、分發部署。jenkins可以很好的支持各種語言(比如:java, c#, php等)的項目構建,也完全相容ant、maven、gradle等多種第三方構建工具,同 ...
  • 今天來討論一個ASP.NET Core 很重要概念管道和中間件,在ASP.NET Core中,針對HTTP請求採用pipeline也就是通常說的管道方式來處理,而管道容器內可以掛載很多中間件(處理邏輯)“串聯”來處理HTTP請求,每一個中間件都有權決定是否需要執行下一個中間件,或者直接做出響應。這樣... ...
  • 微信開發時候有需求需要上傳素材, 以介面http://qydev.weixin.qq.com/wiki/index.php?title=%E4%B8%8A%E4%BC%A0%E4%B8%B4%E6%97%B6%E7%B4%A0%E6%9D%90%E6%96%87%E4%BB%B6 為例 感覺文檔寫得 ...
  • 這是view中的model代碼: 這是web.config配置文件只的代碼: 這樣就不用在每個要使用model 的視圖view 中都添加如下的代碼: 不過,在添加完,需要重新啟動vs,要不然就因為識別不出model報錯。 ...
  • 在使用DataRow讀取數據時,通常會遇到數據可能為Null, 但是又需要轉換為如int等其它類型的數據,因此就通常會寫這樣的代碼: if (dr[name] != DBNull.Value && dr[name] != null){ if (!int.TryParse(dr[name].ToStr ...
  • 目錄索引 【無私分享:ASP.NET CORE 項目實戰】目錄索引 簡介 在我們之前的Asp.net mvc 開發中,一提到配置文件,我們不由的想到 web.config 和 app.config,在 core 中,我們看到了很多的變化,新的配置系統顯得更加輕量級,具有更好的擴展性,並且支持多樣化的 ...
  • 在JSON沒流行起來的時候xml一直作為程式存儲配置信息的主流介質;特別是小型數據表方面還是不錯的選擇,所以經常涉及到的操作無非也就是增刪改查,這篇博客主要是對這些對比較常用的操作做了個簡單的總結 文件載入 SelectNodes()、SelectSingleNode()節點獲取大法 創建XML文檔 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 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 ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...