Unity UDP传输图片

Server：

using System.Net.Sockets;
using System.Net;
using System.Threading;
using System.Text;
using System;

public class UDPServer
{
    private Socket server;
    /// <summary>
    /// 接收缓冲区数据
    /// </summary>
    private byte[] data;
    public Action<byte[]> OnMesageCallback;
    public UDPServer(string ip, int port)
    {
        data = new byte[1024 * 1024*10];
        server = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
        server.Bind(new IPEndPoint(IPAddress.Parse(ip), port));
        ThreadPool.QueueUserWorkItem(ReceiveMessage);
    }
    public void DisConnect()
        {
        server?.Shutdown(SocketShutdown.Both);
        server?.Dispose();
        }
    private void ReceiveMessage(object obj)
    {
        while (true)
        {
            int len = server.Receive(data);
            if(len>0)
            {
                byte[] rec = new byte[len];
                Buffer.BlockCopy(data,0, rec, 0, len);
                OnMesageCallback?.Invoke(rec);
            }
        }
    }
    public void SendMessage(string content, IPEndPoint endPoint)
    {
        byte[] sed = Encoding.UTF8.GetBytes(content);
        server.SendTo(sed, endPoint);
    }
}
 

ServerManager：

using System.Collections;
using System.Collections.Generic;
using System.Text;
using UnityEngine;
using UnityEngine.UI;

public class ServerManager : MonoBehaviour
{
    public GameObject singnature;
    public Transform itemParent;
    private UDPServer server;
    public string ip = "10.19.201.92";
    private byte[] recData;
    private bool isReceived;
    // Start is called before the first frame update
    void Start()
    {
        server = new UDPServer(ip, 7777);
        server.OnMesageCallback += OnMessageCallBack;
    }
    void OnDestroy()
    {
        server?.DisConnect();
    }
    private void OnMessageCallBack(byte[] rec)
    {
        recData = rec;
        isReceived = true;
    }
    private void Update()
    {
        if(isReceived)
        {
            isReceived = false;
            Texture2D tex = new Texture2D(500, 500);
            tex.LoadImage(recData);
            GameObject item = GameObject.Instantiate(singnature, itemParent);
            item.GetComponent<RawImage>().texture = tex;
        }
    }
}
 

Client：

using System.Net.Sockets;
using System.Net;
using System.Threading;
using System.Text;
using System;

public class UDPClient
{
    private Socket server;
    /// <summary>
    /// 接收缓冲区数据
    /// </summary>
    private byte[] data;
    public Action<byte[]> OnMesageCallback;
    public UDPClient()
    {
        data = new byte[1024 * 1024*10];
        server = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
        ThreadPool.QueueUserWorkItem(ReceiveMessage);
    }
    public void SendMessage(byte[] sed, IPEndPoint endPoint)
    {
        server.SendTo(sed, endPoint);
    }
    private void ReceiveMessage(object obj)
    {
        while (true)
        {
            int len = server.Receive(data);
            if (len > 0)
            {
                byte[] rec = new byte[len];
                Buffer.BlockCopy(data, 0, rec, 0, len);
                OnMesageCallback?.Invoke(rec);
            }
        }
    }
    public void SendMessage(string content, IPEndPoint endPoint)
    {
        byte[] sed = Encoding.UTF8.GetBytes(content);
        server.SendTo(sed, endPoint);
    }
}

UDPManager

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

public class UDPManager : MonoBehaviour
{
    public static UDPManager instance;
    private UDPClient client;
    private void Awake()
    {
        instance = this;
    }
    // Start is called before the first frame update
    void Start()
    {
        client = new UDPClient();
        client.OnMesageCallback += OnMessageCallback;
    }
    private void OnMessageCallback(byte[] rec)
    {
        string result = Encoding.UTF8.GetString(rec);
        Debug.Log(result);
    }
    public void Send(string content)
    {
        client.SendMessage(content, new System.Net.IPEndPoint(System.Net.IPAddress.Parse("10.19.201.92"), 7777));
    }
    public void Send(byte[] content)
    {
        client.SendMessage(content, new System.Net.IPEndPoint(System.Net.IPAddress.Parse("10.19.201.92"), 7777));
    }
}