Java在Linux如何进行网络编程

在Linux上玩转Ja va网络编程：从TCP到UDP的实战指南

想在Linux环境下让Ja va应用“开口说话”，实现网络通信吗？这事儿其实没想象中那么复杂。核心就在于用好Ja va标准库里的ja va.net包。下面，咱们就通过几个清晰明了的示例，一步步看看如何搭建起最基本的网络对话通道。

1. 创建一个简单的TCP服务器

TCP协议好比打电话，需要先建立稳定的连接，再进行可靠的数据传输。这是最经典、最常用的网络编程模型。

服务器端代码

import ja va.io.*;
import ja va.net.*;

public class TCPServer {
    public static void main(String[] args) {
        int port = 12345; // 服务器监听的端口
        try (ServerSocket serverSocket = new ServerSocket(port)) {
            System.out.println("服务器已启动，正在监听端口 " + port);
            while (true) {
                Socket clientSocket = serverSocket.accept();
                System.out.println("客户端已连接: " + clientSocket.getInetAddress());
                // 处理客户端请求
                BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
                String inputLine;
                while ((inputLine = in.readLine()) != null) {
                    System.out.println("收到客户端消息: " + inputLine);
                    out.println("服务器已收到: " + inputLine);
                }
                clientSocket.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

这段代码的核心是ServerSocket。它在指定端口上“安营扎寨”，通过accept()方法等待客户端的“敲门”。一旦连接建立，就通过Socket对象获取输入输出流，开始与客户端进行“你一言我一语”的对话。注意，这是一个简单的单线程模型，一个客户端处理完才会接待下一个。

客户端代码

import ja va.io.*;
import ja va.net.*;

public class TCPClient {
    public static void main(String[] args) {
        String hostname = "localhost"; // 服务器地址
        int port = 12345; // 服务器监听的端口
        try (Socket socket = new Socket(hostname, port)) {
            System.out.println("已连接到服务器 " + hostname + ":" + port);
            BufferedReader userInput = new BufferedReader(new InputStreamReader(System.in));
            PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String userInputLine;
            while ((userInputLine = userInput.readLine()) != null) {
                out.println(userInputLine);
                String response = in.readLine();
                System.out.println("服务器回复: " + response);
            }
        } catch (UnknownHostException e) {
            System.err.println("未知主机: " + hostname);
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

客户端这边就主动多了。直接用Socket指定服务器地址和端口，发起连接。连接成功后，同样获取输入输出流，将用户在控制台输入的内容发送给服务器，并等待回音。这就完成了一次完整的TCP交互闭环。

2. 创建一个简单的UDP服务器

如果说TCP是打电话，那UDP就像是寄明信片。它无需建立连接，直接将数据包（DatagramPacket）扔向目标地址，速度快但不管对方是否收到。

服务器端代码

import ja va.io.*;
import ja va.net.*;

public class UDPServer {
    public static void main(String[] args) {
        int port = 12345; // 服务器监听的端口
        try (DatagramSocket socket = new DatagramSocket(port)) {
            System.out.println("UDP服务器已启动，正在监听端口 " + port);
            byte[] buffer = new byte[1024];
            DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
            while (true) {
                socket.receive(packet); // 等待接收数据包
                String received = new String(packet.getData(), 0, packet.getLength());
                System.out.println("收到客户端消息: " + received);
                // 发送回复
                String response = "服务器已收到: " + received;
                DatagramPacket responsePacket = new DatagramPacket(response.getBytes(), response.length(), packet.getAddress(), packet.getPort());
                socket.send(responsePacket);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

UDP服务器使用DatagramSocket在端口上监听。它准备一个空“包裹”（DatagramPacket），然后调用receive()方法等待“邮差”送来数据。收到后，从包裹里取出信息，并可以立刻根据发送者的地址和端口（都包含在packet里）打包一个回复包裹发送回去。

客户端代码

import ja va.io.*;
import ja va.net.*;

public class UDPClient {
    public static void main(String[] args) {
        String hostname = "localhost"; // 服务器地址
        int port = 12345; // 服务器监听的端口
        try (DatagramSocket socket = new DatagramSocket()) {
            InetAddress address = InetAddress.getByName(hostname);
            BufferedReader userInput = new BufferedReader(new InputStreamReader(System.in));
            String userInputLine;
            while ((userInputLine = userInput.readLine()) != null) {
                byte[] buffer = userInputLine.getBytes();
                DatagramPacket packet = new DatagramPacket(buffer, buffer.length, address, port);
                socket.send(packet); // 发送数据包
                byte[] responseBuffer = new byte[1024];
                DatagramPacket responsePacket = new DatagramPacket(responseBuffer, responseBuffer.length);
                socket.receive(responsePacket); // 等待接收回复
                String response = new String(responsePacket.getData(), 0, responsePacket.getLength());
                System.out.println("服务器回复: " + response);
            }
        } catch (UnknownHostException e) {
            System.err.println("未知主机: " + hostname);
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

UDP客户端同样使用DatagramSocket，但它不需要先连接。每次发送数据时，都需要明确指定目标地址和端口，封装成一个DatagramPacket，然后调用send()方法“寄出”。发送后，它可以立即（或稍后）调用receive()来尝试接收服务器的回复包裹。

3. 编译和运行

代码写好了，怎么在Linux上让它跑起来？步骤非常直接。

编译服务器和客户端

ja vac TCPServer.ja va
ja vac TCPClient.ja va

打开终端，导航到你的Ja va文件目录，用ja vac命令分别编译服务器和客户端程序。UDP程序的编译命令完全一样，只是文件名不同。

运行服务器和客户端

ja va TCPServer
ja va TCPClient

编译成功后，先在一个终端窗口运行服务器程序（ja va TCPServer），它会开始监听。然后在另一个终端窗口运行客户端程序（ja va TCPClient），就可以开始通信了。UDP服务器和客户端的运行方式完全相同。

4. 注意事项

• 防火墙：这是第一个要排查的“拦路虎”。确保你的Linux防火墙（如firewalld或ufw）允许程序所使用的端口（如示例中的12345）进行通信。
• 性能与扩展：示例中的TCP服务器是单线程的，一次只能服务一个客户端。这在生产环境中是远远不够的。一个常见的优化方案是使用线程池（ExecutorService）来处理accept()到的每一个客户端连接，从而能够并发服务多个客户端，大幅提升服务器的吞吐能力和响应速度。

好了，从建立可靠的TCP连接到发送轻快的UDP数据包，一套完整的流程就在这儿了。掌握了这些基础，你就已经拿到了在Linux世界用Ja va进行网络通信的钥匙。接下来，无论是构建复杂的微服务通信，还是实现自定义的应用层协议，都可以从这些基石上开始搭建。