我的問(wèn)題比以下場(chǎng)景更通用，盡管這涵蓋了所需的一切。這是針對(duì)Java和socket編程的正確做法。設(shè)想：一臺(tái)服務(wù)器有多個(gè)客戶端。非阻塞 I/O的使用該服務(wù)器是另一臺(tái)服務(wù)器的客戶端。阻塞 I/O的使用每種情況有兩種情況：在一種情況下，所有數(shù)據(jù)都適合分配的字節(jié)緩沖區(qū)，在第二種情況下，它們不適合（僅適用于一次迭代，不適用于程序的生命周期）。我發(fā)現(xiàn)的所有非阻塞 I/O 的示例都是這樣的：InetAddress host = InetAddress.getByName("localhost");Selector selector = Selector.open();ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();serverSocketChannel.configureBlocking(false);serverSocketChannel.bind(new InetSocketAddress(host, 1234));serverSocketChannel.register(selector, SelectionKey. OP_ACCEPT);while (true) { if (selector.select() <= 0) continue; Set<SelectionKey> selectedKeys = selector.selectedKeys(); Iterator<SelectionKey> iterator = selectedKeys.iterator(); while (iterator.hasNext()) { key = (SelectionKey) iterator.next(); iterator.remove(); if (key.isAcceptable()) { SocketChannel socketChannel = serverSocketChannel.accept(); socketChannel.configureBlocking(false); socketChannel.register(selector, SelectionKey.OP_READ); // Do something or do nothing } if (key.isReadable()) { SocketChannel socketChannel = (SocketChannel) key.channel(); ByteBuffer buffer = ByteBuffer.allocate(BUFFER_SIZE); socketChannel.read(buffer); // Something something dark side if (result.length() <= 0) { sc.close(); // Something else } } }read如果緩沖區(qū)足夠大，這里是否讀取來(lái)自該特定客戶端和該特定請(qǐng)求的所有傳入數(shù)據(jù)，或者我是否需要將其放在循環(huán)內(nèi)while？如果緩沖區(qū)不夠大？如果是 a write，我也可以這樣做嗎socketChannel.write(buffer)（至少?gòu)某绦虻慕嵌葋?lái)看）？這里的文檔沒(méi)有指定所有傳入數(shù)據(jù)都適合緩沖區(qū)的情況。當(dāng)我有阻塞 I/O 時(shí)，這也會(huì)讓人有點(diǎn)困惑：然而，可以保證的是，如果通道處于阻塞模式并且緩沖區(qū)中至少剩余一個(gè)字節(jié)，則此方法將阻塞，直到至少讀取一個(gè)字節(jié)。這是否意味著這里（阻塞 I/O）我需要以任何一種方式read通過(guò)while循環(huán)（我發(fā)現(xiàn)的大多數(shù)示例都是這樣做的）？做手術(shù)怎么辦write？所以，總而言之，我的問(wèn)題是，從中間服務(wù)器（客戶端到第二個(gè)服務(wù)器）的角度來(lái)看，在我的場(chǎng)景中讀寫數(shù)據(jù)的正確方法是什么？
1 回答
白板的微信
TA貢獻(xiàn)1883條經(jīng)驗(yàn) 獲得超3個(gè)贊
如果您沒(méi)有調(diào)用configureBlocking(false)，那么是的，您將使用循環(huán)來(lái)填充緩沖區(qū)。
然而……非阻塞套接字的要點(diǎn)是不要掛起等待任何一個(gè)套接字，因?yàn)檫@會(huì)延遲從所有剩余套接字（其選定的鍵尚未被迭代器處理）的讀取。實(shí)際上，如果十個(gè)客戶端連接，并且其中一個(gè)碰巧連接速度較慢，則其他部分或全部客戶端可能會(huì)遇到同樣的緩慢情況。
（未指定所選鍵集的確切順序。查看 Selector 實(shí)現(xiàn)類的源代碼是不明智的，因?yàn)槿狈θ魏雾樞虮ＷC意味著 Java SE 的未來(lái)版本可以更改順序。）
為了避免等待任何一個(gè)套接字，您不要嘗試一次性填滿緩沖區(qū)；相反，您可以在不阻塞的情況下讀取套接字可以提供的任何內(nèi)容，每次調(diào)用只讀取一次select()。
由于每個(gè) ByteBuffer 可能保存部分?jǐn)?shù)據(jù)序列，因此您需要記住每個(gè) Socket 的每個(gè) ByteBuffer 的進(jìn)度。幸運(yùn)的是，SelectionKey 有一個(gè)方便的方法來(lái)做到這一點(diǎn)：附件。
您還想記住從每個(gè)套接字讀取了多少字節(jié)。因此，現(xiàn)在您需要記住每個(gè)套接字的兩件事：字節(jié)數(shù)和字節(jié)緩沖區(qū)。
class ReadState {
final ByteBuffer buffer = ByteBuffer.allocate(BUFFER_SIZE);
long count;
}
while (true) {
// ...
if (key.isAcceptable()) {
SocketChannel socketChannel = serverSocketChannel.accept();
socketChannel.configureBlocking(false);
// Attach the read state for this socket
// to its corresponding key.
socketChannel.register(selector, SelectionKey.OP_READ,
new ReadState());
}
if (key.isReadable()) {
SocketChannel socketChannel = (SocketChannel) key.channel();
ReadState state = (ReadState) key.attachment();
ByteBuffer buffer = state.buffer;
state.count += socketChannel.read(buffer);
if (state.count >= DATA_LENGTH) {
socketChannel.close();
}
buffer.flip();
// Caution: The speed of this connection will limit your ability
// to process the remaining selected keys!
anotherServerChannel.write(buffer);
}
對(duì)于阻塞通道，您可以只使用一次write(buffer)調(diào)用，但是正如您所看到的，使用阻塞通道可能會(huì)限制主服務(wù)器使用非阻塞通道的優(yōu)勢(shì)。將與其他服務(wù)器的連接也設(shè)置為非阻塞通道可能是值得的。這會(huì)讓事情變得更加復(fù)雜，所以除非你希望我這樣做，否則我不會(huì)在這里解決這個(gè)問(wèn)題。
添加回答
舉報(bào)
0/150
提交
取消