Проблемы с неблокирующим выбором с java.nio

Question

Я только что начал использовать java.nio и, вероятно, использовал его неправильно, поэтому у меня возникли небольшие проблемы с ним.

Я пытаюсь написать что-то вроде Port Forwarder, который может модифицировать трафик, который проходит через него, используя различные дополнительные модули.

Вот как я это делаю:

1. ConnectionManager - поток, который имеет собственный селектор, который зарегистрирован в OP_ACCEPT на ServerSocketChannel. Всякий раз, когда он выбирает что угодно - он создает объект подключения ConnectionProcessor, который управляет соединением.

2. ConnectionProcessor - нить , что открывает SocketChannel с заранее определенной передней точки (где посылать пакеты из недавно подключенного клиента). Затем он открывает свой собственный селектор и регистрирует его для OP_READ клиента SocketChannel и сервер SocketChannel OP_READ.

Затем процессор переходит в бесконечный цикл, выбирая данные из селектора и перенаправляя его соответствующим образом. Чтобы определить, куда отправлять данные, он сравнивает SelectionKey.channel() с clientChannel и serverChannel.

Выбор в ConnectionProcessor производится с таймаутом 5 секунд (выберите (5000)) - для обработки тайм-аутов. При выборе тайм-аута - он пытается прочитать из обоих каналов, чтобы получить исключение или -1 результат.

Теперь вот мои вопросы/проблемы:

1. ли право использовать key.cancel() после обработки ключа? Большинство примеров, которые я видел в Интернете просто удалите ключ из selectedKeys(). key.cancel() , похоже, намного лучше подходит.

2. Правильно ли иметь несколько селекторов , которые в основном используют тот же сервер ServerSocketChannel? Или я должен всегда использовать одиночный селектор и передавать выбранные ключи соответствующим менеджерам? То, что я имею в виду, что если 3 клиенты подключаются одновременно, то это то, что будет:

   а) менеджер создает процессор. Процессор открывает клиентский канал. Процессор регистрирует свой собственный селектор на клиентский канал. б) повторение (а) в) повторение (а)

3. По какой-то причине, после того, как даже один клиент подключается к моей экспедитора - это не будет обрабатывать сообщения быстрее, чем 5000msec тайм-аут. Он начинает выбирать, блокируется в течение 5 секунд, а затем идет на вторую итерацию и получает мне 5-6 сообщений, которые я получил во время предыдущего таймаута. Должен ли я обвинять (1), (2) или какую-то другую причину?
4. Есть ли какое-либо руководство по поводу того, как все это работает внутри? Я как бы человек, который понимает, как использовать вещи только после того, как я полностью пойму механику внизу. API чтения не помогает, поскольку он написан для людей, которые уже знают правильный способ использования nio.

Спасибо за то, что прочитали весь мой вопрос и заблаговременно за любую помощь.

Answer 1

1. No. Просто удалите ключ из выбранного набора. Обычно это делается через iterator.remove(). Если вы отмените их, то он больше никогда не будет выбран.

2. Это бессмысленно. Вам не нужен второй селектор или дополнительный поток. Для этого и нужен НИО. Вы можете обрабатывать все это с помощью исходного селектора в исходном потоке.

3. Возможно, это вызвано странным кодом. Повторите это, как указано выше, и посмотрите, все ли это происходит. Если это так, разместите здесь код.

4. Вы должны были бы прочитать API Berkeley Sockets или хорошую книгу, такие как Стивенс, Unix Network Programming, или мое ;-)