六、多客户端连接服务器

上面的服务器端程序一次只能连接一个客户端，这在实际应用中显然是不可能的。通常的网络环境是多个客户端连接到某个主机进行通讯，所以我们要对上面的程序进行改造。

设计思路：服务器端主程序监听某一个端口，客户端发起连接请求，服务器端主程序接收请求，同时构造一个线程类，用于接管会话。当一个Socket会话产生后，这个会话就会交给线程进行处理，主程序继续进行监听。

下面的实现程序流程是：客户端和服务器建立连接，客户端发送消息，服务端根据消息进行处理并返回消息，若客户端申请关闭，则服务器关闭此连接，双方通讯结束。

客户端程序：

1. package sock;
   
2. 
   
3. import java.io.BufferedReader;
   
4. import java.io.InputStreamReader;
   
5. import java.io.PrintWriter;
   
6. import java.net.Socket;
   
7.   
   
8. public class SocketClient {
   
9.     public static void main(String[] args) {
   
10.         try {
    
11.             Socket socket =new Socket("127.0.0.1",2013);
    
12.             socket.setSoTimeout(60000);
    
13.   
    
14.             PrintWriter printWriter =new PrintWriter(socket.getOutputStream(),true);
    
15.             BufferedReader bufferedReader =new BufferedReader(new InputStreamReader(socket.getInputStream()));
    
16.               
    
17.             String result ="";
    
18.             while(result.indexOf("bye") == -1){
    
19.                 BufferedReader sysBuff =new BufferedReader(new InputStreamReader(System.in));
    
20.                 printWriter.println(sysBuff.readLine());
    
21.                 printWriter.flush();
    
22.                   
    
23.                 result = bufferedReader.readLine();
    
24.                 System.out.println("Server say : " + result);
    
25.             }
    
26.   
    
27.             printWriter.close();
    
28.             bufferedReader.close();
    
29.             socket.close();
    
30.         }catch (Exception e) {
    
31.             System.out.println("Exception:" + e);
    
32.         }
    
33.     }
    
34. }

复制代码

服务器端程序：

1. package sock;
   
2. import java.io.*;
   
3. import java.net.*;
   
4.   
   
5. public class Server extends ServerSocket {
   
6.     private static final int SERVER_PORT =2013;
   
7.   
   
8.     public Server()throws IOException {
   
9.         super(SERVER_PORT);
   
10.   
    
11.         try {
    
12.             while (true) {
    
13.                 Socket socket = accept();
    
14.                 new CreateServerThread(socket);//当有请求时，启一个线程处理
    
15.             }
    
16.         }catch (IOException e) {
    
17.         }finally {
    
18.             close();
    
19.         }
    
20.     }
    
21.   
    
22.     //线程类
    
23.     class CreateServerThread extends Thread {
    
24.         private Socket client;
    
25.         private BufferedReader bufferedReader;
    
26.         private PrintWriter printWriter;
    
27.   
    
28.         public CreateServerThread(Socket s)throws IOException {
    
29.             client = s;
    
30.   
    
31.             bufferedReader =new BufferedReader(new InputStreamReader(client.getInputStream()));
    
32.               
    
33.             printWriter =new PrintWriter(client.getOutputStream(),true);
    
34.             System.out.println("Client(" + getName() +") come in...");
    
35.               
    
36.             start();
    
37.         }
    
38.   
    
39.         public void run() {
    
40.             try {
    
41.                 String line = bufferedReader.readLine();
    
42.   
    
43.                 while (!line.equals("bye")) {
    
44.                     printWriter.println("continue, Client(" + getName() +")!");
    
45.                     line = bufferedReader.readLine();
    
46.                     System.out.println("Client(" + getName() +") say: " + line);
    
47.                 }
    
48.                 printWriter.println("bye, Client(" + getName() +")!");
    
49.                   
    
50.                 System.out.println("Client(" + getName() +") exit!");
    
51.                 printWriter.close();
    
52.                 bufferedReader.close();
    
53.                 client.close();
    
54.             }catch (IOException e) {
    
55.             }
    
56.         }
    
57.     }
    
58.   
    
59.     public static void main(String[] args)throws IOException {
    
60.         new Server();
    
61.     }
    
62. }

复制代码

六、多客户端连接服务器

上面的服务器端程序一次只能连接一个客户端，这在实际应用中显然是不可能的。通常的网络环境是多个客户端连接到某个主机进行通讯，所以我们要对上面的程序进行改造。

设计思路：服务器端主程序监听某一个端口，客户端发起连接请求，服务器端主程序接收请求，同时构造一个线程类，用于接管会话。当一个Socket会话产生后，这个会话就会交给线程进行处理，主程序继续进行监听。

下面的实现程序流程是：客户端和服务器建立连接，客户端发送消息，服务端根据消息进行处理并返回消息，若客户端申请关闭，则服务器关闭此连接，双方通讯结束。

客户端程序：

1. package sock;
   
2. 
   
3. import java.io.BufferedReader;
   
4. import java.io.InputStreamReader;
   
5. import java.io.PrintWriter;
   
6. import java.net.Socket;
   
7.   
   
8. public class SocketClient {
   
9.     public static void main(String[] args) {
   
10.         try {
    
11.             Socket socket =new Socket("127.0.0.1",2013);
    
12.             socket.setSoTimeout(60000);
    
13.   
    
14.             PrintWriter printWriter =new PrintWriter(socket.getOutputStream(),true);
    
15.             BufferedReader bufferedReader =new BufferedReader(new InputStreamReader(socket.getInputStream()));
    
16.               
    
17.             String result ="";
    
18.             while(result.indexOf("bye") == -1){
    
19.                 BufferedReader sysBuff =new BufferedReader(new InputStreamReader(System.in));
    
20.                 printWriter.println(sysBuff.readLine());
    
21.                 printWriter.flush();
    
22.                   
    
23.                 result = bufferedReader.readLine();
    
24.                 System.out.println("Server say : " + result);
    
25.             }
    
26.   
    
27.             printWriter.close();
    
28.             bufferedReader.close();
    
29.             socket.close();
    
30.         }catch (Exception e) {
    
31.             System.out.println("Exception:" + e);
    
32.         }
    
33.     }
    
34. }

复制代码

服务器端程序：

1. package sock;
   
2. import java.io.*;
   
3. import java.net.*;
   
4.   
   
5. public class Server extends ServerSocket {
   
6.     private static final int SERVER_PORT =2013;
   
7.   
   
8.     public Server()throws IOException {
   
9.         super(SERVER_PORT);
   
10.   
    
11.         try {
    
12.             while (true) {
    
13.                 Socket socket = accept();
    
14.                 new CreateServerThread(socket);//当有请求时，启一个线程处理
    
15.             }
    
16.         }catch (IOException e) {
    
17.         }finally {
    
18.             close();
    
19.         }
    
20.     }
    
21.   
    
22.     //线程类
    
23.     class CreateServerThread extends Thread {
    
24.         private Socket client;
    
25.         private BufferedReader bufferedReader;
    
26.         private PrintWriter printWriter;
    
27.   
    
28.         public CreateServerThread(Socket s)throws IOException {
    
29.             client = s;
    
30.   
    
31.             bufferedReader =new BufferedReader(new InputStreamReader(client.getInputStream()));
    
32.               
    
33.             printWriter =new PrintWriter(client.getOutputStream(),true);
    
34.             System.out.println("Client(" + getName() +") come in...");
    
35.               
    
36.             start();
    
37.         }
    
38.   
    
39.         public void run() {
    
40.             try {
    
41.                 String line = bufferedReader.readLine();
    
42.   
    
43.                 while (!line.equals("bye")) {
    
44.                     printWriter.println("continue, Client(" + getName() +")!");
    
45.                     line = bufferedReader.readLine();
    
46.                     System.out.println("Client(" + getName() +") say: " + line);
    
47.                 }
    
48.                 printWriter.println("bye, Client(" + getName() +")!");
    
49.                   
    
50.                 System.out.println("Client(" + getName() +") exit!");
    
51.                 printWriter.close();
    
52.                 bufferedReader.close();
    
53.                 client.close();
    
54.             }catch (IOException e) {
    
55.             }
    
56.         }
    
57.     }
    
58.   
    
59.     public static void main(String[] args)throws IOException {
    
60.         new Server();
    
61.     }
    
62. }

复制代码