C# 网络编程之UDP

 更新时间:2021年02月19日 10:46:39   作者:seabluescn  
这篇文章主要介绍了C# 网络编程之UDP的相关资料,帮助大家更好的理解和使用c#,感兴趣的朋友可以了解下

一、概述

UDP和TCP是网络通讯常用的两个传输协议,C#一般可以通过Socket来实现UDP和TCP通讯,由于.NET框架通过UdpClient、TcpListener 、TcpClient这几个类对Socket进行了封装,使其使用更加方便, 本文就通过这几个封装过的类讲解一下相关应用。

二、UDP基本应用

与TCP通信不同,UDP通信是不分服务端和客户端的,通信双方是对等的。为了描述方便,我们把通信双方称为发送方和接收方。

发送方:

首先创建一个UDP对象:

string locateIP = "127.0.0.1"; //本机IP

   int locatePort = 9001;   //发送端口

   IPAddress locateIpAddr = IPAddress.Parse(locateIP);

   IPEndPoint locatePoint = new IPEndPoint(locateIpAddr, locatePort);

   UdpClient udpClient = new UdpClient(locatePoint);

发送数据:

string remoteIP = "127.0.0.1";    //目标机器IP

   int remotePort = 9002;      //接收端口   

   IPAddress remoteIpAddr = IPAddress.Parse(remoteIP);

   IPEndPoint remotePoint = new IPEndPoint(remoteIpAddr, remotePort);

   byte[] buffer = Encoding.UTF8.GetBytes(“hello”);

   udpClient.Send(buffer, buffer.Length, remotePoint);

以上就完成了一个发送任务,一个较完整的发送代码如下: 

public partial class FormServer : Form
 {
  private UdpClient udpClient = null;

  private void btnConnect_Click(object sender, EventArgs e)
  {
   string locateIP = "127.0.0.1";
   int locatePort = 9001;
   IPAddress locateIpAddr = IPAddress.Parse(locateIP);
   IPEndPoint locatePoint = new IPEndPoint(locateIpAddr, locatePort);
   udpClient = new UdpClient(locatePoint);

   this.groupWork.Enabled = true;
  }

  private void Send_Click(object sender, EventArgs e)
  {
   string text = this.txtSend.Text.Trim();
   string remoteIP = "127.0.0.1";
   int remotePort = 9002;
   byte[] buffer = Encoding.UTF8.GetBytes(text);

   if (udpClient != null)
   {
    IPAddress remoteIp = IPAddress.Parse(remoteIP);
    IPEndPoint remotePoint = new IPEndPoint(remoteIp, remotePort);
    udpClient.Send(buffer, buffer.Length, remotePoint);
   }

   Debug.WriteLine("Send OK");
  }
 }

接收端: 

首先创建一个UDP对象:

string locateIP = "127.0.0.1";

   int locatePort = 9002;

   IPAddress locateIpAddr = IPAddress.Parse(locateIP);

   IPEndPoint locatePoint = new IPEndPoint(locateIpAddr, locatePort);

   UdpClient udpClient = new UdpClient(locatePoint);

接收数据: 

IPEndPoint remotePoint = new IPEndPoint(IPAddress.Parse("1.1.1.1"), 1);

  var received = udpClient.Receive(ref remotePoint);

  string info = Encoding.UTF8.GetString(received);

  string from=$” {remotePoint.Address}:{remotePoint.Port}”;

注意两点:

1、remotePoint是获得发送方的IP信息,定义时可以输入任何合法的IP和端口信息;

2、Receive方法是阻塞方法,所以需要在新的线程内运行,程序会一直等待接收数据,当接收到一包数据时程序就返回,要持续接收数据需要重复调用Receive方法。

一个较完整的接收端代码如下: 

public partial class FormClent : Form
 {
  private UdpClient udpClient = null; 

  private void btnConnect_Click(object sender, EventArgs e)
  {
   string locateIP = "127.0.0.1";
   int locatePort = 9002;
   IPAddress locateIpAddr = IPAddress.Parse(locateIP);
   IPEndPoint locatePoint = new IPEndPoint(locateIpAddr, locatePort);
   udpClient = new UdpClient(locatePoint);
   IPEndPoint remotePoint = new IPEndPoint(IPAddress.Parse("1.1.1.1"), 1);

   Task.Run(() =>
   {
    while (true)
    {
     if (udpClient != null)
     {
      var received = udpClient.Receive(ref remotePoint);
      string info = Encoding.UTF8.GetString(received);
      string from=$” {remotePoint.Address}:{remotePoint.Port}”; 
     }
    }
   }); 
  }
 }

三、丢包和乱序问题

   当发送端发送一包数据时,不管对方是否接收都是发送成功的,UDP协议本身并不会对发送的可靠性进行验证。(这里的可靠性是指是否接收到,如果对方接收到数据包,其内容还是可靠的,这个在链路层进行了保证。)同时,由于网络延时等因素,先发送的包并不能确定先被接收到,所以由于这两个原因,UDP通信存在丢包和乱序的情况。

   某些业务场景下,比如实时状态监控,可能对丢包和乱序情况并不敏感, 可以不用处理,但大部分情况下还是介意丢包的,简单的处理办法就是把包的头部固定长度的空间拿出来存放核对信息,比如包编号,如果有缺失,可以要求发送方重发,也可以进行排序。

四、将数据接收包装为事件

 我们对UdpClent又进行一次封装,启用一个线程进行接收数据,将接收到的数据包通过事件发布出来,这样使用起来就更方便了。

namespace Communication.UDPClient
{
 public class UdpStateEventArgs : EventArgs
 {  
  public IPEndPoint remoteEndPoint;  
  public byte[] buffer = null;
 }

 public delegate void UDPReceivedEventHandler(UdpStateEventArgs args);

 public class UDPClient
 {
  private UdpClient udpClient;
  public event UDPReceivedEventHandler UDPMessageReceived;

  public UDPClient(string locateIP, int locatePort)
  {
   IPAddress locateIp = IPAddress.Parse(locateIP);
   IPEndPoint locatePoint = new IPEndPoint(locateIp, locatePort);
   udpClient = new UdpClient(locatePoint);

   //监听创建好后,创建一个线程,开始接收信息
   Task.Run(() =>
   {
    while (true)
    {
     UdpStateEventArgs udpReceiveState = new UdpStateEventArgs();

     if (udpClient != null)
     {
      IPEndPoint remotePoint = new IPEndPoint(IPAddress.Parse("1.1.1.1"), 1);
      var received = udpClient.Receive(ref remotePoint);
      udpReceiveState.remoteEndPoint = remotePoint;
      udpReceiveState.buffer = received;
      UDPMessageReceived?.Invoke(udpReceiveState);
     }
     else
     {
      break;
     }
    }
   });
  }
 }
}

具体使用办法:

private void btnConnect_Click(object sender, EventArgs e)
  {
   string locateIP = "127.0.0.1";
   int locatePort = 9002;   
   UDPClient udpClient = new UDPClient(locateIP, locatePort);
   udpClient.UDPMessageReceived += UdpClient_UDPMessageReceived;   
  }

  private void UdpClient_UDPMessageReceived(UdpStateEventArgs args)
  {
   var remotePoint = args.remoteEndPoint;
   string info = Encoding.UTF8.GetString(args.buffer); 
  }

传送门:

C#网络编程入门系列包括三篇文章:

(一)C#网络编程入门之UDP

(二)C#网络编程入门之TCP

(三)C#网络编程入门之HTTP

以上就是C# 网络编程之UDP的详细内容,更多关于C# 网络编程UDP的资料请关注脚本之家其它相关文章!

相关文章

  • 轻松学习C#的读写操作

    轻松学习C#的读写操作

    轻松学习C#的读写操作,小编也是第一次接触C#的读写操作,感兴趣的小伙伴们可以参考一下,大家一起学习
    2015-11-11
  • c# Task.Wait()与awaiat Task异常处理的区别说明

    c# Task.Wait()与awaiat Task异常处理的区别说明

    这篇文章主要介绍了c# Task.Wait()与awaiat Task异常处理的区别说明,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-06-06
  • C#绘制曲线图的方法

    C#绘制曲线图的方法

    这篇文章主要介绍了C#绘制曲线图的方法,以完整实例形式较为详细的分析了C#进行曲线绘制的具体步骤与相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-10-10
  • C#中使用JSON.NET实现JSON、XML相互转换

    C#中使用JSON.NET实现JSON、XML相互转换

    这篇文章主要介绍了C#中使用JSON.NET实现JSON、XML相互转换的相关代码及示例,需要的朋友可以参考下
    2015-11-11
  • C#基于共享内存实现跨进程队列

    C#基于共享内存实现跨进程队列

    进程通信一般情况下比较少用,但是也有一些使用场景,有些做视频传输的似乎会用多进程来实现,还有在子进程中调用特定的库来避免内存泄漏,笔者最近也遇到了需要使用多进程的场景,本文介绍了C#基于共享内存实现跨进程队列,需要的朋友可以参考下
    2024-07-07
  • C#简单的向量用法实例教程

    C#简单的向量用法实例教程

    这篇文章主要介绍了C#简单的向量用法,需要的朋友可以参考下
    2014-07-07
  • c#使用EPPlus封装excel表格导入功能的问题

    c#使用EPPlus封装excel表格导入功能的问题

    这篇文章主要介绍了c#使用EPPlus封装excel表格导入功能的问题,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-04-04
  • C# 批处理调用方法

    C# 批处理调用方法

    当批处理和aspx不在同一目录中时,最好用WorkingDirectory设置启动的进程的初始目录为批处理所在目录,否则如上例中批处理新建的目录就应在aspx所在目录中而不是批处理所在目录了!
    2008-12-12
  • C#中的Task.WhenAll和Task.WhenAny方法介绍

    C#中的Task.WhenAll和Task.WhenAny方法介绍

    这篇文章介绍了C#中的Task.WhenAll和Task.WhenAny方法,文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-04-04
  • C#中Write()和WriteLine()的区别分析

    C#中Write()和WriteLine()的区别分析

    这篇文章主要介绍了C#中Write()和WriteLine()的区别分析,需要的朋友可以参考下
    2020-11-11

最新评论