JavaTCP通信入门教程详解

想要入门Java TCP网络通信？本文为你提供一份详尽的教程，助你快速掌握使用`java.net`包中的`Socket`和`ServerSocket`类构建客户端-服务器应用。我们将深入讲解服务器端如何创建`ServerSocket`监听端口，并使用`accept()`方法等待客户端连接，以及客户端如何创建`Socket`连接服务器。通过输入输出流，双方可以进行数据交换，实现可靠的数据传输。文章还提供了一个“回声”服务器的完整示例，展示了服务器如何将客户端发送的消息原样返回，并通过发送“bye”结束通信。无论你是Java新手还是有一定经验的开发者，都能通过本文轻松理解并实践Java TCP通信的核心概念和步骤，为构建稳定的网络应用打下坚实基础。

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通信，我们需要分别编写服务器端和客户端的代码。服务器端负责监听特定端口，接受客户端的连接请求，然后与客户端进行数据交换。客户端则主动发起连接，一旦连接建立，就可以发送和接收数据。

从我的经验来看，理解这个过程，最直观的方式就是想象一个电话通话：服务器是那个等待电话响起的固定电话，而客户端则是主动拨号的人。一旦接通（建立连接），双方就可以开始对话（数据传输）。

服务器端基本流程：

1. 创建一个ServerSocket对象，绑定到一个特定的端口，开始监听。
2. 调用accept()方法，阻塞等待客户端连接。一旦有客户端连接，accept()会返回一个Socket对象，代表这个客户端的连接。
3. 通过这个Socket对象获取输入流（InputStream）和输出流（OutputStream），用于读写数据。
4. 进行数据读写操作。
5. 关闭流和Socket连接。

客户端基本流程：

1. 创建一个Socket对象，指定服务器的IP地址和端口号，尝试连接服务器。
2. 连接成功后，通过这个Socket对象获取输入流（InputStream）和输出流（OutputStream）。
3. 进行数据读写操作。
4. 关闭流和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;
                }
            }

终于介绍完啦！小伙伴们，这篇关于《JavaTCP通信入门教程详解》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布文章相关知识，快来关注吧！