如何保持TCP連接與Java保持一致？

1）創建一個偵聽本地計算機中特定端口號的TCP套接字。（服務器）

2）創建另一個TCP套接字將連接到我創建的第一個TCP套接字（客戶端）

3）通過客戶端的一些數據發送到服務器。

4）由客戶端從服務器接收數據。

5）不要關閉連接..等了一小會兒..

6）從服務器接收更多的數據。

這裏是我的代碼：

public class MyTCPServer { 

    public static void main(String argv[]) throws Exception { 
     String clientSentence; 
     String capitalizedSentence; 
     ServerSocket welcomeSocket = new ServerSocket(6789); 
     while (true) { 
      Socket connectionSocket = welcomeSocket.accept(); 
      BufferedReader inFromClient = new BufferedReader(new InputStreamReader(connectionSocket.getInputStream())); 
      DataOutputStream outToClient = new DataOutputStream(connectionSocket.getOutputStream()); 
      clientSentence = inFromClient.readLine(); 
      System.out.println("Received: " + clientSentence); 
      capitalizedSentence = clientSentence.toUpperCase() + '\n'; 
      outToClient.writeBytes(capitalizedSentence); 
      outToClient.writeBytes(String.valueOf(System.currentTimeMillis())); 
      Thread.sleep(1000); 
      outToClient.writeBytes(String.valueOf(System.currentTimeMillis())); 
     } 
    } 

}

所以這個TCP套接字偵聽端口6789請注意，它從客戶端發送回接收到的字符串，它轉換爲大寫並返回回來。然後服務器發送currentTimeMillis，等待1000毫秒，然後再次發送timeMillis。

這裏是我的客戶：

public class MyTCPClient { 

    public static void main(String[] args) throws Exception { 
     String sentence; 
     String modifiedSentence; 
     BufferedReader inFromUser = new BufferedReader(new InputStreamReader(System.in)); 
     Socket clientSocket = new Socket("localhost", 6789); 
     DataOutputStream outToServer = new DataOutputStream(clientSocket.getOutputStream()); 
     BufferedReader inFromServer = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); 
     sentence = inFromUser.readLine(); 
     outToServer.writeBytes(sentence + '\n'); 
     modifiedSentence = inFromServer.readLine(); 
     System.out.println("FROM SERVER: " + modifiedSentence); 
    } 

}

但是當我測試我的代碼，我得到：

Received: asdf 
Exception in thread "main" java.net.SocketException: Connection reset by peer: socket write error 
    at java.net.SocketOutputStream.socketWrite0(Native Method) 
    at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92) 
    at java.net.SocketOutputStream.write(SocketOutputStream.java:115) 
    at java.io.DataOutputStream.writeBytes(DataOutputStream.java:259) 
    at MyTCPServer.main(MyTCPServer.java:28) 
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) 
    at java.lang.reflect.Method.invoke(Method.java:597) 
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:120)

我怎能在客戶端活着有什麼聯繫？此外，我希望能夠從客戶端發送更多文本。

來源

2014-02-22 Koray Tugay

你必須在服務器上的循環「保持連接」，那麼爲什麼你沒有一個在客戶端？ –

最簡單的事情就是在客戶端代碼中放置一個循環。事情是這樣的：

while ((modifiedSentence = inFromServer.readLine()) != null) { 
     System.out.println("FROM SERVER: " + modifiedSentence); 
     sentence = inFromUser.readLine(); 
     outToServer.writeBytes(sentence + '\n'); 
    }

在等待來自服務器的消息，因此客戶端將不會退出readLine()方法塊。

參見下文如何編寫一個socket服務器和客戶端一個簡單的教程：

http://docs.oracle.com/javase/tutorial/networking/sockets/clientServer.html

來源

2014-02-22 17:32:39 dcernahoschi