Comment faire pour que 'channelRead' soit appelé une fois après chaque 'read' dans Netty

Question

J'écris un serveur proxy HTTP dans Netty.

Je voudrais channelRead seulement être tiré au plus une fois après que j'appelle read - et à aucun autre moment. En d'autres termes, je ne veux pas channelRead de tirer jusqu'à ce que je suis prêt pour le message.

J'ai défini AUTO_READ=false. J'appelle ctx.read() une fois dans channelActive (et nulle part ailleurs).

Cependant, pour une curl http://localhost:8080/, les deux incendies gestionnaire channelRead de base:

io.netty.handler.codec.http.DefaultHttpRequest 
io.netty.handler.codec.http.LastHttpContent$1 

Comment puis-je empêcher LastHttpContent d'arriver jusqu'à ce que j'appelle ctx.read() pour la deuxième fois?

Answer 1

FlowControlHandler résout ce problème: il a été conçu spécifiquement pour activer ce comportement.

De the docs:

Le FlowControlHandler assure que seul un message par read() est envoyé en aval .

...

C'est un problème commun avec le HttpObjectDecoder qui va très souvent un feu HttpRequest qui est immédiatement suivi d'un événement LastHttpContent.

ChannelPipeline pipeline = ...;

pipeline.addLast(new HttpServerCodec());

pipeline.addLast(new FlowControlHandler());

pipeline.addLast(new MyExampleHandler());