1

我有一个带有 Socket 的 java 程序。我需要检查客户端是否已断开连接。我需要一个如何做到这一点的例子。我研究过,但我不明白。所以有人可以制作示例代码并解释一切。

抱歉我的代码英语不好:

    package proov_server;

//SERVER 2
import java.io.*;
import java.net.*;

class server2 {
    InetAddress[] kasutaja_aadress = new InetAddress[1000];
    String newLine = System.getProperty("line.separator");
    int kliendiNr = 0;
    int kilene_kokku;
  server2(int port) {

    try {

      ServerSocket severi_pistik = new ServerSocket(port);
        System.out.println("Server töötab ja kuulab porti " + port + ".");


      while (true) {

        Socket pistik = severi_pistik.accept();
        kliendiNr++;

        kasutaja_aadress[kliendiNr] = pistik.getInetAddress();
        System.out.println(newLine+"Klient " + kliendiNr + " masinast "
                      + kasutaja_aadress[kliendiNr].getHostName() + " (IP:"
                      + kasutaja_aadress[kliendiNr].getHostAddress() + ")");

        // uue kliendi lõime loomine
        KliendiLoim klient = new KliendiLoim(pistik,kliendiNr);

        // kliendi lõime käivitamine
        klient.start();

      }
    }
    catch (Exception e) {
      System.out.println("Serveri erind: " + e);
    }
  }

  DataOutputStream[] väljund = new DataOutputStream[1000];
  DataInputStream[] sisend = new DataInputStream[1000];

  int klient = 0;
  int nr;
  // sisemine klass ühendusega tegelemiseks
      class KliendiLoim extends Thread {

        // kliendi pistik

      Socket pistik;
        // kliendi number


        KliendiLoim(Socket pistik2,int kliendiNr) {
          nr = kliendiNr;
          this.pistik = pistik2;

        }
        public boolean kontroll(){
            try{
                System.out.println("con "+pistik.isConnected());
                System.out.println("close "+pistik.isClosed());
                if(pistik.isConnected() &&  !pistik.isClosed()){
                    //System.out.print(con_klient);
                    return true;

                }
            }catch(NullPointerException a){
                System.out.println("Sihukest klienti pole!!!");

            }
            kliendiNr --;
            return false;

        }

        public void run() {
              try { 
                    sisend[nr] = new DataInputStream(pistik.getInputStream()); //sisend
                    väljund[nr] = new DataOutputStream(pistik.getOutputStream()); //väljund 
              }catch (Exception ea) {
                    System.out.println(" Tekkis erind: " + ea);
              }   
              while(true){
                      try{


                        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));

                        System.out.print("Sisesta k2sk: ");
                        String k2sk = null;
                        k2sk = br.readLine();
                        /*
                        String command;
                        if(k2sk.indexOf(" ") < 0){
                            command = k2sk;
                        }else{
                            command = k2sk.substring(0, k2sk.indexOf(" "));
                        }
                        */
                        String[] words = k2sk.split("\\s+");
                        for (int i = 0; i < words.length; i++) {
                            words[i] = words[i].replaceAll(" ", "");
                        }
                        switch(words[0]){
                        case "suhtle":

                            if(väljund.length > klient && väljund[klient] != null)
                            {
                                väljund[klient].writeUTF("1");


                            }else{
                                väljund[klient] = null;
                                sisend[klient] = null;
                                System.out.println("Sihukest klienti pole");
                            }
                        break;
                        case "vaheta":
                            try{
                                int klinetnr = Integer.parseInt(words[1]);
                                //if(kontroll(klinetnr) ){
                                    klient = Integer.parseInt(words[1]);
                                //}
                            }
                            catch(NumberFormatException e){
                                System.out.println("See pole number!!! ");
                            }
                        break;

                        case "kliendid":
                            if(kliendiNr != 0){
                                for(int i=1;i <= kliendiNr;i++){
                                    if(kontroll()){
                                        System.out.println("Klient:"+i+" ip: " + kasutaja_aadress[i] );
                                    }else{
                                        System.out.println("Pisi");
                                        väljund[klient] = null;
                                        sisend[klient] = null;
                                    }
                                }
                                System.out.println(newLine);
                            }else{
                                System.out.println("Kiente pole");
                            }
                        break;

                        }
                      System.out.println(kliendiNr);
                    }catch(SocketException a){
                        System.out.println("Klient kadus");

                    }
                    catch(Exception e){
                         System.out.println(" Viga: " + e);
                    }

          }
        }



  }
  public static void main(String[] args) {
        new server2(4321);

  }
}
4

2 回答 2

10

如果客户端已正确断开连接:

  • read()将返回 -1
  • readLine()返回空
  • readXXX()对于任何其他 X throws EOFException

检测丢失的 TCP 连接的唯一真正可靠的方法是写入它。最终这将抛出一个IOException: connection reset,但由于缓冲,它至少需要两次写入。

于 2013-07-26T19:19:47.663 回答
1

Stackoverflow 上的相关线程以及解决方案。基本上,该解决方案说检测客户端-服务器断开连接的最佳方法是尝试从套接字读取。如果读取成功,则连接处于活动状态。如果在读取过程中抛出异常,则客户端和服务器之间没有连接。或者,可能会为套接字配置一个超时值以完成读取操作。如果超过此超时,将抛出套接字超时异常,这可以被认为是客户端断开连接或网络关闭。

该帖子还谈到了使用isReachable方法 - 请参阅InetAddress 文档。然而,这个方法只告诉我们远程主机是否可达。这可能只是 客户端与服务器断开连接的原因之一由于客户端崩溃或使用此技术终止,您将无法检测到断开连接。

于 2013-07-26T18:05:01.030 回答