java中实现tcp通信需使用java.net包的socket和serversocket类；2. 服务器端创建serversocket绑定端口并监听，调用accept()等待客户端连接，获得socket后通过输入输出流进行数据交换；3. 客户端创建socket连接指定ip和端口，连接成功后同样通过输入输出流与服务器通信；4. 通信结束后双方需关闭流和socket；5. 示例中服务器将客户端发送的消息原样返回，形成“回声”效果，双方以发送“bye”结束通信。该机制基于可靠的、面向连接的数据流，适用于构建稳定的客户端-服务器应用。
Java中实现基于TCP的网络通信，核心在于使用Java提供的
java.net包里的
Socket和
ServerSocket类。它们是构建客户端-服务器应用程序的基石，允许你在网络上建立可靠的、面向连接的数据流。
要实现TCP通信，我们需要分别编写服务器端和客户端的代码。服务器端负责监听特定端口，接受客户端的连接请求，然后与客户端进行数据交换。客户端则主动发起连接，一旦连接建立，就可以发送和接收数据。
从我的经验来看，理解这个过程，最直观的方式就是想象一个电话通话：服务器是那个等待电话响起的固定电话，而客户端则是主动拨号的人。一旦接通（建立连接），双方就可以开始对话（数据传输）。
立即学习“Java免费学习笔记（深入）”；
服务器端基本流程：
- 创建一个
ServerSocket
对象，绑定到一个特定的端口，开始监听。 - 调用
accept()
方法，阻塞等待客户端连接。一旦有客户端连接，accept()
会返回一个Socket
对象，代表这个客户端的连接。 - 通过这个
Socket
对象获取输入流（InputStream
）和输出流（OutputStream
），用于读写数据。 - 进行数据读写操作。
- 关闭流和
Socket
连接。
客户端基本流程：
- 创建一个
Socket
对象，指定服务器的IP地址和端口号，尝试连接服务器。 - 连接成功后，通过这个
Socket
对象获取输入流（InputStream
）和输出流（OutputStream
）。 - 进行数据读写操作。
- 关闭流和
Socket
连接。
我们来看一个最简单的“回声”服务器和客户端的例子。服务器收到什么就原样发回去。
服务器端代码示例：
import java.io.*;
import java.net.*;
public class EchoServer {
public static void main(String[] args) {
int port = 8080; // 监听端口
try (ServerSocket serverSocket = new ServerSocket(port)) {
System.out.println("服务器启动，正在监听端口 " + port + "...");
// 服务器通常需要处理多个客户端，这里先展示单个连接
Socket clientSocket = serverSocket.accept(); // 阻塞，直到有客户端连接
System.out.println("客户端连接成功：" + clientSocket.getInetAddress().getHostAddress());
// 获取输入流和输出流
BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true); // true表示自动刷新
String inputLine;
while ((inputLine = in.readLine()) != null) {
System.out.println("收到客户端消息: " + inputLine);
out.println("Echo: " + inputLine); // 回传给客户端
if ("bye".equalsIgnoreCase(inputLine)) {
break; // 如果客户端发送"bye"，则结束对话
}
}
System.out.println("客户端断开连接。");
clientSocket.close(); // 关闭客户端连接
} catch (IOException e) {
System.err.println("服务器异常: " + e.getMessage());
}
}
}客户端代码示例：
import java.io.*;
import java.net.*;
public class EchoClient {
public static void main(String[] args) {
String host = "localhost"; // 服务器地址
int port = 8080; // 服务器端口
try (Socket socket = new Socket(host, port)) {
System.out.println("成功连接到服务器: " + host + ":" + port);
// 获取输入流和输出流
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream(), true); // true表示自动刷新
// 从控制台读取用户输入
BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
String userInput;
System.out.println("请输入消息，输入'bye'退出:");
while ((userInput = stdIn.readLine()) != null) {
out.println(userInput); // 发送给服务器
System.out.println("服务器响应: " + in.readLine()); // 接收服务器响应
if ("bye".equalsIgnoreCase(userInput)) {
break;
}
} 
