с использованием трубопровода Netty эффективно

Question

На сервере ChannelPipelineFactory # getPipeline() вызывается для каждого нового соединения. У моих каналов ChannelHandlers сервера есть выделение для буферов сериализации и других объектов, которые не являются потокобезопасными. Как я могу избежать выделения их для каждого соединения? Мое приложение имеет большой объем недолговечных соединений, и это ухудшает производительность. Я не сохраняю состояние подключения в обработчиках, мне действительно нужно их выделять один раз в потоке, который будет использовать конвейер, потому что объекты в обработчиках не являются потокобезопасными.

Возможно, я мог бы использовать конвейер с одним обработчиком. Когда какое-либо событие получено, я получаю ссылку на мой фактический обработчик из ThreadLocal. Таким образом, я только распределяю фактический обработчик один раз на потоки, обслуживающие соединения. Это означает, что ThreadLocal ищет все события.

Есть ли другие решения, которые могут быть лучше?

У меня создалось впечатление, что конвейер Netty отлично смотрится в относительно простом примере кода и довольно аккуратный, когда он подходит к проблеме (например, обработка HTTP), но что он не очень гибкий для многих других сценариев. Here - это что-то elses мысли по этим линиям. Это не какая-то катастрофа, поскольку использование одного обработчика для рулона вашего собственного «конвейера» кажется совершенно жизнеспособным, но мне интересно, не делаю ли я это неправильно?

Answer 1

Использование ThreadLocal кажется хорошей идеей, если этого достаточно для вас. Имейте в виду, что это будет хорошо работать только для восходящих событий, поскольку нисходящие события могут быть запущены любым потоком, поэтому материал ThreadLocal может не работать так хорошо.