import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
@Override
protected Object encode(ChannelHandlerContext ctx, Channel channel,
                        Object message) throws Exception {
    if (message instanceof SyncMessage) {
        ChannelBuffer buf = new DynamicChannelBuffer(512);
        ChannelBufferOutputStream os = new ChannelBufferOutputStream(buf);
        TCompactProtocol thriftProtocol =
                new TCompactProtocol(new TIOStreamTransport(os));
        ((SyncMessage) message).write(thriftProtocol);

        ChannelBuffer len = ChannelBuffers.buffer(4);
        len.writeInt(buf.readableBytes());
        return ChannelBuffers.wrappedBuffer(len, buf);
    }
    return message;
}
 

import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent event) throws Exception {
    if (event.getMessage() instanceof HttpRequest) {
        try {
            HttpServletRequest httpServletRequest = new NettyHttpServletRequestAdaptor((HttpRequest) event.getMessage(), ctx.getChannel());
            HttpResponse response = new DefaultHttpResponse(HTTP_1_1, OK);
            response.setContent(new DynamicChannelBuffer(200));
            HttpServletResponse httpServletResponse = new NettyHttpServletResponseAdaptor(response, ctx.getChannel());
            dispatcher.dispatch(httpServletRequest,httpServletResponse);
            response.headers().set(HttpHeaders.Names.CONTENT_LENGTH,response.getContent().writerIndex());
            ChannelFuture future = ctx.getChannel().write(response);
            future.addListener(ChannelFutureListener.CLOSE);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
 

import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e)
        throws Exception {
    HttpRequest request = (HttpRequest) e.getMessage();
    String uri = request.getUri();
    
    System.out.println("uri:" + uri);
    HttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
    ChannelBuffer buffer = new DynamicChannelBuffer(2048);
    buffer.writeBytes("hello!! 你好".getBytes("UTF-8"));
    response.setContent(buffer);
    response.setHeader("Content-Type", "text/html; charset=UTF-8");
    response.setHeader("Content-Length", response.getContent().writerIndex());
    Channel ch = e.getChannel();
    // Write the initial line and the header.
    ch.write(response);
    ch.disconnect();
    ch.close();

}
 

import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
@Before
public void startUp() {
    byte[] bytes = PAYLOAD.getBytes();
    buf = new DynamicChannelBuffer(bytes.length);
    buf.writeBytes(bytes);
}
 

import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
/**
 * Constructor
 *
 * @param estimatedLength Estimated length of the buffer
 */
public DynamicChannelBufferOutputStream(int estimatedLength) {
  buffer = (DynamicChannelBuffer)
      ChannelBuffers.dynamicBuffer(ByteOrder.LITTLE_ENDIAN,
          estimatedLength, DirectChannelBufferFactory.getInstance());
}
 

import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
/**
 * Constructor.
 *
 * @param buffer Buffer to read from
 */
public DynamicChannelBufferInputStream(DynamicChannelBuffer buffer) {
  this.buffer = buffer;
}
 

import org.jboss.netty.buffer.DynamicChannelBuffer; //导入依赖的package包/类
/**
 * Get the dynamic channel buffer
 *
 * @return dynamic channel buffer (not a copy)
 */
public DynamicChannelBuffer getDynamicChannelBuffer() {
  return buffer;
}