Socket实现一对一通信

前言：以前写的一个Socket实现一对一通信的例子

ClientDemo

import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

/**
 * @author shency
 * @description: Socket客户端
 */
public class ClientDemo {
    public void ClientSocket(){
        System.out.println("向服务器请求连接中");
        Socket socket;
        Scanner keybordScanner,inScanner;
        PrintWriter printWriter;
        try {
            socket = new Socket("127.0.0.1", 21412);
            // 返回此套接字的输入流。
            inScanner = new Scanner(socket.getInputStream());
            System.out.println(inScanner.nextLine());
            // 返回此套接字的输出流。
            printWriter = new PrintWriter(socket.getOutputStream());

            System.out.print("客户端：");
            //先读取键盘输入
            keybordScanner = new Scanner(System.in);
            while(keybordScanner.hasNextLine()){
                String keybordData = keybordScanner.nextLine();
                //写到服务端的的控制台
                printWriter.println(keybordData);
                printWriter.flush();
                //阻塞等待接收服务端的消息
                System.out.println("服务端："+inScanner.nextLine());
                System.out.print("客户端：");
            }
            socket.close();
            keybordScanner.close();
            printWriter.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public static void main(String[] args) {
        new ClientDemo().ClientSocket();
    }
}

ServerDemo

import java.io.IOException;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

/**
 * @author shency
 * @description: Socket服务端
 */
public class ServerDemo {
    //服务器
    public  void ServerSocket(){
        //创建一个服务器
        System.out.println("等待客户端连接中");
        PrintWriter printWriter;
        Scanner keybordScanner,inScanner;
        ServerSocket serverSocket;
        try {
            serverSocket = new ServerSocket(21412);
            // 监听并接受到此套接字的连接
            Socket socket = serverSocket.accept();
            // getInetAddress()返回套接字连接的地址
            System.out.println("已成功连接到"+socket.getInetAddress()+"服务器上");
            //字符输出流
            printWriter = new PrintWriter(socket.getOutputStream());
            printWriter.println("已成功连接到远程服务器！"+"\t"+"请您先发言。");
            printWriter.flush();
            keybordScanner = new Scanner(System.in);
            inScanner = new Scanner(socket.getInputStream());
            //阻塞等待客户端发送消息过来
            while(inScanner.hasNextLine()){
                System.out.println("客户端：" + inScanner.nextLine());
                System.out.print("服务端：");
                printWriter.println(keybordScanner.nextLine());
                printWriter.flush();
            }
            serverSocket.close();
            printWriter.close();
            keybordScanner.close();
            inScanner.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public static void main(String[] args) {
        new ServerDemo().ServerSocket();
    }
}