[网络协议]Java TCP编程

Java TCP编程

客户端

public class TcpClient {
    public static void main(String[] args) throws IOException {
        // 创建客户端Socket
        Socket socket = new Socket("localhost", 6666);

        // 获取输出输入流
        InputStream is = socket.getInputStream();
        OutputStream os = socket.getOutputStream();

        // 发消息
        System.out.println("输入发送的消息：");
        Scanner scanner = new Scanner(System.in);
        String sendMsg = scanner.nextLine();
        os.write(sendMsg.getBytes());

        socket.shutdownOutput(); // 通知服务器数据写入完毕

        // 读取服务器返回信息
        byte[] buffer = new byte[1024];
        int len = 0;
        while ((len = is.read(buffer)) != -1) {
            String msg = new String(buffer, 0 ,len);
            System.out.println(msg);
        }

        // 关闭服务
        os.close();
        is.close();
        socket.close();
    }
}

服务端

public class TcpServer {
    public static void main(String[] args) throws IOException {
        // 创建ServerSocket服务
        ServerSocket serverSocket = new ServerSocket(6666);
        System.out.println("serverSocket is running...");
        Socket socket = serverSocket.accept();

        // 获取输出输入流
        InputStream is = socket.getInputStream();
        OutputStream os = socket.getOutputStream();

        // 收消息
        byte[] buffer = new byte[1024];
        int len = 0;
        while ((len = is.read(buffer)) != -1) {
            String msg = new String(buffer, 0 ,len);
            System.out.println(msg);
        }

        socket.shutdownInput(); // 通知客户端读取完毕

        // 返回消息
        os.write("ok".getBytes());

        // 关闭服务
        os.close();
        is.close();
        socket.close();
        serverSocket.close();
    }
}