如何在Java中实现并发IO操作

原创偏执的太偏执、 2024-11-22 01:18 23阅读 0赞

在Java中，我们可以使用多线程、Socket编程以及相关的并发库（如ConcurrentHashMap）来实现并发IO操作。

以下是一些具体的示例：

1. 使用多线程读写文件：
```java
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;

public class ConcurrentFileIO {
    private final int threadCount = 4; // 假设线程数为4

public void writeToFile(String filePath) throws IOException {
        for (int i = 0; i < threadCount; i++) {
            Thread workerThread = new Thread(() -> writeToPartOfFile(filePath, i * 1000))));
            workerThread.start();
        }
    }

private void writeToPartOfFile(String filePath, long partNo) throws IOException {
        Files.write(Paths.get(filePath, String.valueOf(partNo)))),
                42); // 假设每次写入42字节
    }

public static void main(String[] args) throws IOException {
        ConcurrentFileIO fileIO = new ConcurrentFileIO();
        String filePath = "./testfile.txt"; // 假设文件路径为./testfile.txt

fileIO.writeToFile(filePath);

// 之后可以读取该文件，验证数据是否正确
    }
}
```

2. 使用Socket编程实现并发客户端连接：
```java
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class ConcurrentSocketIO {
    private final int serverPort = 9000; // 假设服务器端口为9000

public void serve() throws IOException {
        ServerSocket serverSocket = new ServerSocket(serverPort);
        System.out.println("Server is listening on port " + serverPort);

while (true) {
            Socket clientSocket = serverSocket.accept();
            new ClientHandler(clientSocket).start(); // 创建客户端处理器并启动
        }
    }

public static void main(String[] args) throws IOException {
        ConcurrentSocketIO socketIO = new ConcurrentSocketIO();
        socketIO.serve();
    }
}
```

以上示例分别展示了如何在Java中使用多线程和Socket编程来实现并发IO操作。