Java socket(二)

服务器

    public static void main(String[] args) {
        System.out.println("服务器已启动，等待连接......");
        try {
            ServerSocket serverSocket = new ServerSocket(8902, 2);
            Socket socket = null;
            while (true) {
                socket = serverSocket.accept();
                System.out.println("【客户端】：" + socket.getPort() + "已成功连接。");
                DataInputStream inputStream = new DataInputStream(socket.getInputStream());
                DataOutputStream outputStream = new DataOutputStream(socket.getOutputStream());
                outputStream.writeUTF("【服务器】：成功建立连接");
                try {
                    while (true) {
                        String fromClientMsg = inputStream.readUTF();
                        System.out.println("【客户端】：" + fromClientMsg);
                        outputStream.writeUTF("【服务器】：已成功接收消息【" + fromClientMsg + "】");
                    }
                } catch (IOException e) {
                    System.out.println("【客户端】：" + socket.getPort() + "已断开连接。");
                } finally {
                    socket.close();
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

客户端

    public static void main(String[] args) {
        System.out.println("客户端已启动，正在连接......");
        try {
            Socket socket = new Socket("localhost", 8902);
            DataInputStream inputStream = new DataInputStream(socket.getInputStream());
            DataOutputStream outputStream = new DataOutputStream(socket.getOutputStream());
            Scanner scanner = new Scanner(System.in);
            try {
                System.out.println(inputStream.readUTF());
                while (true) {
                    String msg = scanner.nextLine();
                    if ("quit".equals(msg)) {
                        return;
                    }
                    outputStream.writeUTF(msg);
                    System.out.println(inputStream.readUTF());
                }
            } catch (IOException e) {
                socket.close();
                System.out.println("连接异常，已断开连接。");
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }