当前位置：首页 > news >正文

Java TCP练习1

news 来源：原创 2024/9/20 21:27:55

TCPExercise1Send

package TCPExercise120240817;import java.io.*;
import java.net.Socket;public class TCPExercise1Send {public static void main(String[] args) throws IOException {// 需求// 客户端：发送数据，接受服务器反馈// 服务器：收到消息后给出反馈// 案例分析// 客户端创建对象，使用输出流输出数据// 服务端创建对象，使用输入流接受数据// 服务端使用输出流给出反馈数据// 客户端使用输入流接受反馈数据// 客户端// 创建SocketSocket socket = new Socket("127.0.0.1", 10086);// 创建OutputStream对象BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));// 客户端输出数据bufferedWriter.write("你好，客户端");bufferedWriter.newLine();bufferedWriter.flush();// 关闭输出流socket.shutdownOutput();// 创建InputStream对象接收服务端反馈的数据BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));String line;while ((line = bufferedReader.readLine()) != null) {System.out.print(line);}// 此处关流bufferedReader.close();bufferedWriter.close();socket.close();// 注：十分重要！！！// 客户端发送数据后必须关闭输出流：在客户端发送数据后，应该关闭输出流，这样服务端才能正确读取到数据的结束标志// 服务端读取数据时要处理结束标志：服务端在读取数据时，如果客户端没有关闭输出流，readLine() 方法会一直等待，导致程序阻塞}
}

TCPExercise1Receive

package TCPExercise120240817;import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;public class TCPExercise1Receive {public static void main(String[] args) throws IOException {// 服务端// 创建ServerSocket对象ServerSocket serverSocket = new ServerSocket(10086);// 等待客户端连接Socket socket = serverSocket.accept();// 创建输入流对象BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));// 读取客户端发送的数据String line;while ((line = bufferedReader.readLine()) != null) {System.out.print(line);}// 给客户端返回数据BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bufferedWriter.write("服务端已经收到信息");bufferedWriter.newLine();bufferedWriter.flush();// 关流bufferedWriter.close();bufferedReader.close();socket.close();serverSocket.close();}
}