andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Take advantage of buffering in HttpSnoopServer

Browse Source 
- 50% higher requests/sec with pipeline enabled
This commit is contained in:
Trustin Lee 2013-02-08 23:33:10 +09:00
parent affd514b8c
commit 801f563e80
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
example/src/main/java/io/netty/example/http/snoop/HttpSnoopServerHandler.java
View File

@ -17,7 +17,6 @@ package io.netty.example.http.snoop;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundMessageHandlerAdapter;
@ -177,17 +176,22 @@ public class HttpSnoopServerHandler extends ChannelInboundMessageHandlerAdapter<
}
// Write the response.
ChannelFuture future = ctx.write(response);
ctx.nextOutboundMessageBuffer().add(response);
// Close the non-keep-alive connection after the write operation is done.
if (!keepAlive) {
future.addListener(ChannelFutureListener.CLOSE);
ctx.flush().addListener(ChannelFutureListener.CLOSE);
}
}
private static void send100Continue(ChannelHandlerContext ctx) {
HttpResponse response = new DefaultHttpResponse(HTTP_1_1, CONTINUE);
ctx.write(response);
ctx.nextOutboundMessageBuffer().add(response);
}
@Override
protected void endMessageReceived(ChannelHandlerContext ctx) throws Exception {
ctx.flush();
}
@Override