创建Socket对象

  1. Socket socket = new Socket("localhost", 9688);
  2. // 输入io
  3. BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

localhost 服务端地址， 9688 服务端端口号

写数据给socket对象，传递给服务端

  1. readLine = reader.readLine();
  2. writer.println(readLine);
  3. writer.flush();

reader读取控制台输入，将读取到的数据

监听服务端传过来的数据

  1. Thread thread = new Thread(new Runnable() {
  2.     @Override
  3.     public void run() {
  4.         try {
  5.             System.out.println(socketReader.readLine());
  7.             if (socketReader.readLine().equals("over")) {
  8.                 over[0] = 1;
  9.             }
  11.         } catch (IOException e) {
  12.             e.printStackTrace();
  13.         }
  14.     }
  15. });
  16. thread.start();

完整的客户端代码

  1. package io.bio;
  3. import java.io.BufferedReader;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.io.PrintWriter;
  7. import java.net.Socket;
  9. /**
  10.  * 客户端代码
  11.  * 
  12.  * @author linguo
  13.  *
  14.  */
  15. public class ClientSocketDemo {
  16.     public static void main(String[] args) throws IOException {
  17.         try {
  18.             // 创建Socket对象 localhost 服务端地址， 9688 服务端端口号
  19.             Socket socket = new Socket("localhost", 9688);
  20.             // 输入io
  21.             BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
  22.             // 客户端写io
  23.             PrintWriter writer = new PrintWriter(socket.getOutputStream());
  24.             // 客户端读io
  25.             BufferedReader socketReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
  26.             int[] over = new int[1];
  27.             // 创建线程读取服务端传来的数据
  28.             Thread thread = new Thread(new Runnable() {
  29.                 @Override
  30.                 public void run() {
  31.                     try {
  32.                         System.out.println(socketReader.readLine());
  33.                         if (socketReader.readLine().equals("over")) {
  34.                             over[0] = 1;
  35.                         }
  37.                     } catch (IOException e) {
  38.                         e.printStackTrace();
  39.                     }
  40.                 }
  41.             });
  42.             thread.start();
  43.             // 客户端持续读取控制台并写给服务器
  44.             String readLine = null;
  45.             while (true) {
  46.                 readLine = reader.readLine();
  47.                 writer.println(readLine);
  48.                 writer.flush();
  49.                 // 收到服务端的over需要断开连接
  50.                 if (over[0] == 1) {
  51.                     break;
  52.                 }
  53.             }
  54.             writer.close();
  55.             socketReader.close();
  56.             reader.close();
  57.             socket.close();
  58.         } catch (IOException e) {
  59.             System.out.println("can't listen to:" + e);
  60.         }
  61.     }
  62. }