Программа C # Server не может обнаружить неработающую ссылку

Question

Ниже приведены основные скелеты моего сервера .net и клиентских программ на Java:

Скелет сервера C #

class ServerProgram
{
    static string origClientID = string.Empty;
    static string reqClientID = string.Empty;
    static string stKey = string.Empty;
    static string stValue = string.Empty;
    static Dictionary<string, KeyValue> KeyValueDictionary;
    static Dictionary<string, ClientClass> ClientDictionary;

    static void Main(string[] args)
    {
        Console.Title = "Server";
        Console.WriteLine("Server program started on address [" + Constants.SERVER_IP +":"+Constants.PORT_NO+"]");

        KeyValueDictionary = new Dictionary<string, KeyValue>();
        ClientDictionary = new Dictionary<string, ClientClass>();

        string ipAddress = Constants.SERVER_IP;
        int portNo = Constants.PORT_NO;

        IPAddress ip = IPAddress.Parse(ipAddress);            
        TcpListener listener = new TcpListener(ip, portNo);            

        // poll for clients in a 2nd thread
        Thread thread = new Thread(delegate()
        {
            ServerProgram.PollIncomingClientConns(listener);
        });

        thread.Start();
    }

    #region catching client connections
    static void PollIncomingClientConns(TcpListener listener)
    {
        listener.Start();

        try
        {
            bool keepRunning = true;

            while (keepRunning)
            {
                ClientClass client = new ClientClass(listener);

                ClientDictionary.Add(client.ID, client);

                Thread thread = new Thread(delegate()
                {
                    ServerProgram.ReadFromClient(client);
                });
                thread.Start();
            }
        }
        catch (Exception ex)
        {
            var inner = ex.InnerException as SocketException;
            if (inner != null && inner.SocketErrorCode == SocketError.ConnectionReset)
                Console.WriteLine("Disconnected");
            else
                Console.WriteLine(ex.Message);

            listener.Stop();
        }
    } 
    #endregion     

    static void ReadFromClient(ClientClass client)
    {
       try
        {
            while (client.Tcp.Connected)
            {
                string str = client.Read();
                Console.WriteLine("[" + client.ID + "] says: " + str);

                switch(str)
                {
                    case Commands.AddKeyValue:
                        //...                        
                        break;

                    case Commands.ListKeys:
                        //...
                        break;

                    case Commands.UpdateValue: 
                        //...
                        break;

                    case Commands.Yes:                            
                        //...
                        break;
                }
            }
        }
        catch
        {
            client.Disconnect();
        }
    }
}

Скелет клиента Java

public class FirstJavaClientProgramTest  
{ 
    final static String LOCAL_HOST = "127.0.0.1";
    final static int PORT_NO = 4321; 

    public static void main(String args[]) throws UnknownHostException, IOException  
    { 
        try
        {
            Consolas.WriteLine("Hit enter twice to connect to localhost...\n");

            Consolas.WriteLine("Enter server IP : ");
            String ip = Consolas.ReadLine();

            Consolas.WriteLine("Enter server port : ");
            String portStr = Consolas.ReadLine();

            int port = -99;
            if(ip.equals("\n") || ip.equals("")) 
            {
                ip = LOCAL_HOST;
            } 

            if(!ip.equals("\n") || !ip.equals(""))
            { 
                port = PORT_NO;
            }
            else 
            {
                port = Integer.parseInt(portStr);
            }

            // establish the connection 
            Socket socket = new Socket(ip, port); 

            //send the client ID
            String ID = AlphaNumRandom.randomString(5);
            Consolas.WriteLine(ID);

            BinaryWriter writer = new BinaryWriter(socket);
            writer.Write(ID);

            ReaderRunnableClass readRunnable = new ReaderRunnableClass(socket);        
            Thread readThread = new Thread(readRunnable);        
            readThread.start();

            WriterRunnableClass writeRunnable = new WriterRunnableClass(socket);        
            Thread writeThread = new Thread(writeRunnable);        
            writeThread.start();
        }
        catch(Exception ex)
        {
            Consolas.WriteLine("Failed to connect to the server!");
            //Consoles.WriteLine(ex.getMessage());
        }
    }//:~ main
}//:~ class

Проблема с программой сервера.

Серверная программа может обнаружить отключенного клиента, если клиент явно закрыт пользователем.

Но серверная программа не может явно обнаружить

1. в случае сбоя клиента и / или
2. в случае сбоя сетевого соединенияво время общения

Как я могу это обнаружить?

Answer 1

Я думаю, что вам нужно создать метод, перебрать ClientDictionary, чтобы проверить, живы ли клиентские связи. Посмотрите здесь: Мгновенное обнаружение отключения клиента от сокета сервера

Answer 2

Вы должны периодически отправлять сообщения активности всем подключенным клиентам. Проверьте эту статью Обнаружение полуоткрытых (удаленных) соединений . Я действительно рекомендую вам прочитать всю серию FAQ по сокетам TCP / IP .NET . Здесь вы можете проверить пример реализации C # в методе KeepAlive.