java怎样实现基于TCP的网络通信 java网络协议应用的入门教程

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;
                }
            }