public static void main(String[] args) {
        System.out.println("===服務(wù)端啟動===");
        ServerSocket serverSocket=null;
        try {
            serverSocket=new ServerSocket(5000);
            Socket socket=serverSocket.accept();
            InputStream is = socket.getInputStream();
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            String msg;
            if ((msg = br.readLine()) != null) {
                System.out.println("服務(wù)端接收客戶端信息為：" + msg);
            }
        }catch (Exception exception){
            System.out.println(exception.getMessage());
        }
  }

public static void main(String[] args) {
        Socket socket = null;
        try {
            socket = new Socket("127.0.0.1",5000);
            OutputStream os = socket.getOutputStream();
            PrintStream ps = new PrintStream(os);
            ps.println("Hi BIO! 與服務(wù)端通信成功");
            ps.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

public static void main(String[] args) {
    System.out.println("===服務(wù)端啟動===");
    try {
         ServerSocket ss = new ServerSocket(9988);
         Socket socket = ss.accept();
         InputStream is = socket.getInputStream();
         BufferedReader br = new BufferedReader(new InputStreamReader(is));
         String message;
         while ((message = br.readLine()) != null){
             System.out.println("服務(wù)端接收客戶端信息為：" + message);
         }
     } catch (IOException e) {
            e.printStackTrace();
     }
}

public static void main(String[] args) {
    try {
        Socket socket = new Socket("localhost",9988);
        OutputStream os = socket.getOutputStream();
        PrintStream ps = new PrintStream(os);
        Scanner scanner = new Scanner(System.in);
        while (true){
            System.out.println("請輸入：");
            String input = scanner.nextLine();
            ps.println(input);
            ps.flush();
        }
     } catch (IOException e) {
            e.printStackTrace();
     }
}

  public void listen() throws IOException {
        ServerSocket serverSocket = null;
        try {
            log.info("服務(wù)啟動監(jiān)聽");
            serverSocket = new ServerSocket(9988);
            //循環(huán)接收到客戶端的連接
            while (true) {
                Socket socket = serverSocket.accept();
                //得到連接后，開啟一個線程處理連接
                handleSocket(socket);
            }
        }finally {
            if(serverSocket != null){
                serverSocket.close();
            }
        }
 }
private void handleSocket(Socket socket) {
        HandleSocket socketHandle = new HandleSocket(socket);
        new Thread(socketHandle).start();
}

 public void run() {
        BufferedInputStream bufferedInputStream = null;
        BufferedOutputStream bufferedOutputStream  = null;
        try {
            bufferedInputStream = new BufferedInputStream(socket.getInputStream());
            byte[] bytes = new byte[1024];
            int len ;
            if ((len = bufferedInputStream.read(bytes)) > -1) {
                String result = new String(bytes,0,len);
                System.out.println("本次接收到的結(jié)果："+result);
            }
            System.out.println("回復(fù)信息給客戶端：");
            bufferedOutputStream = new BufferedOutputStream(socket.getOutputStream());
            String outString = Thread.currentThread().getName()+"接收到了";
            bufferedOutputStream.write(outString.getBytes());
            bufferedOutputStream.flush();
            System.out.println("回復(fù)完成：");
        } catch (IOException e) {
            System.out.println("異常："e.getLocalizedMessage());
        } finally {
            System.out.println("關(guān)閉數(shù)據(jù)流：");
            try {
                if (bufferedInputStream != null) {
                    bufferedInputStream.close();
                }
                if (bufferedOutputStream != null) {
                    bufferedOutputStream.close();
                }
            }catch (IOException e){
                System.out.println("請輸入："e.getLocalizedMessage());
            }
        }
    }

  public void start() throws IOException {
        Socket socket = new Socket("127.0.0.1", 8081);
        String msg = "Hi,This is the BioClient";
        //1.拿到輸出流
        //2.對輸出流進行處理
       System.out.println("請輸入："+msg);
        BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(socket.getOutputStream());
        byte[] bytes = msg.getBytes();
        //3.輸出msg
        bufferedOutputStream.write(bytes);
        bufferedOutputStream.flush();
        System.out.println("發(fā)送完畢.");
        System.out.println("開始接收到消息.");
        //4.對輸入流進行處理
        BufferedInputStream bufferedInputStream = new BufferedInputStream(socket.getInputStream());
        byte[] inBytes = new byte[1024];
        int len;
        //5.讀取輸入流
        if ((len = bufferedInputStream.read(inBytes)) != -1) {
            String result = new String(inBytes, 0, len);
            System.out.println("接收到的消息="+result);
        }
        //6.關(guān)閉輸入輸出流
        bufferedOutputStream.close();
        bufferedInputStream.close();
        socket.close();
    }