Java网络编程中服务器端阻塞问题的实战示例

原创爱被打了一巴掌 2024-12-02 09:39 6阅读 0赞

在Java网络编程中，服务器端阻塞问题主要出现在使用Socket进行全双工通信时。当客户端发送数据后，服务端如果直接等待接收，就会出现阻塞的情况。

以下是一个简单的实战示例，展示如何避免服务端阻塞：

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

public class ServerWithNonBlocking {
    public static void main(String[] args) throws IOException {
        // 创建服务器套接字，非阻塞模式
        ServerSocket serverSocket = new ServerSocket(1234, 0)); // 第二个参数设为0表示非阻塞

System.out.println("Server started on port 1234...");

while (true) {
            // 监听客户端连接，非阻塞模式
            Socket clientSocket = serverSocket.accept();

System.out.println("Client connected: " + clientSocket.getRemoteSocketAddress()));

// 客户端发送数据后，服务端立刻处理，不会阻塞
            Thread thread = new Thread(() -> {
                try (InputStream is = clientSocket.getInputStream();
                     OutputStream os = clientSocket.getOutputStream()) {

byte[] bytes = new byte[1024];
                    int count;

System.out.println("Server sending data back...");

// 服务端发送数据给客户端
                    os.write(bytes, 0, bytes.length));

System.out.println("Data sent successfully.");

} catch (IOException e) {
                    System.out.println("Error occurred while sending data: " + e.getMessage());
                }
            }));

thread.start();
        }
    }
}
```

在这个示例中，服务端创建了一个非阻塞的ServerSocket。当客户端连接时，服务端能够立刻处理并发送数据，不会因为等待接收而阻塞。