シンプルなクライアントサーバーのJavaプログラムがループしていない

Question

割り当てを行うときに私は不本意なブロックを見つけました。シンプルなサーバーとクライアントプログラムです。 このプログラムの詳細は次のとおりです。

1. 着信接続をリッスンするサーバークラスEncryptServerを作成します。接続がある場合は、それを受け入れて入出力ストリームを処理するスレッドEncryptServerSessionを作成します。
2. サーバークラスから入力ストリームと出力ストリームを取り込み、処理するスレッドクラスEncryptServerSessionを作成します。
3. サーバークラスに接続するクライアントクラスEncryptClientを作成し、出力ストリームをEncryptServerSessionからEncryptServerにします。

EncryptClientクラスのwhileループはどうにか動作しません。私はループに入ることができない。私のコードに何か問題がありますか？前もって感謝します。

EncryptServer

import java.net.*; 
import java.io.*; 

public class EncryptServer 
{  
    public EncryptServer() throws IOException 
    { 
     ServerSocket serverSocket = new ServerSocket(1122); 
     System.out.println("Server started."); 

     while (true) 
     { 
      Socket conSocket = serverSocket.accept(); 
      System.out.println("Client connected from " + 
conSocket.getLocalAddress().getHostName()); 

      Thread session = new 
EncryptServerSession(conSocket.getInputStream(), 
conSocket.getOutputStream()); 
      session.start(); 
    } 
} 
public static void main(String[] args) 
{ 
    try 
    { 
     EncryptServer server = new EncryptServer(); 
    } 
    catch (Exception e) 
    { 
     System.out.println(e); 
    }          
} 

} 

EncryptServerSession

import java.net.*; 
    import java.io.*; 

public class EncryptServerSession extends Thread 
{ 
    BufferedReader in; 
    Writer out; 

public EncryptServerSession(InputStream inStream, OutputStream outStream) 
{ 
    Reader read = new InputStreamReader(inStream); 
    in = new BufferedReader(read); 
    out = new OutputStreamWriter(outStream); 
} 

public void strEncrypt() 
{ 
    try 
    { 
     String message = in.readLine(); 
     out.write(message); 
     out.flush(); 
    } 
    catch (Exception e) 
    { 
    } 
} 

public void run() 
{ 
    try 
    { 
     //System.out.println(in.readLine()); 
     out.write("Please enter the message to be encrypted: "); 
     out.flush(); 

     //strEncrypt(); 

    } 
    catch (Exception e) 
    { 
     System.out.println(e); 
    } 

} 
} 

EncryptClient

import java.net.*; 
import java.io.*; 


public class EncryptClient 
{ 
BufferedReader input, userTerm; 
Writer output; 
String line; 

public EncryptClient() throws IOException 
{ 
    Socket clientSocket = new Socket("localhost", 1122); 
    Reader read = new InputStreamReader(clientSocket.getInputStream()); 
    input = new BufferedReader(read); 

    userTerm = new BufferedReader(new InputStreamReader(System.in)); 
    output = new OutputStreamWriter(clientSocket.getOutputStream());    

    /////////////// Somehow I cannot get into this loop, why? ////////// 
    while (true) 
    { 
     System.out.println("test "); 
     System.out.println(input.readLine()); 
     System.out.println("Enter message to be encrypted: "); 
     output.write(userTerm.readLine());   
     output.flush(); 
    } 
    /////////////// Somehow I cannot get into this loop, why? ////////// 
} 

public static void main(String[] args) 
{ 
    try 
    { 
     EncryptClient client = new EncryptClient(); 
    } 
    catch (Exception e) 
    { 
     System.out.println(e); 
    } 
} 

}

Answer 1

私が理解しているように、サーバーにメッセージを送信し、ロジックを行い、それをクライアントに送り返そうとしています。上記のコードは私の側でうまくいくようです。ここに私がしたことがあります：

• EncryptServer最初に実行します。私はこれがあなたが直面している問題だと思います。またはあなたのファイアウォールがソケットで聞くことができないかもしれません。

• EncryptServerSessionで、あなたは行を読み込んでいますが、行を書きません。終了した後にcloseストリームを書き込むか、新しい行を書き込んでください。

  ... 
  
  out.write(message); 
  out.write("\r\n"); // write new line 
  out.flush(); 
  
  ... 
  
  } finally { 
      try { 
       out.close(); 
      } catch (IOException e) { 
      } 
  } 
  

  OR

  ... 
  
  out.write(message); 
  out.write("\r\n"); // write new line 
  out.flush(); 
  
  ...