Java基于UDP协议的简单数据传输实现

顾星河

发布时间：2026-10-13 | 5人浏览过

原创

本文将深入解析如何在Java中通过DatagramSocket类实现基于UDP协议的网络通信。不同于TCP的可靠连接，UDP以无连接、速度快为特点，适用于实时性要求高的场景。我们将通过服务端和客户端的完整代码示例，展示数据包的发送与接收过程。

UDP协议特性

UDP（User Datagram Protocol，用户数据报协议）是一种无连接的传输层协议。与TCP不同，UDP不保证数据到达的可靠性，也无法确保数据包按发送顺序到达。这意味着如果先发送“hello”后发送“world”，接收方可能先收到“world”，也可能丢失部分数据。然而，正是这种无连接的特性使得UDP在传输速度上优于TCP，特别适合对实时性要求高但对丢包容忍度较高的应用，如实时音频流或视频直播。

服务端实现

第1步：创建监听Socket

服务端需要创建一个DatagramSocket对象并绑定指定端口，以便监听来自客户端的数据报。

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class EchoServer {
    private DatagramSocket datagramSocket;
    private final int port = 8088; // 监听端口

    public static void main(String[] args) throws SocketException {
        new EchoServer().service();
    }

    public EchoServer() throws SocketException {
        datagramSocket = new DatagramSocket(port);
        System.out.println("服务器启动于端口: " + port);
    }
}

第2步：处理数据请求与响应

在主循环中，服务端持续接收数据报，处理后原路返回给客户端。注意使用receive方法阻塞等待数据，并使用send方法将响应发回。

    public String echo(String msg) {
        return "echo:" + msg; // 简单的回声处理
    }

    public void service() {
        while (true) {
            try {
                // 接收数据报
                byte[] buffer = new byte[512];
                DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
                datagramSocket.receive(packet);

                // 解析数据
                String msg = new String(packet.getData(), 0, packet.getLength());
                System.out.println(packet.getAddress() + "/" + packet.getPort() + " msg:" + msg);

                // 准备响应数据
                String response = echo(msg);
                byte[] responseData = response.getBytes();

                // 重新设置数据包内容用于发送
                DatagramPacket outPacket = new DatagramPacket(responseData, responseData.length, packet.getAddress(), packet.getPort());
                datagramSocket.send(outPacket);

            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

客户端实现

第3步：初始化连接

客户端无需绑定特定端口，只需创建空的DatagramSocket即可。需指定远程主机的IP地址和服务端端口。

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

public class EchoClient {
    private String remoteHost = "localhost";
    private int remotePort = 8088;
    private DatagramSocket datagramSocket;

    public EchoClient() throws SocketException {
        datagramSocket = new DatagramSocket();
    }

    public static void main(String[] args) throws SocketException {
        new EchoClient().talk();
    }
}

第4步：交互逻辑处理

通过控制台输入获取用户消息，构造包含目标地址和数据的服务端数据报进行发送，随后接收服务端的响应。

    public void talk() {
        try {
            BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
            InetAddress address = InetAddress.getByName(remoteHost);
            String msg;

            while ((msg = reader.readLine()) != null) {
                // 发送数据
                byte[] buffer = msg.getBytes();
                DatagramPacket outPacket = new DatagramPacket(buffer, buffer.length, address, remotePort);
                datagramSocket.send(outPacket);

                // 接收响应
                byte[] respBuffer = new byte[512];
                DatagramPacket inPacket = new DatagramPacket(respBuffer, respBuffer.length);
                datagramSocket.receive(inPacket);
                String response = new String(inPacket.getData(), 0, inPacket.getLength());
                System.out.println(response);

                if ("bye".equals(msg)) {
                    break;
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            datagramSocket.close(); // 释放资源
        }
    }
}