在Android中使用NIO的SocketChannel主要包括以下步驟:
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.util.Iterator;
你可以通過調用SocketChannel.open()
方法來創建一個新的SocketChannel實例。
SocketChannel socketChannel = SocketChannel.open();
在Android中,默認情況下,所有的網絡I/O操作都是阻塞的。但NIO允許你將其配置為非阻塞模式。你可以通過調用configureBlocking(false)
方法來實現這一點。
socketChannel.configureBlocking(false);
使用connect()
方法來連接到遠程服務器。請注意,如果此方法是阻塞的,那么你的線程將被掛起,直到連接成功或發生錯誤。但因為我們已經在非阻塞模式下,所以我們可以檢查連接是否已經完成。
InetSocketAddress serverAddress = new InetSocketAddress("www.example.com", 80);
socketChannel.connect(serverAddress);
在Android中,你通常會在一個單獨的線程中使用Selector來等待和處理I/O事件。你可以通過調用Selector.open()
方法來創建一個新的Selector實例。然后,你可以使用SocketChannel.register()
方法將你的SocketChannel注冊到Selector上,并指定我們感興趣的事件(在這種情況下是OP_CONNECT和OP_READ)。
Selector selector = Selector.open();
socketChannel.register(selector, SelectionKey.OP_CONNECT | SelectionKey.OP_READ);
在無限循環中,你可以使用Selector.select()
方法來等待事件的發生。當至少有一個通道準備好進行I/O操作時,該方法將返回。然后,你可以使用Selector.selectedKeys()
方法來獲取所有準備好的鍵,并迭代它們以處理每個事件。
while (true) {
int readyChannels = selector.select();
if (readyChannels == 0) continue;
Set<SelectionKey> selectedKeys = selector.selectedKeys();
Iterator<SelectionKey> keyIterator = selectedKeys.iterator();
while (keyIterator.hasNext()) {
SelectionKey key = keyIterator.next();
if (key.isConnectable()) {
// 處理連接事件
if (socketChannel.finishConnect()) {
System.out.println("Connected to server");
} else {
System.out.println("Failed to connect to server");
socketChannel.close();
}
keyIterator.remove();
}
if (key.isReadable()) {
// 處理讀取事件
ByteBuffer buffer = ByteBuffer.allocate(1024);
int bytesRead = socketChannel.read(buffer);
if (bytesRead == -1) {
System.out.println("Connection closed by server");
socketChannel.close();
} else {
buffer.flip();
while (buffer.hasRemaining()) {
System.out.print((char) buffer.get());
}
buffer.clear();
}
}
}
}
最后,不要忘記在適當的時候關閉你的SocketChannel和Selector。
socketChannel.close();
selector.close();
請注意,上述代碼只是一個基本的示例,并沒有處理所有可能的錯誤情況。在實際應用中,你可能還需要添加額外的錯誤處理邏輯。