答案:Java中使用Socket进行TCP通信需依赖ServerSocket和Socket类,服务端通过ServerSocket监听指定端口并接受客户端连接,获得Socket实例后通过输入输出流收发数据;客户端通过Socket连接服务端并交换信息;为支持多客户端,可为每个连接创建独立线程处理;需注意端口占用、资源释放、流阻塞及异常处理等问题,建议使用try-with-resources确保资源安全关闭。

在Java中使用Socket进行TCP通信,主要依赖于java.net.Socket和java.net.ServerSocket这两个类。TCP通信是面向连接的,保证数据可靠传输,适合需要稳定通信的场景,比如文件传输、即时消息等。
1. 服务端如何监听客户端连接
服务端通过ServerSocket绑定一个端口,等待客户端连接。一旦有客户端接入,会返回一个Socket实例用于后续通信。
示例代码:
import java.io.*; import java.net.*; public class Server { public static void main(String[] args) throws IOException { ServerSocket serverSocket = new ServerSocket(8888); // 监听8888端口 System.out.println("服务器启动,等待客户端连接..."); Socket socket = serverSocket.accept(); // 阻塞等待客户端连接 System.out.println("客户端已连接:" + socket.getInetAddress()); // 获取输入流,读取客户端发送的数据 BufferedReader in = new BufferedReader( new InputstreamReader(socket.getInputStream()) ); String message = in.readLine(); System.out.println("收到消息:" + message); // 向客户端发送响应 PrintWriter out = new PrintWriter(socket.getOutputStream(), true); out.println("消息已收到"); // 关闭资源 in.close(); out.close(); socket.close(); serverSocket.close(); } }
2. 客户端如何连接服务端并发送数据
客户端使用Socket指定服务端IP和端口发起连接,连接成功后可以通过输入输出流与服务端交换数据。
示例代码:
import java.io.*; import java.net.*; public class Client { public static void main(String[] args) throws IOException { Socket socket = new Socket("localhost", 8888); // 连接本地8888端口 // 发送消息到服务端 PrintWriter out = new PrintWriter(socket.getOutputStream(), true); out.println("Hello, Server!"); // 接收服务端响应 BufferedReader in = new BufferedReader( new InputStreamReader(socket.getInputStream()) ); String response = in.readLine(); System.out.println("服务端响应:" + response); // 关闭资源 out.close(); in.close(); socket.close(); } }
3. 处理多客户端连接(使用线程)
如果服务端需要同时处理多个客户端,可以为每个连接创建一个独立线程。
立即学习“Java免费学习笔记(深入)”;
修改服务端代码:
public class MultiClientServer { public static void main(String[] args) throws IOException { ServerSocket serverSocket = new ServerSocket(8888); System.out.println("多客户端服务器启动..."); while (true) { Socket socket = serverSocket.accept(); // 每个客户端分配一个线程 new Thread(new ClientHandler(socket)).start(); } } // 处理单个客户端的线程 static class ClientHandler implements Runnable { private Socket socket; public ClientHandler(Socket socket) { this.socket = socket; } public void run() { try { BufferedReader in = new BufferedReader( new InputStreamReader(socket.getInputStream()) ); PrintWriter out = new PrintWriter(socket.getOutputStream(), true); String message; while ((message = in.readLine()) != null) { System.out.println("客户端说:" + message); out.println("回显:" + message); } in.close(); out.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }
4. 注意事项与常见问题
实际开发中需要注意以下几点:
- 确保服务端端口未被占用,防火墙允许通信
- 及时关闭Socket和流,避免资源泄漏
- 读取数据时注意流的阻塞行为,
readLine()会一直等待直到收到换行符或流关闭 - 建议使用try-with-resources管理资源,更安全
- 生产环境应加入异常处理和超时机制
基本上就这些。Java的Socket编程虽然底层,但理解它有助于掌握网络通信原理。不复杂但容易忽略细节,比如流的刷新和关闭顺序。调试时可先用telnet测试端口连通性,再运行程序。


