Backend Development
C#.Net Tutorial
C# network programming series of articles (7) UdpClient implements asynchronous UDP server
C# network programming series of articles (7) UdpClient implements asynchronous UDP server
This article introduces
The UdpClient class provides simple methods for sending and receiving connectionless UDP packets in synchronous blocking mode. Because UDP is a connectionless transport protocol, you do not need to establish any remote host connection before sending and receiving data. You just need to set up the default remote host options as follows:
Create an instance of the UdpClient class using the remote host name and port number as parameters.
Create an instance of the UdpClient class and call the Connect method.
You can use any send method provided by UdpClient to send data to the remote device. Then use the Receive method to receive data from the remote host.
Tip: If you have specified a default remote host, do not use the host name or IPEndPoint to call the Send method. If you do this, UdpClient will throw an exception.
The UdpClient method also allows you to send and receive multicast packets. UdpClient can be subscribed to a multicast group using the JoinMulticastGroup method. You can also use the DropMulticastGroup method to unsubscribe a UdpClient from a multicast group.
This section introduces the use of UdpClient to implement an asynchronous high-performance UDP server
UdpClient asynchronous UDP server
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.Net;
namespace NetFrame.Net.UDP.Listener.Asynchronous
{
/// <summary>
/// UdpClient 实现异步UDP服务器
/// </summary>
public class AsyncUDPServer
{
#region Fields
/// <summary>
/// 服务器程序允许的最大客户端连接数
/// </summary>
private int _maxClient;
/// <summary>
/// 当前的连接的客户端数
/// </summary>
//private int _clientCount;
/// <summary>
/// 服务器使用的异步UdpClient
/// </summary>
private UdpClient _server;
/// <summary>
/// 客户端会话列表
/// </summary>
//private List<AsyncUDPState> _clients;
private bool disposed = false;
/// <summary>
/// 数据接受缓冲区
/// </summary>
private byte[] _recvBuffer;
#endregion
#region Properties
/// <summary>
/// 服务器是否正在运行
/// </summary>
public bool IsRunning { get; private set; }
/// <summary>
/// 监听的IP地址
/// </summary>
public IPAddress Address { get; private set; }
/// <summary>
/// 监听的端口
/// </summary>
public int Port { get; private set; }
/// <summary>
/// 通信使用的编码
/// </summary>
public Encoding Encoding { get; set; }
#endregion
#region 构造函数
/// <summary>
/// 异步UdpClient UDP服务器
/// </summary>
/// <param name="listenPort">监听的端口</param>
public AsyncUDPServer(int listenPort)
: this(IPAddress.Any, listenPort,1024)
{
}
/// <summary>
/// 异步UdpClient UDP服务器
/// </summary>
/// <param name="localEP">监听的终结点</param>
public AsyncUDPServer(IPEndPoint localEP)
: this(localEP.Address, localEP.Port,1024)
{
}
/// <summary>
/// 异步UdpClient UDP服务器
/// </summary>
/// <param name="localIPAddress">监听的IP地址</param>
/// <param name="listenPort">监听的端口</param>
/// <param name="maxClient">最大客户端数量</param>
public AsyncUDPServer(IPAddress localIPAddress, int listenPort, int maxClient)
{
this.Address = localIPAddress;
this.Port = listenPort;
this.Encoding = Encoding.Default;
_maxClient = maxClient;
//_clients = new List<AsyncUDPSocketState>();
_server = new UdpClient(new IPEndPoint(this.Address, this.Port));
_recvBuffer=new byte[_server.Client.ReceiveBufferSize];
}
#endregion
#region Method
/// <summary>
/// 启动服务器
/// </summary>
/// <returns>异步TCP服务器</returns>
public void Start()
{
if (!IsRunning)
{
IsRunning = true;
_server.EnableBroadcast = true;
_server.BeginReceive(ReceiveDataAsync, null);
}
}
/// <summary>
/// 停止服务器
/// </summary>
public void Stop()
{
if (IsRunning)
{
IsRunning = false;
_server.Close();
//TODO 关闭对所有客户端的连接
}
}
/// <summary>
/// 接收数据的方法
/// </summary>
/// <param name="ar"></param>
private void ReceiveDataAsync(IAsyncResult ar)
{
IPEndPoint remote=null;
byte[] buffer = null;
try
{
buffer = _server.EndReceive(ar, ref remote);
//触发数据收到事件
RaiseDataReceived(null);
}
catch (Exception)
{
//TODO 处理异常
RaiseOtherException(null);
}
finally
{
if (IsRunning && _server != null)
_server.BeginReceive(ReceiveDataAsync, null);
}
}
/// <summary>
/// 发送数据
/// </summary>
/// <param name="msg"></param>
/// <param name="remote"></param>
public void Send(string msg, IPEndPoint remote)
{
byte[] data = Encoding.Default.GetBytes(msg);
try
{
RaisePrepareSend(null);
_server.BeginSend(data, data.Length, new AsyncCallback(SendCallback), null);
}
catch (Exception)
{
//TODO 异常处理
RaiseOtherException(null);
}
}
private void SendCallback(IAsyncResult ar)
{
if (ar.IsCompleted)
{
try
{
_server.EndSend(ar);
//消息发送完毕事件
RaiseCompletedSend(null);
}
catch (Exception)
{
//TODO 数据发送失败事件
RaiseOtherException(null);
}
}
}
#endregion
#region 事件
/// <summary>
/// 接收到数据事件
/// </summary>
public event EventHandler<AsyncUDPEventArgs> DataReceived;
private void RaiseDataReceived(AsyncUDPState state)
{
if (DataReceived != null)
{
DataReceived(this, new AsyncUDPEventArgs(state));
}
}
/// <summary>
/// 发送数据前的事件
/// </summary>
public event EventHandler<AsyncUDPEventArgs> PrepareSend;
/// <summary>
/// 触发发送数据前的事件
/// </summary>
/// <param name="state"></param>
private void RaisePrepareSend(AsyncUDPState state)
{
if (PrepareSend != null)
{
PrepareSend(this, new AsyncUDPEventArgs(state));
}
}
/// <summary>
/// 数据发送完毕事件
/// </summary>
public event EventHandler<AsyncUDPEventArgs> CompletedSend;
/// <summary>
/// 触发数据发送完毕的事件
/// </summary>
/// <param name="state"></param>
private void RaiseCompletedSend(AsyncUDPState state)
{
if (CompletedSend != null)
{
CompletedSend(this, new AsyncUDPEventArgs(state));
}
}
/// <summary>
/// 网络错误事件
/// </summary>
public event EventHandler<AsyncUDPEventArgs> NetError;
/// <summary>
/// 触发网络错误事件
/// </summary>
/// <param name="state"></param>
private void RaiseNetError(AsyncUDPState state)
{
if (NetError != null)
{
NetError(this, new AsyncUDPEventArgs(state));
}
}
/// <summary>
/// 异常事件
/// </summary>
public event EventHandler<AsyncUDPEventArgs> OtherException;
/// <summary>
/// 触发异常事件
/// </summary>
/// <param name="state"></param>
private void RaiseOtherException(AsyncUDPState state, string descrip)
{
if (OtherException != null)
{
OtherException(this, new AsyncUDPEventArgs(descrip, state));
}
}
private void RaiseOtherException(AsyncUDPState state)
{
RaiseOtherException(state, "");
}
#endregion
#region Close
/// <summary>
/// 关闭一个与客户端之间的会话
/// </summary>
/// <param name="state">需要关闭的客户端会话对象</param>
public void Close(AsyncUDPState state)
{
if (state != null)
{
//_clients.Remove(state);
//_clientCount--;
//TODO 触发关闭事件
}
}
/// <summary>
/// 关闭所有的客户端会话,与所有的客户端连接会断开
/// </summary>
public void CloseAllClient()
{
//foreach (AsyncUDPSocketState client in _clients)
//{
// Close(client);
//}
//_clientCount = 0;
//_clients.Clear();
}
#endregion
#region 释放
/// <summary>
/// Performs application-defined tasks associated with freeing,
/// releasing, or resetting unmanaged resources.
/// </summary>
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
/// <summary>
/// Releases unmanaged and - optionally - managed resources
/// </summary>
/// <param name="disposing"><c>true</c> to release
/// both managed and unmanaged resources; <c>false</c>
/// to release only unmanaged resources.</param>
protected virtual void Dispose(bool disposing)
{
if (!this.disposed)
{
if (disposing)
{
try
{
Stop();
if (_server != null)
{
_server = null;
}
}
catch (SocketException)
{
//TODO
RaiseOtherException(null);
}
}
disposed = true;
}
}
#endregion
}
}
Client information encapsulated class
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.Net;
namespace NetFrame.Net.UDP.Listener.Asynchronous
{
public class AsyncUDPState
{
// Client socket.
public UdpClient udpClient = null;
// Size of receive buffer.
public const int BufferSize = 1024;
// Receive buffer.
public byte[] buffer = new byte[BufferSize];
// Received data string.
public StringBuilder sb = new StringBuilder();
public IPEndPoint remote = new IPEndPoint(IPAddress.Any, 0);
}
}Server event parameter class
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
namespace NetFrame.Net.UDP.Listener.Asynchronous
{
/// <summary>
/// UdpClient 异步UDP服务器事件参数类
/// </summary>
public class AsyncUDPEventArgs : EventArgs
{
/// <summary>
/// 提示信息
/// </summary>
public string _msg;
/// <summary>
/// 客户端状态封装类
/// </summary>
public AsyncUDPState _state;
/// <summary>
/// 是否已经处理过了
/// </summary>
public bool IsHandled { get; set; }
public AsyncUDPEventArgs(string msg)
{
this._msg = msg;
IsHandled = false;
}
public AsyncUDPEventArgs(AsyncUDPState state)
{
this._state = state;
IsHandled = false;
}
public AsyncUDPEventArgs(string msg, AsyncUDPState state)
{
this._msg = msg;
this._state = state;
IsHandled = false;
}
}
} The above is the content of UdpClient implementing asynchronous UDP server in C# network programming series article (seven). Please pay attention to more related content PHP Chinese website (www.php.cn)!
Hot AI Tools
Undresser.AI Undress
AI-powered app for creating realistic nude photos
AI Clothes Remover
Online AI tool for removing clothes from photos.
Undress AI Tool
Undress images for free
Clothoff.io
AI clothes remover
Video Face Swap
Swap faces in any video effortlessly with our completely free AI face swap tool!
Hot Article
Hot Tools
Notepad++7.3.1
Easy-to-use and free code editor
SublimeText3 Chinese version
Chinese version, very easy to use
Zend Studio 13.0.1
Powerful PHP integrated development environment
Dreamweaver CS6
Visual web development tools
SublimeText3 Mac version
God-level code editing software (SublimeText3)
Hot Topics
1655
14
1413
52
1306
25
1252
29
1226
24
Active Directory with C#
Sep 03, 2024 pm 03:33 PM
Guide to Active Directory with C#. Here we discuss the introduction and how Active Directory works in C# along with the syntax and example.
C# Serialization
Sep 03, 2024 pm 03:30 PM
Guide to C# Serialization. Here we discuss the introduction, steps of C# serialization object, working, and example respectively.
Random Number Generator in C#
Sep 03, 2024 pm 03:34 PM
Guide to Random Number Generator in C#. Here we discuss how Random Number Generator work, concept of pseudo-random and secure numbers.
C# Data Grid View
Sep 03, 2024 pm 03:32 PM
Guide to C# Data Grid View. Here we discuss the examples of how a data grid view can be loaded and exported from the SQL database or an excel file.
Factorial in C#
Sep 03, 2024 pm 03:34 PM
Guide to Factorial in C#. Here we discuss the introduction to factorial in c# along with different examples and code implementation.
The difference between multithreading and asynchronous c#
Apr 03, 2025 pm 02:57 PM
The difference between multithreading and asynchronous is that multithreading executes multiple threads at the same time, while asynchronously performs operations without blocking the current thread. Multithreading is used for compute-intensive tasks, while asynchronously is used for user interaction. The advantage of multi-threading is to improve computing performance, while the advantage of asynchronous is to not block UI threads. Choosing multithreading or asynchronous depends on the nature of the task: Computation-intensive tasks use multithreading, tasks that interact with external resources and need to keep UI responsiveness use asynchronous.
Patterns in C#
Sep 03, 2024 pm 03:33 PM
Guide to Patterns in C#. Here we discuss the introduction and top 3 types of Patterns in C# along with its examples and code implementation.
Prime Numbers in C#
Sep 03, 2024 pm 03:35 PM
Guide to Prime Numbers in C#. Here we discuss the introduction and examples of prime numbers in c# along with code implementation.
