[Unity]简单UDP

using System;
using System.Collections;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using UnityEngine;
//针对回调函数&＃xff0c;定义一个消息list&＃xff0c;在Update里处理消息
// private List UDPOrders &＃61; new List();
//void Update()
//{
// if (UDPOrders.Count > 0)
// {
// Log.text &＃61; "Recv:" &＃43; UDPOrders[0];
// //处理一个清空一个
// UDPOrders.RemoveAt(0);
// }
//}
public delegate void RecvCallBack(string msg);
public class AnUDP
{
//默认使用ASCII
private int UdpPort;//端口号
private bool IsUdpVaild;//是否可用
private Socket UdpSocket;//socket
private Thread RecvThread;//接收线程
private RecvCallBack CallBack;//回调函数
public AnUDP()
{
UdpPort &＃61; 0;
CallBack &＃61; null;
IsUdpVaild &＃61; false;
}
public bool Open(string SelfIP,int SelfPort)
{
Debug.Log(SelfIP);
UdpPort &＃61; SelfPort;
//定义连接的服务器ip和端口&＃xff0c;可以是本机ip&＃xff0c;局域网&＃xff0c;互联网
IPEndPoint UdpPoint &＃61; new IPEndPoint(IPAddress.Parse(SelfIP), UdpPort);
//定义套接字类型,在主线程中定义
UdpSocket &＃61; new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
UdpSocket.Bind(UdpPoint);
//
IsUdpVaild &＃61; true;
return true;
}
public void Close()
{
if (RecvThread !&＃61; null)
{
RecvThread.Abort();
RecvThread.Interrupt();
}
UdpSocket.Close();
}
public bool SendTo(string TargetIP, int TargetPort,string msg)
{
if (!IsUdpVaild) return false;
//清空发送缓存
byte[] sendData &＃61; new byte[1024];
//数据类型转换
sendData &＃61; Encoding.ASCII.GetBytes(msg);
//
EndPoint sendPoint &＃61; new IPEndPoint(IPAddress.Parse(TargetIP), TargetPort);
//发送给指定客户端
UdpSocket.SendTo(sendData, sendData.Length, SocketFlags.None, sendPoint);
return true;
}
public void StartRecv(RecvCallBack _call)
{
if (!IsUdpVaild) return;
if (RecvThread&＃61;&＃61;null)
{
RecvThread &＃61; new Thread(new ThreadStart(SocketReceive));
RecvThread.Start();
}
//接收回调
CallBack &＃61; _call;
}
private void SocketReceive()
{
while (true)
{
try
{
//创建消息
byte[] recvData &＃61; new byte[1024];
EndPoint recvPoint &＃61; new IPEndPoint(IPAddress.Any, UdpPort);
//接收
int recvLen &＃61; UdpSocket.ReceiveFrom(recvData, ref recvPoint);
if (recvLen > 0)
{
string data &＃61; Encoding.ASCII.GetString(recvData, 0, recvLen);
if (CallBack!&＃61;null)
{
CallBack(data);
}
}
}
catch (Exception e)
{
}
}
}
}

二、针对回调函数

1.定义消息队列
private AnUDP UPD;
private List UDPOrders &＃61; new List();
2.定义回调函数
void OnUDPRecv(string data)
{
UDPOrders.Add(data);
}
3.启用UDP并设置回调
UPD &＃61; new AnUDP();
if(UPD.Open(SelfIP,Selfport))
{
UPD.StartRecv(OnUDPRecv);
}
4.发送
UPD.SendTo("127.0.0.1",10000,"Hello");
三、针对SocketException

    出现错误&＃xff1a;SocketException: 在其上下文中&＃xff0c;该请求的地址无效。一般都是你的ip地址不是所在网段里的地址