送信側
using System; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; public class SocketSend { const string address = "127.0.0.1"; const int port = 5555; public static void Main() { //1.ソケット作成 Socket soc = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); IPEndPoint ePoint = new IPEndPoint(IPAddress.Parse(address),port); while(true) { //2.処理 Thread.Sleep(1000); //3.データ送信 DateTime d = DateTime.Now; Encoding enc = Encoding.UTF8; byte[] sendData; sendData = enc.GetBytes(d.ToString()); soc.SendTo(sendData,ePoint); } } }
受信側
using System; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; public class Socketレエイヴェ { const string address = "127.0.0.1"; const int port = 5555; public static void Main() { //1.ソケット作成 Socket soc = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); EndPoint ePoint = new IPEndPoint(0,0); EndPoint bPoint = new IPEndPoint(0,port); byte[] rData = new byte[4096]; int len; //2.ソケットのバインド soc.Bind(bPoint); while(true) { //2.データ受信 len = soc.ReceiveFrom(rData,ref ePoint); Array.Resize(ref rData,len); Encoding enc = Encoding.UTF8; Console.WriteLine(enc.GetString(rData)); //3.処理 Thread.Sleep(1000); } } }
0 件のコメント:
コメントを投稿