五、基本的Client/Server程序

以下是一个基本的客户端/服务器端程序代码。主要实现了服务器端一直监听某个端口，等待客户端连接请求。客户端根据IP地址和端口号连接服务器端，从键盘上输入一行信息，发送到服务器端，然后接收服务器端返回的信息，最后结束会话。这个程序一次只能接受一个客户连接。

ps：这个小例子写好后，服务端一直接收不到消息，调试了好长时间，才发现误使用了PrintWriter的print()方法，而BufferedReader的readLine()方法一直没有遇到换行，所以一直等待读取。我晕死~~@_@

客户端程序：

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*/
    
12.             // 创建一个流套接字并将其连接到指定 IP 地址的指定端口号(本处是本机)
    
13.             Socket socket =new Socket("127.0.0.1",2013);
    
14.             // 60s超时
    
15.             socket.setSoTimeout(60000);
    
16.   
    
17.             /** 发送客户端准备传输的信息 */
    
18.             // 由Socket对象得到输出流，并构造PrintWriter对象
    
19.             PrintWriter printWriter =new PrintWriter(socket.getOutputStream(),true);
    
20.             // 将输入读入的字符串输出到Server
    
21.             BufferedReader sysBuff =new BufferedReader(new InputStreamReader(System.in));
    
22.             printWriter.println(sysBuff.readLine());
    
23.             // 刷新输出流，使Server马上收到该字符串
    
24.             printWriter.flush();
    
25.   
    
26.             /** 用于获取服务端传输来的信息 */
    
27.             // 由Socket对象得到输入流，并构造相应的BufferedReader对象
    
28.             BufferedReader bufferedReader =new BufferedReader(new InputStreamReader(socket.getInputStream()));
    
29.             // 输入读入一字符串
    
30.             String result = bufferedReader.readLine();
    
31.             System.out.println("Server say : " + result);
    
32.   
    
33.             /** 关闭Socket*/
    
34.             printWriter.close();
    
35.             bufferedReader.close();
    
36.             socket.close();
    
37.         }catch (Exception e) {
    
38.             System.out.println("Exception:" + e);
    
39.         }
    
40.     }
    
41. }

复制代码

服务器端程序：

1. package sock;
   
2. import java.io.BufferedReader;
   
3. import java.io.InputStreamReader;
   
4. import java.io.PrintWriter;
   
5. import java.net.ServerSocket;
   
6. import java.net.Socket;
   
7.   
   
8. public class SocketServer {
   
9.     public static void main(String[] args) {
   
10.         try {
    
11.             /** 创建ServerSocket*/
    
12.             // 创建一个ServerSocket在端口2013监听客户请求
    
13.             ServerSocket serverSocket =new ServerSocket(2013);
    
14.             while (true) {
    
15.                 // 侦听并接受到此Socket的连接,请求到来则产生一个Socket对象，并继续执行
    
16.                 Socket socket = serverSocket.accept();
    
17.   
    
18.                 /** 获取客户端传来的信息 */
    
19.                 // 由Socket对象得到输入流，并构造相应的BufferedReader对象
    
20.                 BufferedReader bufferedReader =new BufferedReader(new InputStreamReader(socket.getInputStream()));
    
21.                 // 获取从客户端读入的字符串
    
22.                 String result = bufferedReader.readLine();
    
23.                 System.out.println("Client say : " + result);
    
24.   
    
25.                 /** 发送服务端准备传输的 */
    
26.                 // 由Socket对象得到输出流，并构造PrintWriter对象
    
27.                 PrintWriter printWriter =new PrintWriter(socket.getOutputStream());
    
28.                 printWriter.print("hello Client, I am Server!");
    
29.                 printWriter.flush();
    
30.   
    
31.                 /** 关闭Socket*/
    
32.                 printWriter.close();
    
33.                 bufferedReader.close();
    
34.                 socket.close();
    
35.             }
    
36.         }catch (Exception e) {
    
37.             System.out.println("Exception:" + e);
    
38.         }finally{
    
39. //          serverSocket.close();
    
40.         }
    
41.     }
    
42. }

复制代码

五、基本的Client/Server程序

以下是一个基本的客户端/服务器端程序代码。主要实现了服务器端一直监听某个端口，等待客户端连接请求。客户端根据IP地址和端口号连接服务器端，从键盘上输入一行信息，发送到服务器端，然后接收服务器端返回的信息，最后结束会话。这个程序一次只能接受一个客户连接。

ps：这个小例子写好后，服务端一直接收不到消息，调试了好长时间，才发现误使用了PrintWriter的print()方法，而BufferedReader的readLine()方法一直没有遇到换行，所以一直等待读取。我晕死~~@_@

客户端程序：

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*/
    
12.             // 创建一个流套接字并将其连接到指定 IP 地址的指定端口号(本处是本机)
    
13.             Socket socket =new Socket("127.0.0.1",2013);
    
14.             // 60s超时
    
15.             socket.setSoTimeout(60000);
    
16.   
    
17.             /** 发送客户端准备传输的信息 */
    
18.             // 由Socket对象得到输出流，并构造PrintWriter对象
    
19.             PrintWriter printWriter =new PrintWriter(socket.getOutputStream(),true);
    
20.             // 将输入读入的字符串输出到Server
    
21.             BufferedReader sysBuff =new BufferedReader(new InputStreamReader(System.in));
    
22.             printWriter.println(sysBuff.readLine());
    
23.             // 刷新输出流，使Server马上收到该字符串
    
24.             printWriter.flush();
    
25.   
    
26.             /** 用于获取服务端传输来的信息 */
    
27.             // 由Socket对象得到输入流，并构造相应的BufferedReader对象
    
28.             BufferedReader bufferedReader =new BufferedReader(new InputStreamReader(socket.getInputStream()));
    
29.             // 输入读入一字符串
    
30.             String result = bufferedReader.readLine();
    
31.             System.out.println("Server say : " + result);
    
32.   
    
33.             /** 关闭Socket*/
    
34.             printWriter.close();
    
35.             bufferedReader.close();
    
36.             socket.close();
    
37.         }catch (Exception e) {
    
38.             System.out.println("Exception:" + e);
    
39.         }
    
40.     }
    
41. }

复制代码

服务器端程序：

1. package sock;
   
2. import java.io.BufferedReader;
   
3. import java.io.InputStreamReader;
   
4. import java.io.PrintWriter;
   
5. import java.net.ServerSocket;
   
6. import java.net.Socket;
   
7.   
   
8. public class SocketServer {
   
9.     public static void main(String[] args) {
   
10.         try {
    
11.             /** 创建ServerSocket*/
    
12.             // 创建一个ServerSocket在端口2013监听客户请求
    
13.             ServerSocket serverSocket =new ServerSocket(2013);
    
14.             while (true) {
    
15.                 // 侦听并接受到此Socket的连接,请求到来则产生一个Socket对象，并继续执行
    
16.                 Socket socket = serverSocket.accept();
    
17.   
    
18.                 /** 获取客户端传来的信息 */
    
19.                 // 由Socket对象得到输入流，并构造相应的BufferedReader对象
    
20.                 BufferedReader bufferedReader =new BufferedReader(new InputStreamReader(socket.getInputStream()));
    
21.                 // 获取从客户端读入的字符串
    
22.                 String result = bufferedReader.readLine();
    
23.                 System.out.println("Client say : " + result);
    
24.   
    
25.                 /** 发送服务端准备传输的 */
    
26.                 // 由Socket对象得到输出流，并构造PrintWriter对象
    
27.                 PrintWriter printWriter =new PrintWriter(socket.getOutputStream());
    
28.                 printWriter.print("hello Client, I am Server!");
    
29.                 printWriter.flush();
    
30.   
    
31.                 /** 关闭Socket*/
    
32.                 printWriter.close();
    
33.                 bufferedReader.close();
    
34.                 socket.close();
    
35.             }
    
36.         }catch (Exception e) {
    
37.             System.out.println("Exception:" + e);
    
38.         }finally{
    
39. //          serverSocket.close();
    
40.         }
    
41.     }
    
42. }

复制代码