网络编程挑战：Java如何实现TCP和UDP的客户端和服务器端编程？

原创阳光穿透心脏的1/2处 2024-10-18 04:09 82阅读 0赞

在Java中，我们可以使用`java.net`包来实现TCP和UDP的客户端和服务器端编程。以下是一个简单的示例：

1. **TCP客户端**：
```java
import java.io.*;
import java.net.*;

public class TCPClient {
    public static void main(String[] args) throws IOException {
        // 创建一个Socket对象，指定要连接的服务器地址和端口号
        Socket socket = new Socket("localhost", 1234); // "localhost"是本地服务器

// 获取输出流
        OutputStream outputStream = socket.getOutputStream();

// 发送数据（这里以字符串为例）
        byte[] bytes = "Hello, Server!".getBytes();
        outputStream.write(bytes);

// 关闭资源
        outputStream.close();
        socket.close();
    }
}
```

2. **TCP服务器**：
```java
import java.io.*;
import java.net.*;

public class TCPServer {
    public static void main(String[] args) throws IOException, InterruptedException {
        // 创建一个Socket对象，指定要监听的端口号
        ServerSocket serverSocket = new ServerSocket(1234); // "localhost"是本地服务器

System.out.println("TCP Server is listening on port 1234...");

// 等待客户端连接
        Socket socket = serverSocket.accept();

System.out.println("Connection from client established: [" + socket.getRemoteSocketAddress() + "]");

// 获取输入流和输出流
        InputStream inputStream = socket.getInputStream();
        OutputStream outputStream = socket.getOutputStream();

// 处理数据（这里以字符串为例）
        byte[] bytes = new byte[1024]; // 设置数据缓冲区的大小
        int length;
        while ((length = inputStream.read(bytes))) != -1) {
            System.out.print(new String(bytes, 0, length))));
        }

// 关闭资源
        outputStream.close();
        socket.close();
    }
}
```

3. **UDP客户端**：
```java
import java.net.*;

public class UDPClient {
    public static void main(String[] args) throws Exception {
        // 创建一个DatagramSocket对象，指定要连接的服务器地址和端口号（UDP不需要主机）
        DatagramSocket socket = new DatagramSocket(1234); // "localhost"是本地服务器

// 创建数据报
        byte[] bytes = "Hello, UDP Server!".getBytes();
        DatagramPacket packet = new DatagramPacket(bytes, bytes.length), socket.getBroadcastAddress(), socket.getPort()); // 设置数据报的目的地址，广播地址（可选）和端口号

// 发送数据报
        socket.send(packet);

// 关闭资源
        socket.close();
    }
}
```

4. **UDP服务器**：
```java
import java.net.*;
import java.util.*;

public class UDPServer {
    public static void main(String[] args) throws Exception {
        // 创建一个DatagramSocket对象，指定要监听的端口号（UDP不需要主机）
        DatagramSocket socket = new DatagramSocket(1234)); // "localhost"是本地服务器

System.out.println("UDP Server is listening on port 1234...");

// 等待客户端数据报
        byte[] bytes = new byte[512]; // 设置数据缓冲区的大小
        DatagramPacket packet = new DatagramPacket(bytes, bytes.length));
        while ((packet = socket.receive(packet))) != null) {
            System.out.println("Received data from client: [" + new String(packet.getData(), 0, packet.getLength())) + "]");
        }

// 关闭资源
        socket.close();
    }
}
```

以上示例分别实现了TCP客户端和服务器，以及UDP客户端和服务器。你可以根据需求调整这些示例代码。