EventLoopGroup和BIO操作。

Question

我有Netty Web服务器，它应该使用Hibernate检索数据并向客户端返回响应。

所以我想知道我的实现是否正确

   ChannelPipeline pipeline = ch.pipeline();
        EventExecutorGroup ex = new DefaultEventExecutorGroup(64);

        pipeline.addLast("decoder", new HttpRequestDecoder());
        pipeline.addLast("aggregator", new HttpObjectAggregator(65536));
        pipeline.addLast("encoder", new HttpResponseEncoder());
        pipeline.addLast("chunkedWriter", new ChunkedWriteHandler());

        pipeline.addLast(ex,"handler", new HttpWebServerHandler());

然后在messageReceived方法内部：

    @Override
    public void messageReceived(ChannelHandlerContext ctx, FullHttpRequest request)
            throws Exception {
         if (!request.getDecoderResult().isSuccess()) {
                sendError(ctx, BAD_REQUEST);
                return;
            }
          ctx.executor().execute(new MyRunnable(ctx)); 
    }

在Runnable内部：

@Override
public void run() {

        SomeObejct so = HibernateTemplate.getSomeObject() ;
                    String serializedSo = serialize(so);
          FullHttpResponse res = new DefaultFullHttpResponse(
                    HTTP_1_1, OK, Unpooled.copiedBuffer(serializedSo, CharsetUtil.UTF_8));
            res.headers().set(CONTENT_TYPE, "text/plain; charset=UTF-8");                      ctx.write(res).addListener(ChannelFutureListener.CLOSE);     
}

我做得对吗？

Answer 1

是的，看起来是这样的。您可能需要考虑的是从ChannelPipeline中删除HttpObjectAggregator，从而节省一些内存开销。但请注意，您需要自己处理不同的HTTP消息部分。