1. Schritte
(1) Erstellen Sie eine SocketChannel-Instanz und konfigurieren Sie sie im nicht blockierenden Modus. Nur in der SocketChannel-Instanz Alle sind nicht blockierend.
(2) Verwenden Sie die connect()-Methode, um eine Verbindung zum Server herzustellen, und verwenden Sie eine While-Schleife, um kontinuierlich zu erkennen und eine vollständige Verbindung herzustellen. Sie müssen finishConnect() verwenden, um den Verbindungsprozess abzuschließen, bevor sofortige E/A-Vorgänge erforderlich sind.
(3) Verwenden Sie ByteBuffer zum Lesen und Schreiben von Bytes. Wenn SelectableChannel ein nicht blockierender Modus ist, liest und schreibt sein E/A-Vorgang möglicherweise weniger Bytes als die tatsächlichen Bytes oder sogar keine. Daher verwenden wir kontinuierliches Lesen und Schreiben in einer Schleife, um sicherzustellen, dass das Lesen und Schreiben abgeschlossen ist.
2, Beispiel
public class NonBlockingTCPClient {
public static void main(String[] args) {
byte[] data = "hello".getBytes();
SocketChannel channel = null;
try {
// 1. open a socket channel
channel = SocketChannel.open();
// adjust to be nonblocking
channel.configureBlocking(false);
// 2. init connection to server and repeatedly poll with complete
// connect() and finishConnect() are nonblocking operation, both return immediately
if (!channel.connect(new InetSocketAddress(InetAddress.getLocalHost(), 8899))) {
while (!channel.finishConnect()) {
System.out.print(".");
}
}
System.out.println("Connected to server...");
ByteBuffer writeBuffer = ByteBuffer.wrap(data);
ByteBuffer readBuffer = ByteBuffer.allocate(data.length);
int totalBytesReceived = 0;
int bytesReceived;
// 3. read and write bytes
while (totalBytesReceived < data.length) {
if (writeBuffer.hasRemaining()) {
channel.write(writeBuffer);
}
if ((bytesReceived = channel.read(readBuffer)) == -1) {
throw new SocketException("Connection closed prematurely");
}
totalBytesReceived += bytesReceived;
System.out.print(".");
}
System.out.println("Server said: " + new String(readBuffer.array()));
} catch (IOException e) {
e.printStackTrace();
} finally {
// 4 .close socket channel
try {
if (channel != null) {
channel.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}Das obige ist der detaillierte Inhalt vonSo implementieren Sie den SocketChannel-Client in Java. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
