TCP程序有主次之分，一个是服务器程序，另一个是客户机程序。它们的交互规则如下图：  *模拟服务器和客户端的方法：分在使用eclipse创建两个独立的工作空间，一个编写TCP服务端程序，另一个编写TCP客户端程序。编写好后，先运行TCP服务端程序，再运行TCP客户端程序。或者使用命令行业可以，请先往下看。* **`net/server/TcpServer.java`**(服务端） ```java package net.server; import java.io.*; import java.net.*; import java.util.Random; /** * TCP 服务端程序 * @version 2020/10/21 * */ public class TcpServer { public static void main(String[] args) { new TcpServer().getServer(); } private BufferedReader reader; private ServerSocket server; private Socket socket; private PrintWriter printWriter; private Random random = new Random(); /** * 服务器与客户端的连接，接收客户端的请求并响应客户端的请求 */ void getServer() { try { server = new ServerSocket(5000); // 为服务器创建一个为5000的端口号 System.out.println("服务器套接字已创建成功"); while(true) { // 等待客户机连接 System.out.println("等待客户机的连接..."); // 当有客户机连接时，accept返回一个新的Socket对象与其客户端的Socket对象交互，否则一直阻塞 socket = server.accept(); System.out.println("已有客户端连接"); // 该对象负责获取客户端的请求信息 reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); // 该对象负责响应客户端 printWriter = new PrintWriter(socket.getOutputStream(), true); while(true) { String message = reader.readLine(); // 获取客户端的请求信息 System.out.println("客户端：" + message); // 当客户端输入exit时，表明该客户端已断开请求 if("exit".equals(message)) { System.out.println("客户端已断开连接！\n"); // 服务器响应客户端的请求，发送一段字符串给客户端 printWriter.println("你已退出！"); break; } // 服务器响应客户端的请求，发送一段字符串给客户端 printWriter.println("我已响应你想要的资源了！" + random.nextInt(1000)); } reader.close(); printWriter.close(); } } catch (Exception e) { e.printStackTrace(); } } } ``` **`net/client/TcpClient.java`** (客户端） ``` package net.client; import java.io.*; import java.net.Socket; import java.util.Scanner; public class TcpClient { public static void main(String[] args) throws IOException, InterruptedException { new TcpClient().connect(); } private Socket socket; private PrintWriter printWriter; private String message = "connect"; private Scanner input = new Scanner(System.in); private BufferedReader bufferedReader; /** * 连接服务器并发送请求信息 * @throws IOException */ public void connect() throws IOException, InterruptedException { System.out.println("正在尝试连接服务器..."); socket = new Socket("127.0.0.1", 5000); // 指定服务端的IP地址和端口 System.out.println("连接成功！"); // 该对象负责将客户端的请求发送到服务端 printWriter = new PrintWriter(socket.getOutputStream(), true); // 该对象负责获取服务端的响应 bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream())); while(!"exit".equals(message)) { System.out.print(">>"); message = input.nextLine(); printWriter.println(message); // 发送请求信息到服务端 Thread.sleep(1000); // 获取服务端的响应 System.out.println("服务器：" + bufferedReader.readLine()); } socket.close(); printWriter.close(); input.close(); bufferedReader.close(); } } ``` ``` 打开第一个cmd窗口执行服务端程序： 编译源码：javac TcpServer.java -encoding utf-8 执行程序：java net.server.TcpServer 打开第二个cmd窗口执行客户端程序： 编译源码：javac TcpClient.java -encoding utf-8 执行程序：java net.client.TcpClient ``` 结果如下：