网络编程：TCP/IP协议栈在Java中的应用实例

原创淩亂°似流年 2024-09-28 02:30 44阅读 0赞

在Java中，我们可以使用NIO（Non-blocking I/O）或者更底层的Socket API来实现对TCP/IP协议栈的应用。

以下是一个简单的TCP客户端和服务器的Java代码示例：

1. **客户端**（创建连接、发送数据、接收响应）

```java
import java.io.IOException;
import java.net.Socket;

public class Client {
    public static void main(String[] args) {
        // 创建Socket对象
        Socket socket = new Socket("localhost", 1234); // "localhost"是服务器的IP，1234是服务器监听的端口

try {
            // 发送数据
            String message = "Hello, Server!";
            socket.getOutputStream().write(message.getBytes());

// 接收响应
            byte[] response = new byte[1024];
            int receivedBytes = socket.getInputStream().read(response);
            System.out.println("Received: " + new String(response, 0, receivedBytes)));

} catch (IOException e) {
            e.printStackTrace();
        } finally {
            // 关闭Socket
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}
```

2. **服务器**（创建监听、接受连接、发送数据、接收响应）

```java
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) throws IOException {
        // 创建ServerSocket对象，指定监听的端口
        ServerSocket serverSocket = new ServerSocket(1234);

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

// 接受连接
            Socket clientSocket = serverSocket.accept(); // accept()方法会阻塞直到有客户端连接

System.out.println("\nNew connection received! Client IP: " + clientSocket.getInetAddress().getHostAddress());

// 发送数据（例如：欢迎信息）
            String welcomeMessage = "Welcome to the Server, Client!";
            clientSocket.getOutputStream().write(welcomeMessage.getBytes()));

// 接收响应并打印
            byte[] response = new byte[1024];
            int receivedBytes = clientSocket.getInputStream().read(response);
            System.out.println("Received: " + new String(response, 0, receivedBytes)));

} catch (IOException e) {
            e.printStackTrace();
        } finally {
            // 关闭连接
            try {
                clientSocket.close();
                serverSocket.close(); // ServerSocket也关闭，以释放系统资源
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}
```

以上代码示例中，客户端发送一个消息到服务器，然后接收服务器的响应。服务器端则创建监听的端口，并接受来自客户端的连接，处理请求并返回响应。