闲来无事,写个基于UDP协议的Socket通讯Demo

时间:2023-03-09 16:43:17
闲来无事,写个基于UDP协议的Socket通讯Demo

  项目一期已经做完,二期需求还没定稿,所以最近比较闲。

  上一篇写的是TCP协议,今天写一下UDP协议。TCP是有连接协议,所以发送和接收消息前客户端和服务端需要建立连接;UDP是无连接协议,所以发送消息前不需要建立连接,只需向指定的网络端点发送消息即可,不管端点是否存在都可以发送,无论消息是否到达端点都不关心,接收消息前也不需要建立连接,只需要在本地绑定的端口上接收就可以了,UDP没有明确的客户端和服务端。

  程序是基于命令行的,启动一个实例之后根据界面提示输入本地端口号、远程IP、远程端口号即可,可以启动多个实例互相通讯。

  程序启动之后首先根据输入的本地端口号绑定本地端口,其次启动一个线程接收本地端口的数据,然后界面上提示输入消息,输入完成则发送到远程IP和远程端口号,界面上再次提示输入消息……

  运行效果图:

闲来无事,写个基于UDP协议的Socket通讯Demo

图1. 实例1

闲来无事,写个基于UDP协议的Socket通讯Demo

图2. 实例2

关键代码

  绑定本地端口:

 var localPoint = new IPEndPoint(, localPort);
socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
socket.Bind(localPoint);

  

  启动线程执行数据接收:

 // 启动新线程负责接收数据
ThreadPool.QueueUserWorkItem(OnReceive, socket);
Show("准备就绪");

  数据接收细节:

 /// <summary>
/// 接收数据
/// </summary>
/// <param name="obj"></param>
private static void OnReceive(object obj)
{
try
{
var socket = obj as Socket;
if (socket == null)
{
return;
} while (true)
{
try
{
var receiveBuffer = new byte[];
// 接收数据
EndPoint remotePoint = new IPEndPoint(IPAddress.Any, );
var receiveLength = socket.ReceiveFrom(receiveBuffer, ref remotePoint);
...
}
catch (ThreadAbortException)
{
throw;
}
catch (SocketException exception)
{
...
}
catch (Exception exception)
{
...
}
}
}
catch (ThreadAbortException)
{
...
}
catch (Exception exception)
{
...
}
}

  循环执行数据发送:

 do
{
try
{
Show("请输入消息:", false);
var msg = Read();
...
// 发送数据
EndPoint sendPoint = new IPEndPoint(address, remotePort);
var sendLength = socket.SendTo(sendBuffer, sendPoint);
...
}
catch (SocketException exception)
{
...
}
catch (Exception exception)
{
...
}
} while (true);

  本人才疏学浅,欢迎大家批评指正!

源代码下载