Socket的配置
//得到本机IP,设置UDP端口号
ip = getValidIP(tbLocalIP.Text);
port = getValidPort(tbLocalPort.Text);
ipLocalPoint = new IPEndPoint(ip, port);
//定义网络类型,数据连接类型和网络协议UDP
mySocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
//绑定网络地址
mySocket.Bind(ipLocalPoint);
//得到客户机IP
ip = getValidIP(tbRemoteIP.Text);
port = getValidPort(tbRemotePort.Text);
IPEndPoint ipep = new IPEndPoint(ip, port);
RemotePoint = (EndPoint)(ipep);
//启动一个新的线程,执行方法this.ReceiveHandle,
//以便在一个独立的进程中执行数据接收的操作
RunningFlag = true;
Thread thread = new Thread(new ThreadStart(this.ReceiveHandle));
thread.Start();
接收线程
//定义一个委托
public delegate void MyInvoke(string strRecv);
private void ReceiveHandle()
{
//接收数据处理线程
string msg;
byte[] data=new byte[1024];
MyInvoke myI = new MyInvoke(UpdateMsgTextBox);
while (RunningFlag)
{
if (mySocket == null || mySocket.Available < 1)
{
Thread.Sleep(200);
continue;
}
//跨线程调用控件
//接收UDP数据报,引用参数RemotePoint获得源地址
int rlen = mySocket.ReceiveFrom(data, ref RemotePoint);
msg = Encoding.Default.GetString(data, 0, rlen);
tbMsg.BeginInvoke(myI, new object[]{RemotePoint.ToString() + " : " + msg});
}
}
private void btSend_Click(object sender, EventArgs e)
{
string msg;
msg = tbSendMsg.Text;
//发送UDP数据包
byte[] data = Encoding.Default.GetBytes(msg);
mySocket.SendTo(data, data.Length, SocketFlags.None, RemotePoint);
}
private void UpdateMsgTextBox(string msg)
{
//接收数据显示
this.tbMsg.AppendText( msg + "n");
}
以上只需设置好本地和远程的IP和端口号,很容易就实现了UDP的双向通信。虽说UDP数据包不能保证可靠传输,网络繁忙、拥塞等因素,都有可能阻止数据包到达指定的目的地。但经过测试,其通信还蛮可靠的,别忘了QQ也是利用UDP进行即时通信的。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持ASPKU。
注:相关教程知识阅读请移步到c#教程频道。










