TCP网络通信编程之字符流

news2024/10/1 1:24:04

【案例1】

【题目描述】

【注意事项】

(3条消息) 节点流和处理流字符处理流BufferedReader、BufferedWriter，字节处理流-BufferedInputStream和BufferedOutputStream (代码均正确且可运行_Studying~的博客-CSDN博客

1。这里需要使用字符处理流，来将字节流转为字符流。使用的字符流，所以一定要使用writer.flush来进行手动刷新，否则无法将数据写入到数据通道。然后使用时只需要关闭外层流即可。

2. 这里因为使用的是字符流，结束标志就可以改为 writer.newLine();，但是这样的话，要求接收数据端一定要使用reder.readLine();

【服务端代码】

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @ProjectName: Study
 * @FileName: SocketTCP02Server
 * @author:HWJ
 * @Data: 2023/7/29 11:50
 */
public class SocketTCP03Server {
    public static void main(String[] args) throws IOException {

        // 监听本机端口9999，等待连接
        // 细节：要求在本机没有其他服务在监听9999端口
        ServerSocket serverSocket = new ServerSocket(9999);
        System.out.println("服务端，在9999端口监听，等待连接");
        // 当没有客户端连接9999端口时，程序会阻塞，等待连接
        // 如果有客户端连接，则会返回Socket对象，程序继续
        Socket socket = serverSocket.accept();

        // 通过socket.getInputStream() 读取客户端写入到数据通道的数据，显示
        InputStream inputStream = socket.getInputStream();
        BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));

        // 读取数据
        String str = reader.readLine();
        System.out.println(str);

        // 发送给客户端
        OutputStream outputStream = socket.getOutputStream();
        BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(outputStream));
        writer.write("hello, client");
        writer.newLine(); // 插入一个换行符，表示写入的内容结束，注意，要求对方使用readLine()!!!
        writer.flush(); // 如果使用的字符流，需要手动刷新，否则数据不会写入数据通道

        // 这里一定要关闭流对象和socket，serverSocket对象，否则会造成资源浪费。
        serverSocket.close();
        socket.close();
        reader.close();
        writer.close();
        System.out.println("服务端退出...");
    }
}

【客户端代码】

import java.io.*;
import java.net.InetAddress;
import java.net.Socket;

/**
 * @ProjectName: Study
 * @FileName: SocketTCP02Client
 * @author:HWJ
 * @Data: 2023/7/29 11:50
 */
public class SocketTCP03Client {
    public static void main(String[] args) throws IOException {

        // 连接本机的 9999端口，如果连接成功，返回Socket对象
        Socket socket = new Socket(InetAddress.getLocalHost(), 9999);
        System.out.println("连接成功...");

        // 连接上后，生成Socket对象，通过socket.getOutputStream 来写入数据
        OutputStream outputStream = socket.getOutputStream();
        BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(outputStream));
        writer.write("hello, server");
        writer.newLine(); // 插入一个换行符，表示写入的内容结束，注意，要求对方使用readLine()!!!
        writer.flush(); // 如果使用的字符流，需要手动刷新，否则数据不会写入数据通道

        // 通过socket.getInputStream() 读取客户端写入到数据通道的数据，显示
        InputStream inputStream = socket.getInputStream();
        BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));

        // 读取数据
        String str = reader.readLine();
        System.out.println(str);

        // 这里一定要关闭流对象和socket对象，否则会造成资源浪费。
        socket.close();
        reader.close(); // 只需要关闭外层流即可
        writer.close();
        reader.close();
        System.out.println("客户端退出...");

    }
}

【结果展示】