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; } }
评论（已关闭）
评论已关闭