我已经设置了一个 PC 内通信服务器/客户端，用于从一个程序向另一个程序发送和接收数据 - 在本例中，是一个正在监听文本命令和 Unity3D 的自定义服务器。

在大多数情况下，它是有效的，但是每隔一段时间，它就会丢包，如果不多次尝试，Unity 将无法获得它们。数据包似乎已发送但丢失了，因为我确实看到了“已发送消息”控制台日志。以下是服务端和客户端的代码:

服务器:

class TCPGameServer
{
    public event EventHandler Error;

    public Action<Data> ADelegate;

    TcpListener TCPListener;
    TcpClient TCPClient;
    Client ActiveClient;

    NetworkStream networkStream;

    StreamWriter returnWriter;
    StreamReader streamReader;

    Timer SystemTimer = new Timer();
    Timer PingTimer = new Timer();

    int Port = 8637;

    public TCPGameServer()
    {
        TCPListener = new TcpListener(IPAddress.Loopback, Port);
        SystemTimer.Elapsed += StreamTimer_Tick;
        SystemTimer.AutoReset = true;
        SystemTimer.Interval = 2000;

        PingTimer.Elapsed += PingTimer_Tick;
        PingTimer.AutoReset = true;
        PingTimer.Interval = 30000;
    }

    public void OpenListener()
    {
        TCPListener.Start();
        TCPListener.BeginAcceptTcpClient(AcceptTCPCallBack, null);
        Console.WriteLine("Network Open.");
    }

    public void GameLogout()
    {
        SystemTimer.AutoReset = false;
        SystemTimer.Stop();

        PingTimer.AutoReset = false;
        PingTimer.Stop();

        ActiveClient = null;

        returnWriter.Dispose();
        streamReader.Dispose();

        Console.WriteLine("The client has logged out successfully.");
    }

    private void AcceptTCPCallBack(IAsyncResult asyncResult)
    {
        TCPClient = null;
        ActiveClient = null;
        returnWriter = null;
        streamReader = null;

        try
        {
            TCPClient = TCPListener.EndAcceptTcpClient(asyncResult);

            TCPListener.BeginAcceptTcpClient(AcceptTCPCallBack, null);


            ActiveClient = new Client(TCPClient);
            networkStream = ActiveClient.NetworkStream;

            returnWriter = new StreamWriter(TCPClient.GetStream());
            streamReader = new StreamReader(TCPClient.GetStream());

            Console.WriteLine("Client Connected Successfully.");

            Data Packet = new Data();
            Packet.cmdCommand = Command.Login;
            Packet.strName = "Server";
            Packet.strMessage = "LOGGEDIN";
            SendMessage(Packet);


            SystemTimer.AutoReset = true;
            SystemTimer.Enabled = true;
            SystemTimer.Start();

            Ping();

            PingTimer.AutoReset = true;
            PingTimer.Enabled = true;
            PingTimer.Start();

        } catch (Exception ex)
        {
            OnError(TCPListener, ex);
            return;
        }


    }

    private void StreamTimer_Tick(object source, System.Timers.ElapsedEventArgs e)
    {
        CheckStream();
    }

    private void PingTimer_Tick(object source, System.Timers.ElapsedEventArgs e)
    {
        Ping();
    }

    private void Ping()
    {
        if (TCPClient.Connected)
        {
            Data Packet = new Data();
            Packet.cmdCommand = Command.Ping;
            Packet.strName = "Server";
            Packet.strMessage = "PING";

            SendMessage(Packet);
        }
    }


    public void CheckStream()
    {
        try
        {
            if (TCPClient.Available > 0 || streamReader.Peek() >= 0)
            {
                string PacketString = streamReader.ReadLine();
                Data packet = JsonConvert.DeserializeObject<Data>(PacketString);

                switch (packet.cmdCommand)
                {
                    case Command.Logout:
                        GameLogout();
                        break;
                    case Command.Message:
                        if (ADelegate != null)
                        {
                            ADelegate(packet);
                        }
                        break;
                    case Command.Ping:
                        Console.WriteLine("PONG!");
                        break;
               }
            }
        } catch (IOException e)
        {
            Console.WriteLine(e.Message);
        } catch (NullReferenceException e)
        {
            Console.WriteLine(e.Message);
        }
    }

    public void SendMessage(Data packet)
    {
        if (ActiveClient != null)
        {
            string packetMessage = JsonConvert.SerializeObject(packet);
            returnWriter.WriteLine(packetMessage);
            returnWriter.Flush();
        }
    }


    public void OnError(object sender, Exception ex)
    {
        EventHandler handler = Error;
        if (handler != null)
        {
            ErrorEventArgs e = new ErrorEventArgs(ex);
            handler(sender, e);
        }
    }

    public void RegisterActionDelegate(Action<Data> RegisterDelegate)
    {
        ADelegate += RegisterDelegate;
    }

    public void UnRegisterActionDelegate(Action<Data> UnregisterDelegate)
    {
        ADelegate -= UnregisterDelegate;
    }
} 

客户:

public class TCPNetworkClient
{

    public Action<Data> PacketDelegate;

    public TcpClient TCPClient;
    int Port = 8637;

    StreamReader streamReader;
    StreamWriter streamWriter;

    Timer StreamTimer = new Timer();

    public bool LoggedIn = false;



    public void Start()
    {
        if (LoggedIn == false)
        {
            TCPClient = null;
            StreamTimer.AutoReset = true;
            StreamTimer.Interval = 2000;
            StreamTimer.Elapsed += StreamTimer_Tick;


            try
            {
                TCPClient = new TcpClient("127.0.0.1", Port);

                streamReader = new StreamReader(TCPClient.GetStream());
                streamWriter = new StreamWriter(TCPClient.GetStream());

                StreamTimer.Enabled = true;
                StreamTimer.Start();
            }
            catch (Exception ex)
            {
                Debug.Log(ex.Message);
            }
        }

    }

    private void StreamTimer_Tick(System.Object source,    System.Timers.ElapsedEventArgs e)
    {
        if (TCPClient.Available > 0 || streamReader.Peek() >= 0)
        {
            string PacketString = streamReader.ReadLine();
            Data packet = JsonConvert.DeserializeObject<Data>(PacketString);

            PacketDelegate(packet);
        } 
    }

    public void Logout()
    {
        Data Packet = new Data();
        Packet.cmdCommand = Command.Logout;
        Packet.strMessage = "LOGOUT";
        Packet.strName = "Game";
        SendMessage(Packet);

        if (streamReader != null && streamWriter != null)
        {
            streamReader.Dispose();
            streamWriter.Dispose();
            TCPClient.Close();
            TCPClient = null;
            streamReader = null;
            streamWriter = null;
        }

        StreamTimer.Stop();
    }

    public void SendMessage(Data packet)
    {
        string packetMessage = JsonConvert.SerializeObject(packet);

        try
        {
            streamWriter.WriteLine(packetMessage);
            streamWriter.Flush();
        } catch (Exception e)
        {

        }
    }

    public void RegisterActionDelegate(Action<Data> RegisterDelegate)
    {
        PacketDelegate += RegisterDelegate;
    }

    public void UnRegisterActionDelegate(Action<Data> UnregisterDelegate)
    {
        PacketDelegate -= UnregisterDelegate;
    }
}

我不太确定发生了什么，或者我是否需要在系统中添加更多额外的检查。注意:它是 TCP，因此“当”这完全有效时，我可以将客户端放到我可能编写的可能不完全依赖或使用 Unity 的其他程序中。

最佳答案

1. new TcpClient("127.0.0.1", Port) 不适合客户端。只需使用 TcpClient()。不需要指定IP和端口，这两个最终都会出错。
2. TCPClient.Available 几乎总是一个错误。您似乎假设 TCP 是基于数据包的。您无法测试是否收到完整消息。 TCP 只提供无边界的字节流。因此，此 Available 检查不会告诉您整行是否可用。此外，可能有多行。正确的阅读方式是让一个阅读循环一直在运行，并且不检查就简单地阅读行。任何到达的行都将以这种方式处理。无需计时器等。
3. 服务器也有同样的问题。

问题 (2) 可能以某种方式导致丢失数据包的出现。无论如何你都需要解决这个问题。

关于c# - C# 中的一个非常简单的 TCP 服务器/客户端偶尔会丢弃数据包。我能做些什么来防止这种情况发生？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/38186406/