unity socket 异步通信

Question

客户端 和服务端 可以链接成功，并且客户端按空格可以发送消息给服务端，但是问题出现在 服务端发送消息 客户端收不到
实在不知道什么地方错误了
就服务端发送空格消息过不去
客户端

using UnityEngine;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System;
using System.Collections.Generic;
public class ClientState
{
    public Socket socket;
    public byte[] data = new byte[1024];
}
public class Server : MonoBehaviour
{
    private Socket server;
    EndPoint clientEnd = new IPEndPoint(IPAddress.Any, 0);   //实例化一个客户端端口 来给客户端发消息
    private Dictionary<Socket, ClientState> clients = new Dictionary<Socket, ClientState>();
    void Start()
    {
        server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //开启服务
        IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8888); //建立端口
        server.Bind(endPoint); //绑定端口 IP
        server.Listen(0);//监听客户端数量不限  
        Debug.Log("服务端启动成功：等待客户端连");
        server.BeginAccept(AcceptCallBack, server);  //开启异步监听接入
    }
    void AcceptCallBack(IAsyncResult ar)
    {
        Debug.Log("客户端接入成功：等待发送消息");
        Socket server = ar.AsyncState as Socket;  //状态结果
        Socket client = server.EndAccept(ar); //   接受结果  //返回这个通道

        Debug.Log($"{server.LocalEndPoint}---{client.RemoteEndPoint}");
        clientEnd = client.RemoteEndPoint;

        //下面3条是给字典赋值保存 这些人正在连接中
        ClientState clientState = new ClientState();  //实例化了一个客户端 数据
        clientState.socket = client;//客户数据的  socket复制
        clients.Add(client, clientState); //把客户的ip和端口保存起来


        //接收此客户端发来的信息
        //client.BeginReceive(clientState.data, 0, 1024, 0, ReceiveCallBack, clientState);  
        //继续监听新的客户端接入
        server.BeginAccept(AcceptCallBack, server); //进入无限循环监听
    }
    void ReceiveCallBack(IAsyncResult ar)
    {
        ClientState state = ar.AsyncState as ClientState;  //获取正在工作的socket
        Socket client = state.socket; //获取到这个socket
        int count = client.EndReceive(ar); //接受数据字符串
        if (count == 0)
        {
            client.Close();
            clients.Remove(client); //从保存的字典中删除 
            Debug.Log("客户端关闭");
            return;
        }
        string msg = Encoding.UTF8.GetString(state.data, 0, count);
        Debug.Log("收到客户端消息：" + msg);
        client.BeginReceive(state.data, 0, 1024, 0, ReceiveCallBack, state);
    }
    public void SendToServer(string sendStr)
    {
        byte[] sendData = new byte[1024]; //发送的数据，必须为字节
        sendData = Encoding.ASCII.GetBytes(sendStr);

        //创建发送参数
        SocketAsyncEventArgs sendEventArgs = new SocketAsyncEventArgs();
        sendEventArgs.RemoteEndPoint = clientEnd;
        //设置要发送的数据
        sendEventArgs.SetBuffer(sendData, 0, sendData.Length);
    }

    void Update()
    {

        if (Input.GetKeyDown(KeyCode.Space))
        {
            //按下空格向服务器发送消息
            SendToServer("ceshi");
        }
    }

}

服务端

using UnityEngine;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System;
public class Client : MonoBehaviour
{
    private Socket client;
    private byte[] data = new byte[1024];
    IPEndPoint endPoint;
    // Use this for initialization
    void Start()
    {
        client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        //ip："127.0.0.1"连接本地测试， 端口号：8888 服务器客户端端口号需相同
        endPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8888);
        client.BeginConnect(endPoint, OnConnectCallBack, client);
    }
    void OnConnectCallBack(IAsyncResult ar)
    {
        Socket socket = ar.AsyncState as Socket;
        socket.EndConnect(ar);
        Debug.Log("Connected sucess");
        socket.BeginReceive(data, 0, 1024, 0, OnReiceiveCallBack, socket);

    }
    void OnReiceiveCallBack(IAsyncResult ar)
    {
        Debug.Log("111");
        Socket socket = ar.AsyncState as Socket;
        int count = socket.EndReceive(ar);
        string recStr = Encoding.UTF8.GetString(data, 0, count);
        Debug.Log("收到服务器发送消息：" + recStr);
        //在此处继续接收信息
        socket.BeginReceive(data, 0, 1024, 0, OnReiceiveCallBack, socket);
    }

    public void SendToServer(string sendStr)
    {
        byte[] sendData = new byte[1024]; //发送的数据，必须为字节
        sendData = Encoding.ASCII.GetBytes(sendStr);

        //创建发送参数
        SocketAsyncEventArgs sendEventArgs = new SocketAsyncEventArgs();
        sendEventArgs.RemoteEndPoint = endPoint;
        //设置要发送的数据
        sendEventArgs.SetBuffer(sendData, 0, sendData.Length);
        //异步发送数据
        client.SendAsync(sendEventArgs);

    }
    void Update()
    {

        if (Input.GetKeyDown(KeyCode.Space))
        {
            //按下空格向服务器发送消息
            SendToServer("ceshi");
        }
    }
}

Answer 1

你搞错对象了呀
client是用来侦听的
socket 才是建立好的通信啊
可是你的socket 是个局部变量