One thread one ByteBuffer NIO

Question

Мне интересно, как лучше реализовать многопользовательский NIO-сервер с одним потоком и одним буфером. В настоящее время я использую селектор для достижения этого, но я только выяснил, как делать чтение на всех клиентах. У меня возникла проблема с реализацией записи с использованием одного буфера. Нужен ли мне второй буфер для записи? Или я должен (к сожалению) иметь буфер записи на клиента? Я написал этот пример, чтобы легко показать, как я делаю вещи, так что вы знаете, что вся обработка происходит в потоке планировщика, я не взаимодействую ни с каким другим состоянием через другой поток!

ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor(); 

ServerSocketChannel server = ServerSocketChannel.open(); 
Selector selector = Selector.open(); 
ByteBuffer buffer = ByteBuffer.allocateDirect(8192); 
Map<SelectionKey, SocketChannel> clients = new HashMap<>(); 

server.configureBlocking(false); 
server.register(selector, SelectionKey.OP_ACCEPT); 
server.bind(new InetSocketAddress(43594)); 

scheduler.scheduleAtFixedRate(() -> { 
    try { 
     selector.selectNow(); 
     Iterator<SelectionKey> keys = selector.selectedKeys().iterator(); 
     while (keys.hasNext()) { 
      SelectionKey key = keys.next(); 
      keys.remove(); 
      if (key.isAcceptable()) { 
       for (int i = 0; i < 16; i++) { 
        SocketChannel client = server.accept(); 
        if (client == null) 
         break; 
        client.configureBlocking(false); 
        SelectionKey clientKey = client.register(selector, SelectionKey.OP_READ); 
        clients.put(clientKey, client); 
       } 
      } 
      if (key.isReadable()) { 
       SocketChannel client = clients.get(key); 
       if (client != null) { 
        buffer.clear(); 
        client.read(buffer); 
        buffer.flip(); 
        // do stuff with buffer 
       } 
      } 
     } 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
}, 600, 600, TimeUnit.MILLISECONDS); 

Answer 1

Вы не можете. Для любого менее тривиального, чем эхо-сервер, вам нужен хотя бы один буфер на канал, возможно, два (чтение и запись). В противном случае вы не сможете обрабатывать частично прочитанные запросы или частично написанные ответы.

Вы можете связать буферы с каналом через вложение SelectionKey.