【案例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("客户端退出...");}
}

【结果展示】