非常简单的问题:我正在从一个SocketChannel读取数据,并希望将结果写入另一个SocketChannel。我使用了一个Selector对象,所以我等待直到一个SocketChannel可读,将数据转储到ByteBuffer中,然后当下一个SocketChannel可写时,将ByteBuffer转储到那里。到目前为止都还好。然而,似乎没有任何方法可以实际“清除”一个ByteBuffer,因此我无法进行任何检查以知道是否有新数据到达。
我尝试了.clear()方法,但显然这并没有清除缓冲区,而只是将缓冲区位置重置为1。
以下是一些示例代码:
我尝试了.clear()方法,但显然这并没有清除缓冲区,而只是将缓冲区位置重置为1。
以下是一些示例代码:
ByteBuffer channel1buf = ByteBuffer.allocate(1024);
ByteBuffer channel2buf = ByteBuffer.allocate(1024);
if (key.isReadable()) {
if (key.channel().equals(channel1)) {
channel1.read(channel2buf);
} else if (key.channel().equals(channel2)) {
channel2.read(channel1buf);
}
} else if (key.isWritable()) {
if (key.channel().equals(channel1) && channel1buf.asCharBuffer().length() > 0) {
channel1.write(channel1buf);
/* some way to clear channel1buf */
} else /* same idea for channel2... */
}
ByteBuffer
用作附件,这样您就可以从SelectionKey
中检索附件并避免所有嵌套的if子句。 - mike