Java Socket编程：连接、读写及异常处理案例

原创你的名字 2024-10-17 22:51 51阅读 0赞

在Java的Socket编程中，我们会涉及到以下几个关键部分：连接建立、数据读写以及异常处理。下面是一个完整的案例：

1. 创建Socket服务器端：

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

public class Server {
    private static final int PORT = 8000;

public static void main(String[] args) {
        try (ServerSocket serverSocket = new ServerSocket(PORT)) {
            System.out.println("Server is listening on port " + PORT);

while (true) {
                Socket clientSocket = serverSocket.accept();
                handleClient(clientSocket);
            }
        } catch (IOException e) {
            System.err.println("Error accepting connections: " + e.getMessage());
        }
    }

private static void handleClient(Socket socket) {
        try (
                DataInputStream dataInputStream = new DataInputStream(socket.getInputStream()));
                DataOutputStream dataOutputStream = new DataOutputStream(socket.getOutputStream()))
        ) {
            // 读写数据，这里假设接收的是字符串
            String clientMessage = dataInputStream.readUTF();
            System.out.println("Received message from client: " + clientMessage);

// 再次发送回客户端的信息
            String serverResponse = "Server response to " + clientMessage;
            dataOutputStream.writeUTF(serverResponse);
        } catch (IOException e) {
            System.err.println("Error handling client connection: " + e.getMessage());
        }
    }
}
```

2. 创建Socket客户端：

```java
import java.io.*;
import java.net.*;

public class Client {
    private static final String SERVER_ADDRESS = "localhost";
    private static final int SERVER_PORT = 8000;

public static void main(String[] args) {
        try (Socket socket = new Socket(SERVER_ADDRESS, SERVER_PORT)))) {
            System.out.println("Connected to server on port " + SERVER_PORT);

// 发送数据
            DataOutputStream dataOutputStream = new DataOutputStream(socket.getOutputStream()));
            String clientMessage = "Hello, Server!";
            dataOutputStream.writeUTF(clientMessage);
            dataOutputStream.flush();

// 接收数据
            BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()))));
            String serverResponse = reader.readLine();
            System.out.println("Received response from server: " + serverResponse));

} catch (IOException e) {
            System.err.println("Error connecting to server: " + e.getMessage());
        }
    }
}
```

以上就是Socket编程的一个基本示例，包括连接建立、数据读写以及异常处理。