手机网站 开发者模式外企网站建设公司

Begin开头的方法

BeginSendTo

BeginSendTo 是 UdpClient 类中的一个重要方法，用于开始一个异步操作来发送 UDP 数据报到指定的远程端点

public IAsyncResult BeginSendTo(byte[] datagram,int bytes,IPEndPoint endPoint,AsyncCallback requestCallback,object state
);

参数解释

• datagram：要发送的字节数组，也就是你要发送的数据内容。
• bytes：datagram 数组中要发送的字节数。
• endPoint：IPEndPoint 类型，代表数据报要发送到的远程端点，包含了目标 IP 地址和端口号。
• requestCallback：AsyncCallback 类型的回调方法，当异步发送操作完成时会调用这个方法。
• state：一个用户定义的对象，它会被传递给回调方法，可用于在回调方法中携带额外的状态信息。

返回值

该方法返回一个 IAsyncResult 对象，可用于跟踪异步操作的状态。可以把这个对象传递给 EndSendTo 方法来完成异步操作。

BeginReceiveFrom

BeginReceiveFrom 是 UdpClient 类里的一个方法，用于开始一个异步操作，从指定的远程端点接收 UDP 数据报

public IAsyncResult BeginReceiveFrom(byte[] buffer,int offset,int size,ref EndPoint remoteEP,AsyncCallback requestCallback,object state
);

参数解释

• buffer：用于接收数据的字节数组。
• offset：在 buffer 中开始存储接收到的数据的偏移量。
• size：buffer 中可用于存储数据的最大字节数。
• remoteEP：EndPoint 类型的引用，代表发送数据报的远程端点。在接收操作完成后，该参数会被更新为实际发送数据的远程端点信息。
• requestCallback：AsyncCallback 类型的回调方法，当异步接收操作完成时会调用此方法。
• state：一个用户定义的对象，会被传递给回调方法，可用于在回调方法中携带额外的状态信息。

返回值

该方法返回一个 IAsyncResult 对象，可用于跟踪异步操作的状态。你可以把这个对象传递给 EndReceiveFrom 方法来完成异步操作。

Begin开头的方法要和End开头的方法配套使用

Async结尾的方法

SendToAsync

SendToAsync 是 UdpClient 类中用于异步发送 UDP 数据报到指定远程端点的方法，它是 .NET 中提供的基于任务的异步模式（TAP）的方法，相比于传统的 BeginSendTo 和 EndSendTo 组合，使用起来更加简洁和直观，结合 async 和 await 关键字能让代码更具可读性。

public Task<int> SendToAsync(byte[] datagram, int bytes, IPEndPoint endPoint);

参数解释

• datagram：要发送的字节数组，即你要传输的数据内容。
• bytes：datagram 数组中要发送的字节数。
• endPoint：IPEndPoint 类型，代表数据报要发送到的远程端点，包含目标 IP 地址和端口号。

返回值

该方法返回一个 Task<int> 对象，Task 表示异步操作，int 表示实际发送的字节数。你可以使用 await 关键字等待这个任务完成，并获取发送的字节数。

ReceiveFromAsync

ReceiveFromAsync 是 UdpClient 类中的一个方法，它以异步方式从指定的远程端点接收 UDP 数据报。这个方法遵循基于任务的异步模式（TAP），借助 async 和 await 关键字，能够让代码的异步操作变得更加简洁和易读。

public Task<UdpReceiveResult> ReceiveFromAsync();

返回值

该方法返回一个 Task<UdpReceiveResult> 对象。Task 代表一个异步操作，而 UdpReceiveResult 是一个结构体，包含两个重要属性：

• Buffer：一个字节数组，存储着接收到的数据。
• RemoteEndPoint：EndPoint 类型，指示发送数据的远程端点。

方法使用

using System;
using System.Collections;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Text;
using UnityEngine;public class Lesson16 : MonoBehaviour
{byte []cachebytes = new byte[512];// Start is called before the first frame updatevoid Start(){#region UDP异步通信中begin相关的方法Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);//BeginSendTobyte[] bytes = Encoding.UTF8.GetBytes("w9r39hjfwaofi");EndPoint IpPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8080);socket.BeginSendTo(bytes, 0, bytes.Length, SocketFlags.None, IpPoint, SendOver, socket);//BeginReceiveFromsocket.BeginReceiveFrom(cachebytes, 0, cachebytes.Length, SocketFlags.None, ref IpPoint, ReceiveFromOver, (socket, IpPoint));#endregion#region UDP异步通信中Async结尾的方法//SendToAsyncSocketAsyncEventArgs args = new SocketAsyncEventArgs();args.SetBuffer(bytes, 0, bytes.Length);args.Completed += SendAsync;socket.SendToAsync(args);//ReceiveFromAsyncSocketAsyncEventArgs args2 = new SocketAsyncEventArgs();socket.ReceiveFromAsync(args2);args2.SetBuffer(cachebytes, 0, cachebytes.Length);args2.Completed += ReceiveAsync;#endregion }private void SendOver(IAsyncResult result){try{Socket s = result.AsyncState as Socket;s.EndSendTo(result);}catch (SocketException s){print("发消息出问题了" + s.SocketErrorCode + s.Message);}}private void ReceiveFromOver(IAsyncResult result){try{(Socket s, EndPoint ipPont) info = ((Socket ,EndPoint))result.AsyncState;//返回值 就是接收了多少个字节数int num=info.s.EndReceiveFrom(result, ref info.ipPont);//处理消息//处理完消息继续接收消息info.s.BeginReceiveFrom(cachebytes, 0, cachebytes.Length,SocketFlags.None,ref info.ipPont, ReceiveFromOver, info);}catch (SocketException s){print("接收消息失败" + s.SocketErrorCode + s.Message);}}private void SendAsync(object s,SocketAsyncEventArgs args){try{print("发消息成功");}catch (SocketException e){print("发消息出问题了" + e.SocketErrorCode + e.Message);}}private void ReceiveAsync(object s,SocketAsyncEventArgs args){if(args.SocketError ==SocketError.Success){print("接收消息成功");//具体收了多少字节//args.BytesTransferred//可以通过以下两种方式获取收到的字节数组的内容//args.Buffer//cacheBytes//解析消息Socket socket = s as Socket;args.SetBuffer(0, cachebytes.Length);//只需要设置从第几个位置开始接 能接多少socket.ReceiveFromAsync(args);}    else{print("收消息失败");}}// Update is called once per framevoid Update(){}
}