[csharp] view plaincopy print?
代碼?? ?? Code?highlighting?produced?by?Actipro?CodeHighlighter?(freeware)http:?? ????{?? ?? ????????static ?bool ?connecting?=?true ;?? ????????static ?void ?Main()?? ????????{?? ????????????Received();?? ????????????while ?(connecting)?? ????????????{?? ????????????????string ?content?=?Console.ReadLine();?? ????????????????if ?(content.Length?>?0)?? ????????????????{?? ????????????????????if ?(string .Compare(content,?"<Stop>" ,?true )?==?0)?? ????????????????????{?? ????????????????????????Console.WriteLine("關(guān)閉..." );?? ????????????????????????connecting?=?false ;?? ????????????????????}?? ????????????????????else ?? ????????????????????{?? ????????????????????????Send(content);?? ????????????????????}?? ????????????????}?? ????????????}?? ????????????Console.ReadKey();?? ????????}?? ?? ????????public ?static ?void ?Send(string ?content)?? ????????{?? ????????????Socket?sock?=?new ?Socket(AddressFamily.InterNetwork,?SocketType.Dgram,?ProtocolType.Udp);?? ?????????????? ????????????IPEndPoint?iep2?=?new ?IPEndPoint(IPAddress.Parse("192.168.100.255" ),?9050);?? ????????????? ????????????byte []?data?=?Encoding.ASCII.GetBytes(content);?? ????????????sock.SetSocketOption(SocketOptionLevel.Socket,?? ????????????SocketOptionName.Broadcast,?1);?? ?????????????? ????????????sock.SendTo(data,?iep2);?? ????????????sock.Close();?? ????????}?? ?? ????????public ?static ?void ?Received()?? ????????{?? ????????????ThreadPool.QueueUserWorkItem((x)?=>?? ????????????{?? ????????????????Socket?sock?=?new ?Socket(AddressFamily.InterNetwork,?SocketType.Dgram,?ProtocolType.Udp);?? ????????????????IPEndPoint?iep?=?new ?IPEndPoint(IPAddress.Any,?9050);?? ????????????????sock.Bind(iep);?? ????????????????EndPoint?ep?=?(EndPoint)iep;?? ?? ????????????????byte []?data;?? ????????????????int ?recv;?? ????????????????string ?stringData;?? ????????????????Console.WriteLine("接聽(tīng)開(kāi)啟..." );?? ????????????????while ?(connecting)?? ????????????????{?? ????????????????????data?=?new ?byte [1024];?? ????????????????????recv?=?sock.ReceiveFrom(data,?ref ?ep);?? ????????????????????stringData?=?Encoding.ASCII.GetString(data,?0,?recv);?? ????????????????????Console.WriteLine("信息:?{0}?來(lái)自:?{1}" ,?stringData,?ep.ToString());?? ????????????????}?? ????????????????Console.WriteLine("接聽(tīng)關(guān)閉..." );?? ????????????????sock.Close();?? ????????????});?? ????????}?? ?? ????}?? 代碼Code highlighting produced by Actipro CodeHighlighter (freeware)http://www.CodeHighlighter.com/--> class Program{static bool connecting = true;static void Main(){Received();while (connecting){string content = Console.ReadLine();if (content.Length > 0){if (string.Compare(content, "<Stop>", true) == 0){Console.WriteLine("關(guān)閉...");connecting = false;}else{Send(content);}}}Console.ReadKey();}public static void Send(string content){Socket sock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);//IPEndPoint iep1 = new IPEndPoint(IPAddress.Broadcast, 9050);//255.255.255.255 IPEndPoint iep2 = new IPEndPoint(IPAddress.Parse("192.168.100.255"), 9050);// string hostname = Dns.GetHostName();byte[] data = Encoding.ASCII.GetBytes(content);sock.SetSocketOption(SocketOptionLevel.Socket,SocketOptionName.Broadcast, 1);//sock.SendTo(data, iep1);sock.SendTo(data, iep2);sock.Close();}public static void Received(){ThreadPool.QueueUserWorkItem((x) =>{Socket sock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);IPEndPoint iep = new IPEndPoint(IPAddress.Any, 9050);sock.Bind(iep);EndPoint ep = (EndPoint)iep;byte[] data;int recv;string stringData;Console.WriteLine("接聽(tīng)開(kāi)啟...");while (connecting){data = new byte[1024];recv = sock.ReceiveFrom(data, ref ep);stringData = Encoding.ASCII.GetString(data, 0, recv);Console.WriteLine("信息: {0} 來(lái)自: {1}", stringData, ep.ToString());}Console.WriteLine("接聽(tīng)關(guān)閉...");sock.Close();});}}
從原理角度考慮，廣播和單向定點(diǎn)發(fā)送沒(méi)什么區(qū)別，獻(xiàn)上一段小代碼（來(lái)自msdn），基本很詳細(xì)的說(shuō)了如何廣播式發(fā)送udp數(shù)據(jù)包：
?
[csharp] view plaincopy print?
using ???System;???????using ???System.Net;????? ??using ???System.Net.Sockets;????? ??using ???System.Text;????? ?????? ??public ???class ???UDPMulticastSender???{????? ?????? ??????????private ???static ???IPAddress???GroupAddress???=??????? ??????????????????IPAddress.Parse("224.168.100.2" );????? ??????????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;????? ??????????}??? using System; using System.Net; using System.Net.Sockets; using System.Text; public class UDPMulticastSender { private static IPAddress GroupAddress = IPAddress.Parse("224.168.100.2"); 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; }
??? 在廣播通信中， 網(wǎng)絡(luò)層提供了將封包從一個(gè)節(jié)點(diǎn)發(fā)送到所有其他節(jié)點(diǎn)的服務(wù)。
??? 利用廣播(broadcast) 可以將數(shù)據(jù)發(fā)送給本地子網(wǎng)上的每個(gè)機(jī)器。廣播的缺點(diǎn)是如果多個(gè)進(jìn)程都發(fā)送廣播數(shù)據(jù)， 網(wǎng)絡(luò)就會(huì)阻塞。
1. 服務(wù)端
[csharp] view plaincopy print?
using ?System;??using ?System.Collections.Generic;??using ?System.Text;??using ?System.Net.Sockets;??using ?System.Net;??using ?System.Threading;???? namespace ?_5._2_廣播通信??{?? ????class ?Program?? ????{?? ????????static ?void ?Main(string []?args)?? ????????{?? ????????????Socket?s?=?new ?Socket(AddressFamily.InterNetwork,?SocketType.Dgram,?ProtocolType.Udp);?? ????????????s.SetSocketOption(SocketOptionLevel.Socket,?SocketOptionName.Broadcast,?true );?? ?? ????????????byte []?buffer?=?Encoding.Unicode.GetBytes("Hello?World" );?? ????????????IPEndPoint?iep1?=?new ?IPEndPoint(IPAddress.Broadcast,?4567);?? ?? ????????????int ?i?=?0;?? ????????????while ?(true )?? ????????????{?? ????????????????Console.WriteLine("正在進(jìn)行廣播?{0}" ,?i++.ToString());?? ????????????????s.SendTo(buffer,?iep1);?? ????????????????Thread.Sleep(5000);?? ????????????}?? ????????}?? ????}?? }?? using System;
using System.Collections.Generic;
using System.Text;
using System.Net.Sockets;
using System.Net;
using System.Threading;namespace _5._2_廣播通信
{class Program{static void Main(string[] args){Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);s.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.Broadcast, true);byte[] buffer = Encoding.Unicode.GetBytes("Hello World");IPEndPoint iep1 = new IPEndPoint(IPAddress.Broadcast, 4567);//255.255.255.255int i = 0;while (true){Console.WriteLine("正在進(jìn)行廣播 {0}", i++.ToString());s.SendTo(buffer, iep1);Thread.Sleep(5000);}}}
}
? 廣播消息的目的IP地址是一種特殊IP地址，稱(chēng)為廣播地址。
? 廣播地址由IP地址網(wǎng)絡(luò)前綴加上全1主機(jī)后綴組成，如：192.168.1.255是 192.169.1.0 這個(gè)網(wǎng)絡(luò)的廣播地址;
? 130.168.255.255 是130.168.0.0 這個(gè)網(wǎng)絡(luò)的廣播地址。
? 向全部為1的IP地址（255.255.255.255）發(fā)送消息的話(huà)，那么理論上全世界所有的聯(lián)網(wǎng)的計(jì)算機(jī)都能收得到了。
? 但實(shí)際上不是這樣的，一般路由器上設(shè)置拋棄這樣的包，只在本地網(wǎng)內(nèi)廣播，所以效果和向本地網(wǎng)的廣播地址發(fā)送消息是一樣的。
? 進(jìn)行廣播通信， 必須打開(kāi)廣播選項(xiàng) SO_BROADCAST
2. 客戶(hù)端
[csharp] view plaincopy print?
using ?System;??using ?System.Collections.Generic;??using ?System.Text;??using ?System.Net.Sockets;??using ?System.Net;???? namespace ?Client??{?? class ?Program???{?? static ?void ?Main(string []?args)???{?? ?Socket?m_s?=?new ?Socket(AddressFamily.InterNetwork,?SocketType.Dgram,?ProtocolType.Udp);?? ?? ?IPEndPoint?iep?=?new ?IPEndPoint(IPAddress.Any,?4567);?? ?EndPoint?ep?=?(EndPoint)iep;?? ?m_s.Bind(iep);?? ?? byte []?buffer?=?new ?byte [1204];??while ?(true )???{?? int ?revc?=?m_s.ReceiveFrom(buffer,?ref ?ep);??if ?(revc?>?0)???{?? string ?data?=?Encoding.Unicode.GetString(buffer,?0,?revc);???Console.WriteLine(data);?? ?}?? ?}?? ?}?? ?}?? }?? using System;
using System.Collections.Generic;
using System.Text;
using System.Net.Sockets;
using System.Net;namespace Client
{
class Program{
static void Main(string[] args){Socket m_s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);IPEndPoint iep = new IPEndPoint(IPAddress.Any, 4567);EndPoint ep = (EndPoint)iep;m_s.Bind(iep);byte[] buffer = new byte[1204];
while (true){
int revc = m_s.ReceiveFrom(buffer, ref ep);
if (revc > 0){
string data = Encoding.Unicode.GetString(buffer, 0, revc);Console.WriteLine(data);}}}}
}
3. 效果
?
?
?C#實(shí)現(xiàn)局域網(wǎng)UDP廣播,這一塊設(shè)置到局域網(wǎng)，需要用到的主要命名空間是:System.NET和System.Net.Scoket:
接收端:
?????????? Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);//初始化一個(gè)Scoket協(xié)議
??????????? IPEndPoint iep = new IPEndPoint(IPAddress.Any, 9095);//初始化一個(gè)偵聽(tīng)局域網(wǎng)內(nèi)部所有IP和指定端口
??????????? EndPoint ep = (EndPoint)iep;
??????????? socket.Bind(iep);//綁定這個(gè)實(shí)例
??????????? while (true)
??????????????????
{ }
發(fā)送端:
??????????? Socket sock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);//初始化一個(gè)Scoket實(shí)習(xí),采用UDP傳輸
??????????? IPEndPoint iep = new IPEndPoint(IPAddress.Broadcast, 9095);//初始化一個(gè)發(fā)送廣播和指定端口的網(wǎng)絡(luò)端口實(shí)例
??????????? sock.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.Broadcast, 1);//設(shè)置該scoket實(shí)例的發(fā)送形式
??????????? string request = "你好,TEST SEND!";//初始化需要發(fā)送而的發(fā)送數(shù)據(jù)
??????????? byte[] buffer = Encoding.Unicode.GetBytes(request);
??????????? sock.SendTo(buffer, iep);
??????????? sock.Close();
總結(jié)
以上是生活随笔 為你收集整理的C#实现 UDP简单广播 的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
如果覺(jué)得生活随笔 網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔 推薦給好友。
