Ошибка OutMemoryError при подключении к стороннему серверу, который не может достаточно быстро обрабатывать запросы.
Попытался передать NioClientSocketChannelFactory в службу-исполнитель с ограниченной очередью и политикой отбрасывания (ThreadPoolExecutor.DiscardPolicy), но все равно получил OutOfMemoryError.
Что мне не хватает?
Спасибо
Если буфер записи вашего канала Netty на стороне клиента заполняется, а сервер читает его недостаточно быстро, вы увидите OutOfMemoryError на стороне клиента. Чтобы избежать этого, вы должны перестать писать, если Channel.isWritable() возвращает false. Вы будете уведомлены событием channelInterestOpsChanged, когда состояние Channel.writable' changes. Then, you can check again ifChannel.isWritable()returnstrue` и продолжите запись.
Если можно отбросить ожидающие данные, я бы просто не вызывал Channel.write(), если Channel.isWritable() возвращает false.
Вы можете настроить при изменении свойства Channel.writable свойства водяного знака, предоставленные в NioSocketChannelConfig. Кроме того, пожалуйста, взгляните на пример «отброса», в котором используется этот метод.
