Java SE 9 网络编程TCP/UDP + Socket#

网络编程核心是进程间跨设备数据通信，Java 通过 Socket 封装网络交互，主流分为 TCP 可靠传输、UDP 快速传输两种模式。

一、核心概念#

Socket：网络通信端点，相当于数据收发的 “管道端口”
TCP：面向连接、可靠、有序、三次握手，适合文件、文本传输
UDP：无连接、不可靠、速度快，适合直播、语音、广播

二、TCP 通信（面向连接）#

基于 ServerSocket（服务端）+ Socket（客户端），点对点稳定通信。

TCP 服务端#

1
public class TcpServer {
2
    public static void main(String[] args) throws IOException {
3
        // 绑定端口，监听客户端连接
4
        ServerSocket serverSocket = new ServerSocket(8888);
5
        Socket socket = serverSocket.accept(); // 阻塞等待连接
6

7
        // 读取客户端数据
8
        BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
9
        String msg = br.readLine();
10
        System.out.println("服务端接收：" + msg);
11

12
        socket.close();
13
        serverSocket.close();
14
    }
15
}

TCP 客户端#

1
public class TcpClient {
2
    public static void main(String[] args) throws IOException {
3
        // 连接本机8888端口服务端
4
        Socket socket = new Socket("127.0.0.1", 8888);
5
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
6
        bw.write("Hello TCP");
7
        bw.flush();
8

9
        socket.close();
10
    }
11
}

三、UDP 通信（无连接）#

基于 DatagramSocket 收发数据包，无需建立连接，以数据包为单位传输。

UDP 服务端（接收）#

1
public class UdpServer {
2
    public static void main(String[] args) throws IOException {
3
        DatagramSocket socket = new DatagramSocket(9999);
4
        byte[] buf = new byte[1024];
5
        DatagramPacket packet = new DatagramPacket(buf, buf.length);
6
        socket.receive(packet); // 阻塞接收数据包
7

8
        String msg = new String(packet.getData(),0,packet.getLength());
9
        System.out.println("UDP接收：" + msg);
10
        socket.close();
11
    }
12
}

UDP 客户端（发送）#

1
public class UdpClient {
2
    public static void main(String[] args) throws IOException {
3
        DatagramSocket socket = new DatagramSocket();
4
        byte[] data = "Hello UDP".getBytes();
5
        // 指定数据包、目标地址端口
6
        DatagramPacket packet = new DatagramPacket(data,data.length,
7
                InetAddress.getLocalHost(),9999);
8
        socket.send(packet);
9
        socket.close();
10
    }
11
}