如何通過java中的服務器啓動客戶端更新

Question

我有一個客戶端/服務器應用程序來管理某種類型的行。 所有的客戶添加對象到我的線。

我希望服務器每當線路，線路插入或移除發生變化時，都會向客戶端發送jpanel的屏幕截圖。 我設法捕捉jpanel jpag甚至發送它。 但我的應用程序的流程停止，第一次更新後我得到eofexception，終止我的偵聽服務器套接字。

什麼是更新客戶端的正確方法？我是否應該設置一個serversocket以便始終在客戶端進行監聽？

請幫助，我堅持這個爲2周。

這是我的監聽線程（服務器）：

public class ListeningThread implements Runnable { 

static boolean listening = true;  
public BufferedReader in; 


public void run() { 

    ServerSocket echoServer = null; 
    String line; 
    DataInputStream is = null; 
    PrintStream os = null; 
    Socket clientSocket = null; 

    try { 
     echoServer = new ServerSocket(RequestReciever._communicationPort); 
    } 
    catch (IOException e) { 
     System.out.println(e); 

    } 

// Create a socket object from the ServerSocket to listen and accept 
// connections. 
// Open input and output streams 

try { 


// As long as we receive data, send it to be phrased to a request. 
     while (true) { 

     clientSocket = echoServer.accept(); 
     is = new DataInputStream(clientSocket.getInputStream()); 
     os = new PrintStream(clientSocket.getOutputStream()); 

// An option for a stop listening button. currently not available ! 
     if(listening==true) { 
     line = is.readUTF(); 
     os.println(line); 
     System.out.println(line); 
     RequestReciever.pharseToRequest(line); 
//   clientSocket = null; 


     } 
     else { 
       echoServer.close(); 
       is.close(); 
       os.close(); 
       break; 
      } 
     } 

} 

catch (IOException e) { 
     e.printStackTrace(); 
     System.out.println("Listening Thread Unknown error"); 
    } 
} 
} 

這是我Pharse方法：

public static void pharseToRequest(String input) { 

    List<String> list = new ArrayList<String>(Arrays.asList(input.split(";;;"))); 
    if (list.get(0).equalsIgnoreCase("Login") && list.get(1).equalsIgnoreCase ("Login") && list.get(2).equalsIgnoreCase("5")) 
    { 
     _adminClients.add(list.get(4)); 
     updateScreenCapture(); 
     AdminClientUpdate tmp = new AdminClientUpdate(list.get(4)); 
     Thread aCU = new Thread (tmp); 
     aCU.start(); 
    } 
    else 
    { 
    ServerRequest newReq = new ServerRequest(list.get(0), list.get(1), Integer.parseInt(list.get(2)),list.get(3),list.get(4)); 
    addRequest(newReq); 
    } 
} 

，這是AdminClientUpdate類

public class AdminClientUpdate implements Runnable { 

static boolean listening = true;  
public BufferedReader in; 
public String _ip; 

public AdminClientUpdate(String ip) 
{ 
    _ip = ip; 
} 

public void run() { 

     try { 
      Socket socket = new Socket(_ip, RequestReciever._communicationPort); 
      InputStream in = new FileInputStream("Capture/tmp.jpg"); 
      java.io.OutputStream out = socket.getOutputStream(); 

      copy(in, out); 
      System.out.println("Sent Image !"); 
      socket.close(); 
      out.close(); 
      in.close(); 

     } catch (UnknownHostException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } catch (FileNotFoundException e) { 
      System.out.println("Cant find tmp.jpg"); 
      e.printStackTrace(); 
     } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
    } 


    static void copy(InputStream in, java.io.OutputStream out) throws IOException { 
      byte[] buf = new byte[8192]; 
      int len = 0; 
      while ((len = in.read(buf)) != -1) { 
       out.write(buf, 0, len); 
      } 
      in.close(); 
      out.close(); 
    } 
} 

Answer 1

在經歷了幾次大腦崩潰之後，我決定在客戶端安裝一個服務器套接字來偵聽來自服務器的更新是最好的方法。 我修正了幾件事情： *服務器應該啓動一個新線程來處理每個接受的連接，而不是在接受線程中處理每一個內聯。 *我試圖通過服務器套接字獲取第一次更新，而不是登錄初始化。 現在，在登錄後獲得第一次更新後，我在客戶端添加了一個服務器套接字，因此它將繼續監聽來自服務器的進一步更新。

Answer 2

消除這種

echoServer.close(); 

這一行關閉套接字。由此導致連接中止。