.NET TCP сервер сбрасывает соединения - PullRequest
Новая
       9

.NET TCP сервер сбрасывает соединения

2 голосов
/ 22 июня 2011

Некоторое время назад я написал небольшое приложение для реализации TCP-сервера, но, как новичок в C # .NET, я просто следовал учебному пособию. Часть авторизации работает нормально, но из-за того, что внимательно следит за учебником, после авторизации он сбрасывает соединение с tcpClient.Close ();

Как мне настроить этот код, чтобы прослушивать больше пакетов? Я думаю, что большинство серверов разрывают соединения через X минут, но я все еще новичок в этом типе вещей. 

// Starts the TCP RCON Server
public void StartServer()
{
    Console.WriteLine("RCON Server starting on Port: {0}", serverPort);

    this.tcpListener = new TcpListener(IPAddress.Any, serverPort);
    this.listenThread = new Thread(new ThreadStart(ListenForClients));
    this.listenThread.Start();

    Console.WriteLine("RCON Server has been Started.");
}

// Listen for Client Connections
private void ListenForClients()
{
    this.tcpListener.Start();

    while (true)
    {
        // blocks until a client has connected to the server
        TcpClient client = this.tcpListener.AcceptTcpClient();

        // Create a thread for client communication
        Thread clientThread = new Thread(new ParameterizedThreadStart(ReadClientPacket));
        clientThread.Start(client);
    }
}

private void ReadClientPacket(object client)
{
    TcpClient tcpClient = (TcpClient)client;
    NetworkStream clientStream = tcpClient.GetStream();

    bool terminate = false;

    while (!terminate)
    {
        try
        {
            int packetsize;

            // Create a new Packet Object and fill out the data from the incoming TCP Packets
            RCONPacket packet = new RCONPacket();

            using (BinaryReader reader = new BinaryReader(clientStream))
            {
                // First Int32 is Packet Size
                packetsize = reader.ReadInt32();

                packet.RequestId = reader.ReadInt32();
                packet.RconDataReceived = (RCONPacket.RCONDATA_rec)reader.ReadInt32();

                Console.WriteLine("Packet Size: {0} RequestID: {1} ServerData: {2}", packetsize, packet.RequestId, packet.RconDataReceived);

                // Read first and second String in the Packet (UTF8 Null Terminated)
                packet.String1 = ReadBytesString(reader);
                packet.String2 = ReadBytesString(reader);

                Console.WriteLine("String1: {0} String2: {1}", packet.String1, packet.String2);

                switch (packet.RconDataReceived)
                {
                    case RCONPacket.RCONDATA_rec.SERVERDATA_AUTH:
                    {
                        if (packet.String1 == "testpass")
                        {
                            Console.WriteLine("Password is Valid");
                            ReplyAuthRequest(packet.RequestId, tcpClient, packet.String1); // Junk Packet
                            ReplyAuthRequest(packet.RequestId, tcpClient, packet.String1);
                        }
                        else
                        {
                            Console.WriteLine("Password is Invalid");
                            ReplyAuthRequest(BAD_PASSWORD, tcpClient, packet.String1); // Junk Packet
                            ReplyAuthRequest(BAD_PASSWORD, tcpClient, packet.String1);

                            terminate = true;
                        }

                        break;
                    }
                    case RCONPacket.RCONDATA_rec.SERVERDATA_EXECCOMMAND:
                    {
                        Console.WriteLine("RCON Command Packet Received");
                        ReplyExecCommand(packet.RequestId, tcpClient);

                        break;
                    }
                    default:
                    {
                        break;
                    }
                }
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
            terminate = true;
        }
    }

    tcpClient.Close();
}

1 Ответ

4 голосов
/ 22 июня 2011

Если вы заметили, у вас много break заявлений.Я не совсем понимаю весь дизайн вашей программы, но если вы удалите их, а затем добавите проверку для значения boolean в цикле while, например while(!terminated) { .. }, это будет гарантировать, что всякий раз, когда ваше приложение сообщает программе о завершенииили чтобы прекратить прослушивание, цикл также будет прерван, потому что вы установите terminated в true.То, что вы говорите с помощью while(true), должно продолжаться вечно до тех пор, пока не произойдет break, который впоследствии выйдет из цикла while и вызовет .Close().

...