Unity客户端接收UDP数据包失败，两种实现均异常求助

针对你遇到的两种UDP接收方式的问题，分别给出原因和解决办法：

一、非阻塞式BeginReceive日志延迟问题 #

原因 #

Unity的Debug.Log是主线程专属API，后台线程调用时不会立即输出日志，而是被Unity缓存，直到主线程生命周期结束（比如停止编辑器）才会一次性打印。

解决办法 #

通过主线程消息队列将后台线程的接收数据传递到主线程处理日志，代码示例：

using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Text;
using UnityEngine;

public class UdpClientHandler : MonoBehaviour
{
    private Queue<string> _mainThreadLogQueue = new Queue<string>();
    private UdpClient _udpClient;
    private readonly object _queueLock = new object();

    [SerializeField] private int listenPort = 8888; // 需与服务器发送的目标端口一致

    void Start()
    {
        // 绑定监听端口，0.0.0.0表示监听所有网卡
        _udpClient = new UdpClient(new IPEndPoint(IPAddress.Any, listenPort));
        StartReceive();
    }

    void StartReceive()
    {
        _udpClient.BeginReceive(OnReceiveCallback, null);
    }

    void OnReceiveCallback(IAsyncResult ar)
    {
        IPEndPoint remoteEndPoint = null;
        try
        {
            // 完成接收
            byte[] receivedData = _udpClient.EndReceive(ar, ref remoteEndPoint);
            string message = Encoding.UTF8.GetString(receivedData);

            // 将日志消息加入主线程队列
            lock (_queueLock)
            {
                _mainThreadLogQueue.Enqueue($"收到[{remoteEndPoint}]的消息: {message}");
            }

            // 继续监听下一个数据包
            StartReceive();
        }
        catch (SocketException ex)
        {
            // 忽略程序退出时的终止异常
            if (ex.SocketErrorCode != SocketError.Interrupted)
            {
                lock (_queueLock)
                {
                    _mainThreadLogQueue.Enqueue($"接收异常: {ex.Message}");
                }
            }
        }
    }

    void Update()
    {
        // 主线程处理日志队列
        lock (_queueLock)
        {
            while (_mainThreadLogQueue.Count > 0)
            {
                Debug.Log(_mainThreadLogQueue.Dequeue());
            }
        }
    }

    void OnApplicationQuit()
    {
        // 关闭UDP客户端，终止监听
        _udpClient?.Close();
    }
}

二、阻塞式Receive无法接收问题 #

原因 #

1. 直接在Unity主线程调用Receive()会阻塞主线程，导致Unity无响应，且无法正确处理接收逻辑；
2. 独立线程中使用时，可能存在线程生命周期未正确管理、UDPClient实例被提前释放，或端口绑定错误的情况。

解决办法 #

在后台独立线程中运行阻塞接收逻辑，同时通过主线程队列传递日志，代码示例：

using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using UnityEngine;

public class BlockingUdpClient : MonoBehaviour
{
    private Queue<string> _mainThreadLogQueue = new Queue<string>();
    private UdpClient _udpClient;
    private Thread _receiveThread;
    private bool _isRunning = false;
    private readonly object _queueLock = new object();

    [SerializeField] private int listenPort = 8888;

    void Start()
    {
        _udpClient = new UdpClient(new IPEndPoint(IPAddress.Any, listenPort));
        _isRunning = true;

        // 创建后台线程，Unity退出时自动终止
        _receiveThread = new Thread(ReceiveLoop)
        {
            IsBackground = true
        };
        _receiveThread.Start();
    }

    void ReceiveLoop()
    {
        IPEndPoint remoteEndPoint = null;
        while (_isRunning)
        {
            try
            {
                // 阻塞等待接收
                byte[] receivedData = _udpClient.Receive(ref remoteEndPoint);
                string message = Encoding.UTF8.GetString(receivedData);

                lock (_queueLock)
                {
                    _mainThreadLogQueue.Enqueue($"收到[{remoteEndPoint}]的消息: {message}");
                }
            }
            catch (SocketException ex)
            {
                if (_isRunning && ex.SocketErrorCode != SocketError.Interrupted)
                {
                    lock (_queueLock)
                    {
                        _mainThreadLogQueue.Enqueue($"接收异常: {ex.Message}");
                    }
                }
            }
        }
    }

    void Update()
    {
        lock (_queueLock)
        {
            while (_mainThreadLogQueue.Count > 0)
            {
                Debug.Log(_mainThreadLogQueue.Dequeue());
            }
        }
    }

    void OnApplicationQuit()
    {
        // 终止线程并清理资源
        _isRunning = false;
        _udpClient?.Close();
        _receiveThread?.Join(1000); // 等待线程终止，超时1秒
    }
}

额外排查点 #

• 端口一致性：确认服务器发送的目标端口与客户端绑定的监听端口完全一致，可通过WireShark查看数据包的Destination Port字段；
• 端口占用：用netstat -ano命令检查监听端口是否被其他程序占用；
• IP绑定范围：客户端绑定IPAddress.Any（监听所有网卡），避免因绑定特定IP导致本地数据包无法接收；
• 资源清理：确保在Unity退出或脚本销毁时，正确关闭UDPClient并终止线程，避免资源泄漏。

内容的提问来源于stack exchange，提问作者Ofir Dahan