当前位置：首页 > news >正文

c#一个udp代码

news 来源：原创 2024/9/28 23:25:15

不使用socket进行

unity下的

private Thread connectThread;private UdpClient udpClient;public Queue LogQueue = new Queue();public static UDPManager Instance{get;private set;}private void Awake(){Instance = this;}private void Start(){udpClient = new UdpClient();udpClient.EnableBroadcast = true;connectThread = new Thread(new ThreadStart(SocketReceive));Thread.Sleep(1000);connectThread.Start();}private void Update(){SendMessanger();}void SocketReceive(){UdpClient udpClient = new UdpClient(6900);try{while (true){IPEndPoint remoteIpEndPoint = new IPEndPoint(IPAddress.Any, 0);while (true){byte[] recvData = udpClient.Receive(ref remoteIpEndPoint);string recvStr = Encoding.UTF8.GetString(recvData);LogQueue.Enqueue(recvStr);}}}catch (Exception){throw;}finally{udpClient.Close();}}void SendMessanger(){if (LogQueue.Count <= 0) return;string strArray = LogQueue.Dequeue() as string;if (strArray!=null){Debug.Log(strArray);}}public void SendAllStart(string content){byte[] bytes = Encoding.UTF8.GetBytes(content);udpClient.Send(bytes, bytes.Length, new IPEndPoint(IPAddress.Loopback, 6910));}

c#其他下使用：

public partial class NetSever
{private static NetSever instance;public static NetSever Instance{get{if (instance == null){instance = new NetSever();}return instance;}}static UdpClient udpClient;static int connectPort;public static Queue LogQueue = new Queue();static IPAddress remoteIP = IPAddress.Parse("127.0.0.1");IPEndPoint remotePoint = new IPEndPoint(remoteIP, connectPort);//实例化一个远程端点//网络端口唤醒public void Init(){//初始化协议if (GetIP() == ""){Console.WriteLine ("当前IP地址不存在，或没有信号进行连接！");return;}udpClient = new UdpClient();udpClient.EnableBroadcast = true;connectPort = 6900;//添加事件订阅信息AddEventNeight();开启一个线程Task task = new Task(SocketReceive);task.Start();}private void AddEventNeight(){}string GetIP(){//本机名 string hostName = Dns.GetHostName();//会返回所有地址，包括IPv4和IPv6IPAddress[] addressList = Dns.GetHostAddresses(hostName);foreach (IPAddress ip in addressList){if (ip.AddressFamily == AddressFamily.InterNetwork){return ip.ToString();}}return "127.0.0.1";}static void SocketReceive(){UdpClient client = null;string receiveString = null;//实例化一个远程端点，IP和端口可以随意指定，等调用client.Receive(ref remotePoint)时会将该端点改成真正发送端端点IPEndPoint remotePoint = new IPEndPoint(IPAddress.Any, 0);//NetSever.Instance.SendAllStart("网络开启");UdpClient udpClient = new UdpClient(6910);try{while (true){IPEndPoint remoteIpEndPoint = new IPEndPoint(IPAddress.Any, 0);while (true){byte[] recvData = udpClient.Receive(ref remoteIpEndPoint);receiveString = Encoding.UTF8.GetString(recvData);string[] date = null;if (receiveString.Contains("\r\n")){receiveString = receiveString.TrimEnd((char[])"\r\n".ToCharArray());}if (receiveString.Contains("010")){date = receiveString.Split('-');receiveString = "010";}if (receiveString.Contains("openFile")){date = receiveString.Split('-');receiveString = "openFile";}switch (receiveString){case "Text":Console.WriteLine("网络端口测试！！！已收到信息");NetSever.Instance.SendAllStart("网络已打开");break;}}}}catch (Exception){//NetSever.Instance.SendAllStart("网络已打开");throw;}finally{udpClient.Close();}}//发送端口public void SendAllStart(string content){byte[] bytes = Encoding.UTF8.GetBytes(content);UdpClient udpClient = new UdpClient();try{udpClient.Connect("127.0.0.1", 6900);udpClient.Send(bytes, bytes.Length);}catch (Exception ex){Console.WriteLine(ex.ToString());}}

至于为啥这么写，只能说经验之谈