基於C#的UDP協議的同步通訊完成代碼。本站提示廣大學習愛好者:(基於C#的UDP協議的同步通訊完成代碼)文章只能為提供參考,不一定能成為您想要的結果。以下是基於C#的UDP協議的同步通訊完成代碼正文
一、摘要
總結基於C#的UDP協議的同步通訊。
二、實驗平台
Visual Studio 2010
三、實驗原理
UDP傳輸協議同TCP傳輸協議的區別可查閱相關文檔,此處不再贅述。
四、實例
4.1 采用socket完成UDP
由於UDP是一種無銜接的協議。因而,為了使服務器使用可以發送和接納UDP數據包,則需求做兩件事情:
(1) 創立一個Socket對象;
(2) 將創立的套接字對象與本地IPEndPoint停止綁定。
完成上述步驟後,那麼創立的套接字就可以在IPEndPoint上接納流入的UDP數據包,或許將流出的UDP數據包發送到網絡中其他恣意設備。運用UDP停止通訊時,不需求銜接。由於異地的主機之間沒有樹立銜接,所以UDP不能運用規范的Send()和Receive()t套接字辦法,而是運用兩個其他的辦法:SendTo()和ReceiveFrom()。
SendTo()辦法指定要發送的數據,和目的機器的IPEndPoint。該辦法有多種不同的運用辦法,可以依據詳細的使用停止選擇,但是至多要指定數據包和目的機器。如下:
SendTo(byte[] data,EndPoint Remote)
ReceiveFrom()辦法同SendTo()辦法相似,但是運用EndPoint對象聲明的方式不一樣。應用ref修飾,傳遞的不是一個EndPoint對象,而是將參數傳遞給一個EndPoint對象。
UDP使用不是嚴厲意義上的真正的服務器和客戶機,而是對等的關系,即沒有主與次的關系。為了簡便起見,依然把上面的這個使用叫做UDP服務器。
服務器端代碼:
using System; using System.Collections.Generic; using System.Text; using System.Net; using System.Net.Sockets; namespace UDP { class Program { static void Main(string[] args) { int recv; byte[] data = new byte[1024]; //失掉本機IP,設置TCP端口號 IPEndPoint ip = new IPEndPoint(IPAddress.Any, 8001); Socket newsock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); //綁定網絡地址 newsock.Bind(ip); Console.WriteLine("This is a Server, host name is {0}", Dns.GetHostName()); //等候客戶機銜接 Console.WriteLine("Waiting for a client"); //失掉客戶機IP IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0); EndPoint Remote = (EndPoint)(sender); recv = newsock.ReceiveFrom(data, ref Remote); Console.WriteLine("Message received from {0}: ", Remote.ToString()); Console.WriteLine(Encoding.ASCII.GetString(data, 0, recv)); //客戶機銜接成功後,發送信息 string welcome = "你好 ! "; //字符串與字節數組互相轉換 data = Encoding.ASCII.GetBytes(welcome); //發送信息 newsock.SendTo(data, data.Length, SocketFlags.None, Remote); while (true) { data = new byte[1024]; //發送接納信息 recv = newsock.ReceiveFrom(data, ref Remote); Console.WriteLine(Encoding.ASCII.GetString(data, 0, recv)); newsock.SendTo(data, recv, SocketFlags.None, Remote); } } } }
關於接納流入的UDP服務器順序來說,必需將順序與本地零碎中指定的UDP端口停止綁定。這就可以經過運用適宜的本地IP地址創立一個IPEndPoint對象,以及適宜的UDP端口號。上述范例順序中的UDP服務器可以在端口8001從網絡上接納恣意流入的UDP數據包。
UDP客戶機順序與服務器順序十分相似。
由於客戶機不需求在指定的UDP端口等候流入的數據,因而,不運用Bind()辦法,而是運用在數據發送時零碎隨機指定的一個UDP端口,而且運用同一個端口接納前往的音訊。在開發產品時,要為客戶機指定一套UDP端口,以便服務器和客戶機順序運用相反的端口號。UDP客戶機順序首先定義一個IPEndPoint,UDP服務器將發送數據包到這個IPEndPoint。假如在近程設備上運轉UDP服務器順序,在IPEndPoint定義中必需輸出適當的IP地址和UDP端口號信息。
客戶端代碼:
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Net; using System.Net.Sockets; namespace UDPClient { class Program { static void Main(string[] args) { byte[] data = new byte[1024]; string input, stringData; //構建TCP 服務器 Console.WriteLine("This is a Client, host name is {0}", Dns.GetHostName()); //設置服務IP,設置TCP端口號 IPEndPoint ip = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8001); //定義網絡類型,數據銜接類型和網絡協議UDP Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); string welcome = "你好! "; data = Encoding.ASCII.GetBytes(welcome); server.SendTo(data, data.Length, SocketFlags.None, ip); IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0); EndPoint Remote = (EndPoint)sender; data = new byte[1024]; //關於不存在的IP地址,參加此行代碼後,可以在指定時間內解除阻塞形式限制 int recv = server.ReceiveFrom(data, ref Remote); Console.WriteLine("Message received from {0}: ", Remote.ToString()); Console.WriteLine(Encoding.ASCII.GetString(data, 0, recv)); while (true) { input = Console.ReadLine(); if (input == "exit") break; server.SendTo(Encoding.ASCII.GetBytes(input), Remote); data = new byte[1024]; recv = server.ReceiveFrom(data, ref Remote); stringData = Encoding.ASCII.GetString(data, 0, recv); Console.WriteLine(stringData); } Console.WriteLine("Stopping Client."); server.Close(); } } }
上述代碼的完成邏輯為:相關設置完成後,服務器端先向客戶端發送信息,之後客戶端經過鍵盤發送字符串,服務器端收到後再發送給客戶端,如此循環。
4.2 采用UDPClient類完成
服務器端代碼:
using System; using System.Net; using System.Net.Sockets; using System.Text; public class Custom { // 設置IP,IPV6 private static readonly IPAddress GroupAddress = IPAddress.Parse("IP地址"); // 設置端口 private const int GroupPort = 11000; private static void StartListener() { bool done = false; UdpClient listener = new UdpClient(); IPEndPoint groupEP = new IPEndPoint(GroupAddress, GroupPort); try { //IPV6,組播 listener.JoinMulticastGroup(GroupAddress); listener.Connect(groupEP); while (!done) { Console.WriteLine("Waiting for broadcast"); byte[] bytes = listener.Receive(ref groupEP); Console.WriteLine("Received broadcast from {0} :\n {1}\n", groupEP.ToString(), Encoding.ASCII.GetString(bytes, 0, bytes.Length)); } listener.Close(); } catch (Exception e) { Console.WriteLine(e.ToString()); } } public static int Main(String[] args) { StartListener(); return 0; } }
客戶端代碼:
using System; using System.Net; using System.Net.Sockets; using System.Text; public class Client { private static IPAddress GroupAddress = IPAddress.Parse("IP地址"); private static int GroupPort = 11000; private static void Send(String message) { UdpClient sender = new UdpClient(); IPEndPoint groupEP = new IPEndPoint(GroupAddress, GroupPort); try { Console.WriteLine("Sending datagram : {0}", message); byte[] bytes = Encoding.ASCII.GetBytes(message); sender.Send(bytes, bytes.Length, groupEP); sender.Close(); } catch (Exception e) { Console.WriteLine(e.ToString()); } } public static int Main(String[] args) { Send(args[0]); return 0; } }
以上代碼需求闡明的是:
(1) 上述代碼是基於IPV6地址的組播形式。IPv4中的播送(broadcast)可以招致網絡功能的下降甚至播送風暴(broadcast storm)。在IPv6中就不存在播送這一概念了,取而代之的是組播(multicast)和恣意播(anycast)。
(2) IPV6地址表示辦法:
a) X:X:X:X:X:X:X:X(每個X代表16位的16進制數字),不區分大小寫;
b) 排頭的0可省略,比方09C0就可以寫成9C0,0000可以寫成0;
c) 延續為0的字段可以以::來替代,但是整個地址中::只能呈現一次,比方FF01:0:0:0:0:0:0:1就可以簡寫成FF01::1。
(3) 假如是采用窗體的方式建議運用這種格式,否則在接納數據時能夠會呈現死機的景象。
// 創立一個子線程 Thread thread = new Thread( delegate() { try { //在這裡寫你的代碼 } catch (Exception ) { } } ); thread.Start();
以上就是本文的全部內容,希望對大家的學習有所協助,也希望大家多多支持。