package com.javapp.ch11;
 import java.io.*;
 import java.net.*;
 /**
 * Description: 具有“回顯”功能的服務(wù)器端和客戶端程序
 */
 public class EchoClientDemo {
     // 服務(wù)器端的服務(wù)端口。
     public static final int SERVERPORT = 990;
     public static void main(String[] args) {
         try {
             // 建立連接套接字。
             Socket s = new Socket("localhost",SERVERPORT);
             System.out.println("socket = " + s);
             // 新建網(wǎng)絡(luò)連接的輸入流。
             BufferedReader in = new BufferedReader(new InputStreamReader(s
                     .getInputStream()));
             // 新建網(wǎng)絡(luò)連接的自動刷新的輸出流。
             PrintWriter out = new PrintWriter(new BufferedWriter(
                     new OutputStreamWriter(s.getOutputStream())),true);
             // 先使用System.in構(gòu)造InputStreamReader，再構(gòu)造BufferedReader。
             BufferedReader stdin = new BufferedReader(
                     new InputStreamReader(System.in));
             System.out.println("Enter a string， Enter BYE to exit! ");
             while (true) {
                 // 讀取從控制臺輸入的字符串，并向網(wǎng)絡(luò)連接輸出，即向服務(wù)器端發(fā)送數(shù)據(jù)。
                 out.println(stdin.readLine());
                 // 從網(wǎng)絡(luò)連接讀取一行，即接收服務(wù)器端的數(shù)據(jù)。
                 String str = in.readLine();
         // 如果接收到的數(shù)據(jù)為空（如果直接按Enter，不是空數(shù)據(jù)），則退出循環(huán)，關(guān)閉連接。
                 if (str == null) {
                     break;
                 }
                 System.out.println(str);
             }
             s.close();
         } catch (IOException e) {
             System.err.println("IOException" + e.getMessage());
         }
     }
 }

package com.javapp.ch11;
 import java.io.*;
 import java.net.*;
 /**
 * Description:支持多客戶端的“回顯”服務(wù)器端程序
 */
 public class EchoServerThreadDemo {
     // 服務(wù)器端的服務(wù)端口。
     public static final int SERVERPORT = 990;
     public static void main(String[] args) {
         try {
             // 已經(jīng)連接上的客戶端的序號。
             int number = 1;
             // 建立服務(wù)器端傾聽套接字。
             ServerSocket s = new ServerSocket(SERVERPORT);
             System.out.println("Started: " + s);
             while (true) {
                 // 等待并接收請求，建立連接套接字。
                 Socket incoming = s.accept();
                 System.out.println("Connection " + number + " accepted: ");
                 System.out.println(incoming);
                 // 啟動一個線程來進行服務(wù)器端和客戶端的數(shù)據(jù)傳輸。
                 // 主程序繼續(xù)監(jiān)聽是否有請求到來。
                 Thread t = new EchoThread(incoming,number);
                 t.start();
                 number++;
             }
         } catch (IOException e) {
             System.err.println("IOException");
         }
     }
 }
 class EchoThread extends Thread {
     private Socket s;
     int n;
     public EchoThread(Socket incoming,int number) {
         s = incoming;
         n = number;
     }
     public void run() {
         try {
             // 新建網(wǎng)絡(luò)連接的輸入流。
             BufferedReader in = new BufferedReader(new InputStreamReader(s
                     .getInputStream()));
             // 新建網(wǎng)絡(luò)連接的自動刷新的輸出流。
             PrintWriter out = new PrintWriter(new BufferedWriter(
                     new OutputStreamWriter(s.getOutputStream())),true);
             System.out.println("Hello! Enter BYE to exit.");
             // 回顯客戶端的輸入。
             while (true) {
                 // 從網(wǎng)絡(luò)連接讀取一行，即接收客戶端的數(shù)據(jù)。
                 String line = in.readLine();
         // 如果接收到的數(shù)據(jù)為空（如果直接按Enter，不是空數(shù)據(jù)），則退出循環(huán)，關(guān)閉連接。
                 if (line == null) {
                     break;
                 } else {
                     if (line.trim().equals("BYE")) {
                         System.out.println("The client " + n + " entered BYE!");
                         System.out.println("Connection " + n + " will be closed!");
                         break;
                     }
                     System.out.println("Echo " + n + ": " + line);
                     // 向網(wǎng)絡(luò)連接輸出一行，即向客戶端發(fā)送數(shù)據(jù)。
                     out.println("Echo " + n + ": " + line);
                 }
             }
             // 關(guān)閉套接字。
             s.close();
         } catch (IOException e) {
             System.err.println("IOException");
         }
     }
 }