diff --git a/src/j2/ThreadEchoClient.java b/src/j2/ThreadEchoClient.java index 0cc1b47..ccf9e2a 100644 --- a/src/j2/ThreadEchoClient.java +++ b/src/j2/ThreadEchoClient.java @@ -7,53 +7,51 @@ import java.net.Socket; import java.net.UnknownHostException; public class ThreadEchoClient { - public static void main(String[] args) { - // ソケットや入出力用のストリームの宣言 - Socket echoSocket = null; - DataOutputStream os = null; - BufferedReader is = null; - BufferedReader inputbr = null; - - // ポート9999番を開く - String host = "localhost"; - try { - echoSocket = new Socket(host, 9999); - os = new DataOutputStream(echoSocket.getOutputStream()); - is = new BufferedReader(new InputStreamReader(echoSocket.getInputStream())); - inputbr = new BufferedReader(new InputStreamReader(System.in)); - } catch (UnknownHostException e) { - System.err.println("Don't know about host: "+host); - } catch (IOException e) { - System.err.println("Couldn't get I/O for the connection to: "+host); - } + public static void main(String[] args) { + // ソケットや入出力用のストリームの宣言 + Socket echoSocket = null; + DataOutputStream os = null; + BufferedReader is = null; + BufferedReader inputbr = null; - // サーバーにメッセージを送る - if (echoSocket != null && os != null && is != null) { - try { - // メッセージを送ります - os.writeBytes("HELLO\n"); + // ポート9999番を開く + String host = "localhost"; + try { + echoSocket = new Socket(host, 9999); + os = new DataOutputStream(echoSocket.getOutputStream()); + is = new BufferedReader(new InputStreamReader(echoSocket.getInputStream())); + inputbr = new BufferedReader(new InputStreamReader(System.in)); + } catch (UnknownHostException e) { + System.err.println("Don't know about host: "+host); + } catch (IOException e) { + System.err.println("Couldn't get I/O for the connection to: "+host); + } - // サーバーからのメッセージを受け取り画面に表示します - String line; - while ((line = is.readLine()) != null) { - System.out.println("Server: " + line); - if (line.equals("quit")) break; - if (inputbr.ready()) { - String s = inputbr.readLine(); - System.out.println(s); - os.writeBytes(s+"\n"); - } - } + // サーバーにメッセージを送る + if (echoSocket != null && os != null && is != null) { + try { + // メッセージを送ります + os.writeBytes("HELLO\n"); - // 開いたソケットなどをクローズ - os.close(); - is.close(); - echoSocket.close(); - } catch (UnknownHostException e) { - System.err.println("Trying to connect to unknown host: " + e); - } catch (IOException e) { - System.err.println("IOException: " + e); - } - } - } + // サーバーからのメッセージを受け取り画面に表示します + String line; + while ((line = is.readLine()) != null) { + System.out.println("Server: " + line); + if (line.equals("quit")) break; + String s = inputbr.readLine(); + System.out.println(s); + os.writeBytes(s+"\n"); + } + + // 開いたソケットなどをクローズ + os.close(); + is.close(); + echoSocket.close(); + } catch (UnknownHostException e) { + System.err.println("Trying to connect to unknown host: " + e); + } catch (IOException e) { + System.err.println("IOException: " + e); + } + } + } } \ No newline at end of file