GET /hello.txt HTTP/1.1User-Agent: curl/7.16.3 libcurl/7.16.3 OpenSSL/0.9.7l zlib/1.2.3Host: www.example.comAccept-Language: en, mi

根据HTTP标准，HTTP请求可以使用多种请求方法。

HTTP1.0定义了三种请求方法： GET, POST 和 HEAD方法。

HTTP1.1新增了五种请求方法：OPTIONS, PUT, DELETE, TRACE 和 CONNECT 方法。

 1 import io.netty.bootstrap.ServerBootstrap; 2 import io.netty.channel.ChannelFuture; 3 import io.netty.channel.ChannelInitializer; 4 import io.netty.channel.EventLoopGroup; 5 import io.netty.channel.nio.NioEventLoopGroup; 6 import io.netty.channel.socket.SocketChannel; 7 import io.netty.channel.socket.nio.NioServerSocketChannel; 8 import io.netty.handler.codec.http.HttpObjectAggregator; 9 import io.netty.handler.codec.http.HttpRequestDecoder;10 import io.netty.handler.codec.http.HttpResponseEncoder;11 import io.netty.handler.stream.ChunkedWriteHandler;12 13 /**14  * @author lilinfeng15  * @version 1.016  * @date 2014年2月14日17  */18 public class HttpFileServer {19 20     private static final String DEFAULT_URL = "/";21 22     public void run(final int port, final String url) throws Exception {23         EventLoopGroup bossGroup = new NioEventLoopGroup();24         EventLoopGroup workerGroup = new NioEventLoopGroup();25         try {26             ServerBootstrap b = new ServerBootstrap();27             b.group(bossGroup, workerGroup)28                     .channel(NioServerSocketChannel.class)29                     .childHandler(new ChannelInitializer<SocketChannel>() {30                         @Override31                         protected void initChannel(SocketChannel ch)32                                 throws Exception {33                             ch.pipeline().addLast("http-decoder",34                                     new HttpRequestDecoder()); // 请求消息解码器35                             ch.pipeline().addLast("http-aggregator",36                                     new HttpObjectAggregator(65536));// 目的是将多个消息转换为单一的request或者response对象37                             ch.pipeline().addLast("http-encoder",38                                     new HttpResponseEncoder());//响应解码器39                             ch.pipeline().addLast("http-chunked",40                                     new ChunkedWriteHandler());//目的是支持异步大文件传输（）41                             ch.pipeline().addLast("fileServerHandler",42                                     new HttpFileServerHandler(url));// 业务逻辑43                         }44                     });45             ChannelFuture future = b.bind("127.0.0.1", port).sync();46             System.out.println("HTTP文件目录服务器启动，网址是 : " + "http://127.0.0.1:"47                     + port + url);48             future.channel().closeFuture().sync();49         } catch (Exception e) {50             e.printStackTrace();51         } finally {52             bossGroup.shutdownGracefully();53             workerGroup.shutdownGracefully();54         }55     }56 57     public static void main(String[] args) throws Exception {58         int port = 8080;59         if (args.length > 0) {60             try {61                 port = Integer.parseInt(args[0]);62             } catch (NumberFormatException e) {63                 e.printStackTrace();64             }65         }66         String url = DEFAULT_URL;67         if (args.length > 1)68             url = args[1];69         new HttpFileServer().run(port, url);70     }71 }

import io.netty.buffer.ByteBuf;import io.netty.buffer.Unpooled;import io.netty.channel.*;import io.netty.handler.codec.http.*;import io.netty.handler.stream.ChunkedFile;import io.netty.util.CharsetUtil;import javax.activation.MimetypesFileTypeMap;import java.io.File;import java.io.FileNotFoundException;import java.io.RandomAccessFile;import java.io.UnsupportedEncodingException;import java.net.URLDecoder;import java.util.regex.Pattern;import static io.netty.handler.codec.http.HttpMethod.GET;import static io.netty.handler.codec.http.HttpResponseStatus.*;import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;/** * @author lilinfeng * @version 1.0 * @date 2014年2月14日 */public class HttpFileServerHandler extends        SimpleChannelInboundHandler<FullHttpRequest> {    private final String url;    public HttpFileServerHandler(String url) {        this.url = url;    }    @Override    protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest request) throws Exception {        /*如果无法解码400*/        if (!request.decoderResult().isSuccess()) {            sendError(ctx, BAD_REQUEST);            return;        }        /*只支持GET方法*/        if (request.method() != GET) {            sendError(ctx, METHOD_NOT_ALLOWED);            return;        }        final String uri = request.uri();        /*格式化URL，并且获取路径*/        final String path = sanitizeUri(uri);        if (path == null) {            sendError(ctx, FORBIDDEN);            return;        }        File file = new File(path);        /*如果文件不可访问或者文件不存在*/        if (file.isHidden() || !file.exists()) {            sendError(ctx, NOT_FOUND);            return;        }        /*如果是目录*/        if (file.isDirectory()) {            //1. 以/结尾就列出所有文件            if (uri.endsWith("/")) {                sendListing(ctx, file);            } else {                //2. 否则自动+/                sendRedirect(ctx, uri + ‘/‘);            }            return;        }        if (!file.isFile()) {            sendError(ctx, FORBIDDEN);            return;        }        RandomAccessFile randomAccessFile = null;        try {            randomAccessFile = new RandomAccessFile(file, "r");// 以只读的方式打开文件        } catch (FileNotFoundException fnfe) {            sendError(ctx, NOT_FOUND);            return;        }        long fileLength = randomAccessFile.length();        //创建一个默认的HTTP响应        HttpResponse response = new DefaultHttpResponse(HTTP_1_1, OK);        //设置Content Length        HttpUtil.setContentLength(response, fileLength);        //设置Content Type        setContentTypeHeader(response, file);        //如果request中有KEEP ALIVE信息        if (HttpUtil.isKeepAlive(request)) {            response.headers().set(HttpHeaderNames.CONNECTION, HttpHeaderValues.KEEP_ALIVE);        }        ctx.write(response);        ChannelFuture sendFileFuture;        //通过Netty的ChunkedFile对象直接将文件写入发送到缓冲区中        sendFileFuture = ctx.write(new ChunkedFile(randomAccessFile, 0,                fileLength, 8192), ctx.newProgressivePromise());        sendFileFuture.addListener(new ChannelProgressiveFutureListener() {            @Override            public void operationProgressed(ChannelProgressiveFuture future,                                            long progress, long total) {                if (total < 0) { // total unknown                    System.err.println("Transfer progress: " + progress);                } else {                    System.err.println("Transfer progress: " + progress + " / "                            + total);                }            }            @Override            public void operationComplete(ChannelProgressiveFuture future)                    throws Exception {                System.out.println("Transfer complete.");            }        });        ChannelFuture lastContentFuture = ctx                .writeAndFlush(LastHttpContent.EMPTY_LAST_CONTENT);        //如果不支持keep-Alive，服务器端主动关闭请求        if (!HttpUtil.isKeepAlive(request)) {            lastContentFuture.addListener(ChannelFutureListener.CLOSE);        }    }    @Override    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)            throws Exception {        cause.printStackTrace();        if (ctx.channel().isActive()) {            sendError(ctx, INTERNAL_SERVER_ERROR);        }    }    private static final Pattern INSECURE_URI = Pattern.compile(".*[<>&\"].*");    private String sanitizeUri(String uri) {        try {            uri = URLDecoder.decode(uri, "UTF-8");        } catch (UnsupportedEncodingException e) {            try {                uri = URLDecoder.decode(uri, "ISO-8859-1");            } catch (UnsupportedEncodingException e1) {                throw new Error();            }        }        if (!uri.startsWith(url)) {            return null;        }        if (!uri.startsWith("/")) {            return null;        }        uri = uri.replace(‘/‘, File.separatorChar);        if (uri.contains(File.separator + ‘.‘)                || uri.contains(‘.‘ + File.separator) || uri.startsWith(".")                || uri.endsWith(".") || INSECURE_URI.matcher(uri).matches()) {            return null;        }        return System.getProperty("user.dir") + File.separator + uri;    }    private static final Pattern ALLOWED_FILE_NAME = Pattern            .compile("[A-Za-z0-9][-_A-Za-z0-9\\.]*");    private static void sendListing(ChannelHandlerContext ctx, File dir) {        FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1, OK);        response.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/html; charset=UTF-8");        StringBuilder buf = new StringBuilder();        String dirPath = dir.getPath();        buf.append("<!DOCTYPE html>\r\n");        buf.append("<html><head><title>");        buf.append(dirPath);        buf.append(" 目录：");        buf.append("</title></head><body>\r\n");        buf.append("<h3>");        buf.append(dirPath).append(" 目录：");        buf.append("</h3>\r\n");        buf.append("<ul>");        buf.append("<li>链接：<a href=http://www.mamicode.com/"../\">..</a></li>\r\n");        for (File f : dir.listFiles()) {            if (f.isHidden() || !f.canRead()) {                continue;            }            String name = f.getName();            if (!ALLOWED_FILE_NAME.matcher(name).matches()) {                continue;            }            buf.append("<li>链接：<a href=http://www.mamicode.com/"");            buf.append(name);            buf.append("\">");            buf.append(name);            buf.append("</a></li>\r\n");        }        buf.append("</ul></body></html>\r\n");        ByteBuf buffer = Unpooled.copiedBuffer(buf, CharsetUtil.UTF_8);        response.content().writeBytes(buffer);        buffer.release();        ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);    }    private static void sendRedirect(ChannelHandlerContext ctx, String newUri) {        FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1, FOUND);        response.headers().set(HttpHeaderNames.LOCATION, newUri);        ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);    }    private static void sendError(ChannelHandlerContext ctx,                                  HttpResponseStatus status) {        FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1,                status, Unpooled.copiedBuffer("Failure: " + status.toString()                + "\r\n", CharsetUtil.UTF_8));        response.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/plain; charset=UTF-8");        ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);    }    private static void setContentTypeHeader(HttpResponse response, File file) {        MimetypesFileTypeMap mimeTypesMap = new MimetypesFileTypeMap();        response.headers().set(HttpHeaderNames.CONTENT_TYPE,                mimeTypesMap.getContentType(file.getPath()));    }}

import io.netty.handler.codec.http.FullHttpRequest;/** * @author Lilinfeng * @version 1.0 * @date 2014年3月1日 */public class HttpJsonRequest {    private FullHttpRequest request;    private Object body;    public HttpJsonRequest(FullHttpRequest request, Object body) {        this.request = request;        this.body = body;    }    /**     * @return the request     */    public final FullHttpRequest getRequest() {        return request;    }    /**     * @param request the request to set     */    public final void setRequest(FullHttpRequest request) {        this.request = request;    }    /**     * @return the object     */    public final Object getBody() {        return body;    }    /**     * @param object the object to set     */    public final void setBody(Object body) {        this.body = body;    }    /*     * (non-Javadoc)     *      * @see java.lang.Object#toString()     */    @Override    public String toString() {        return "HttpJsonRequest [request=" + request + ", body =" + body + "]";    }}

import io.netty.handler.codec.http.FullHttpResponse;/** * @author Administrator * @version 1.0 * @date 2014年3月1日 */public class HttpJsonResponse {    private FullHttpResponse httpResponse;    private Object result;    public HttpJsonResponse(FullHttpResponse httpResponse, Object result) {        this.httpResponse = httpResponse;        this.result = result;    }    /**     * @return the httpResponse     */    public final FullHttpResponse getHttpResponse() {        return httpResponse;    }    /**     * @param httpResponse the httpResponse to set     */    public final void setHttpResponse(FullHttpResponse httpResponse) {        this.httpResponse = httpResponse;    }    /**     * @return the body     */    public final Object getResult() {        return result;    }    /**     * @param body the body to set     */    public final void setResult(Object result) {        this.result = result;    }    /*     * (non-Javadoc)     *      * @see java.lang.Object#toString()     */    @Override    public String toString() {        return "HttpJsonResponse [httpResponse=" + httpResponse + ", result="                + result + "]";    }}

import demo.protocol.http.json.FastJsonUtils;import io.netty.buffer.ByteBuf;import io.netty.buffer.Unpooled;import io.netty.channel.ChannelHandlerContext;import io.netty.handler.codec.MessageToMessageEncoder;import java.nio.charset.Charset;/** * Created by carl.yu on 2016/12/16. */public abstract class AbstractHttpJsonEncoder<T> extends MessageToMessageEncoder<T> {    final static Charset UTF_8 = Charset.forName("utf-8");    protected ByteBuf encode0(ChannelHandlerContext ctx, Object body) {        String jsonStr = FastJsonUtils.convertObjectToJSON(body);        ByteBuf encodeBuf = Unpooled.copiedBuffer(jsonStr, UTF_8);        return encodeBuf;    }}

import demo.protocol.http.json.FastJsonUtils;import io.netty.buffer.ByteBuf;import io.netty.channel.ChannelHandlerContext;import io.netty.handler.codec.MessageToMessageDecoder;import java.nio.charset.Charset;/** * Created by carl.yu on 2016/12/16. */public abstract class AbstractHttpJsonDecoder<T> extends MessageToMessageDecoder<T> {    private Class<?> clazz;    private boolean isPrint;    private final static Charset UTF_8 = Charset.forName("UTF-8");    protected AbstractHttpJsonDecoder(Class<?> clazz) {        this(clazz, false);    }    protected AbstractHttpJsonDecoder(Class<?> clazz, boolean isPrint) {        this.clazz = clazz;        this.isPrint = isPrint;    }    protected Object decode0(ChannelHandlerContext ctx, ByteBuf body) {        String content = body.toString(UTF_8);        if (isPrint)            System.out.println("The body is : " + content);        Object result = FastJsonUtils.convertJSONToObject(content, clazz);        return result;    }}

import io.netty.buffer.Unpooled;import io.netty.channel.ChannelFutureListener;import io.netty.channel.ChannelHandlerContext;import io.netty.handler.codec.http.DefaultFullHttpResponse;import io.netty.handler.codec.http.FullHttpRequest;import io.netty.handler.codec.http.FullHttpResponse;import io.netty.handler.codec.http.HttpResponseStatus;import io.netty.util.CharsetUtil;import java.util.List;import static io.netty.handler.codec.http.HttpHeaders.Names.CONTENT_TYPE;import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;/** * Created by carl.yu on 2016/12/16. */public class HttpJsonRequestDecoder extends AbstractHttpJsonDecoder<FullHttpRequest> {    public HttpJsonRequestDecoder(Class<?> clazz) {        this(clazz, false);    }    /**     * 构造器     *     * @param clazz   解码的对象信息     * @param isPrint 是否需要打印     */    public HttpJsonRequestDecoder(Class<?> clazz, boolean isPrint) {        super(clazz, isPrint);    }    /**     * @param ctx channel上下文     * @param msg 消息     * @param out 输出集合     * @throws Exception     */    @Override    protected void decode(ChannelHandlerContext ctx, FullHttpRequest msg, List<Object> out) throws Exception {        if (!msg.decoderResult().isSuccess()) {            sendError(ctx, HttpResponseStatus.BAD_REQUEST);            return;        }        HttpJsonRequest request = new HttpJsonRequest(msg, decode0(ctx, msg.content()));        out.add(request);    }    /**     * 测试的话，直接封装，实战中需要更健壮的处理     */    private static void sendError(ChannelHandlerContext ctx,                                  HttpResponseStatus status) {        FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1,                status, Unpooled.copiedBuffer("Failure: " + status.toString()                + "\r\n", CharsetUtil.UTF_8));        response.headers().set(CONTENT_TYPE, "text/plain; charset=UTF-8");        ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);    }}

/** * Created by carl.yu on 2016/12/16. */public class HttpJsonResponseEncoder extends AbstractHttpJsonEncoder<HttpJsonResponse> {    @Override    protected void encode(ChannelHandlerContext ctx, HttpJsonResponse msg, List<Object> out) throws Exception {        //编码        ByteBuf body = encode0(ctx, msg.getResult());        FullHttpResponse response = msg.getHttpResponse();        if (response == null) {            response = new DefaultFullHttpResponse(HTTP_1_1, OK, body);        } else {            response = new DefaultFullHttpResponse(msg.getHttpResponse()                    .protocolVersion(), msg.getHttpResponse().status(),                    body);        }        response.headers().set(CONTENT_TYPE, "text/json");        HttpUtil.setContentLength(response, body.readableBytes());        out.add(response);    }}

import io.netty.buffer.ByteBuf;import io.netty.channel.ChannelHandlerContext;import io.netty.handler.codec.http.*;import java.net.InetAddress;import java.util.List;/** * Created by carl.yu on 2016/12/16. */public class HttpJsonRequestEncoder extends AbstractHttpJsonEncoder<HttpJsonRequest> {    @Override    protected void encode(ChannelHandlerContext ctx, HttpJsonRequest msg, List<Object> out) throws Exception {        //(1)调用父类的encode0，将业务需要发送的对象转换为Json        ByteBuf body = encode0(ctx, msg.getBody());        //(2) 如果业务自定义了HTTP消息头，则使用业务的消息头，否则在这里构造HTTP消息头        // 这里使用硬编码的方式来写消息头，实际中可以写入配置文件        FullHttpRequest request = msg.getRequest();        if (request == null) {            request = new DefaultFullHttpRequest(HttpVersion.HTTP_1_1,                    HttpMethod.GET, "/do", body);            HttpHeaders headers = request.headers();            headers.set(HttpHeaderNames.HOST, InetAddress.getLocalHost()                    .getHostAddress());            headers.set(HttpHeaderNames.CONNECTION, HttpHeaders.Values.CLOSE);            headers.set(HttpHeaderNames.ACCEPT_ENCODING,                    HttpHeaderValues.GZIP.toString() + ‘,‘                            + HttpHeaderValues.DEFLATE.toString());            headers.set(HttpHeaderNames.ACCEPT_CHARSET,                    "ISO-8859-1,utf-8;q=0.7,*;q=0.7");            headers.set(HttpHeaderNames.ACCEPT_LANGUAGE, "zh");            headers.set(HttpHeaderNames.USER_AGENT,                    "Netty json Http Client side");            headers.set(HttpHeaderNames.ACCEPT,                    "text/html,application/json;q=0.9,*/*;q=0.8");        }        HttpUtil.setContentLength(request, body.readableBytes());        // (3) 编码后的对象        out.add(request);    }}

import io.netty.channel.ChannelHandlerContext;import io.netty.handler.codec.http.FullHttpResponse;import java.util.List;/** * Created by carl.yu on 2016/12/16. */public class HttpJsonResponseDecoder extends AbstractHttpJsonDecoder<FullHttpResponse> {    public HttpJsonResponseDecoder(Class<?> clazz) {        this(clazz, false);    }    /**     * 构造器     *     * @param clazz   解码的对象信息     * @param isPrint 是否需要打印     */    public HttpJsonResponseDecoder(Class<?> clazz, boolean isPrint) {        super(clazz, isPrint);    }    /**     * @param ctx channel上下文     * @param msg 消息     * @param out 输出集合     * @throws Exception     */    @Override    protected void decode(ChannelHandlerContext ctx, FullHttpResponse msg, List<Object> out) throws Exception {        System.out.println("开始解码...");        out.add(                new HttpJsonResponse(msg, decode0(ctx, msg.content()))        );    }}

import demo.protocol.http.json.codec.HttpJsonRequestDecoder;import demo.protocol.http.json.codec.HttpJsonResponseEncoder;import demo.protocol.http.json.pojo.Order;import io.netty.bootstrap.ServerBootstrap;import io.netty.channel.ChannelFuture;import io.netty.channel.ChannelInitializer;import io.netty.channel.EventLoopGroup;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.SocketChannel;import io.netty.channel.socket.nio.NioServerSocketChannel;import io.netty.handler.codec.http.HttpObjectAggregator;import io.netty.handler.codec.http.HttpRequestDecoder;import io.netty.handler.codec.http.HttpResponseEncoder;import java.net.InetSocketAddress;/** * Created by carl.yu on 2016/12/16. */public class HttpJsonServer {    public void run(final int port) throws Exception {        EventLoopGroup bossGroup = new NioEventLoopGroup();        EventLoopGroup workerGroup = new NioEventLoopGroup();        try {            ServerBootstrap b = new ServerBootstrap();            b.group(bossGroup, workerGroup)                    .channel(NioServerSocketChannel.class)                    .childHandler(new ChannelInitializer<SocketChannel>() {                        @Override                        protected void initChannel(SocketChannel ch)                                throws Exception {                            //接收HttpJsonRequest，需要对应解码器                            //ByteBuf->FullHttpRequest-> HttpJsonRequestDecoder                            //输出HttpJsonResponse，需要对应编码器                            //HttpResponseEncoder->FullHttpResponse-> HttpJsonResponseEncoder                            ch.pipeline().addLast("http-decoder", new HttpRequestDecoder());                            ch.pipeline().addLast("http-aggregator", new HttpObjectAggregator(65536));                            ch.pipeline().addLast("json-decoder", new HttpJsonRequestDecoder(Order.class, true));                            ch.pipeline().addLast("http-encoder", new HttpResponseEncoder());                            ch.pipeline().addLast("json-encoder", new HttpJsonResponseEncoder());                            ch.pipeline().addLast("jsonServerHandler", new HttpJsonServerHandler());                        }                    });            ChannelFuture future = b.bind(new InetSocketAddress(port)).sync();            System.out.println("HTTP订购服务器启动，网址是 : " + "http://localhost:"                    + port);            future.channel().closeFuture().sync();        } finally {            bossGroup.shutdownGracefully();            workerGroup.shutdownGracefully();        }    }    public static void main(String[] args) throws Exception {        int port = 8080;        if (args.length > 0) {            try {                port = Integer.parseInt(args[0]);            } catch (NumberFormatException e) {                e.printStackTrace();            }        }        new HttpJsonServer().run(port);    }}

import demo.protocol.http.json.codec.HttpJsonRequest;import demo.protocol.http.json.codec.HttpJsonResponse;import demo.protocol.http.json.pojo.Address;import demo.protocol.http.json.pojo.Order;import io.netty.buffer.Unpooled;import io.netty.channel.ChannelFuture;import io.netty.channel.ChannelFutureListener;import io.netty.channel.ChannelHandlerContext;import io.netty.channel.SimpleChannelInboundHandler;import io.netty.handler.codec.http.*;import io.netty.util.CharsetUtil;import io.netty.util.concurrent.Future;import io.netty.util.concurrent.GenericFutureListener;import java.util.ArrayList;import java.util.List;import static io.netty.handler.codec.http.HttpHeaders.Names.CONTENT_TYPE;import static io.netty.handler.codec.http.HttpResponseStatus.INTERNAL_SERVER_ERROR;import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;/** * Created by carl.yu on 2016/12/16. */public class HttpJsonServerHandler extends SimpleChannelInboundHandler<HttpJsonRequest> {    @Override    protected void channelRead0(ChannelHandlerContext ctx, HttpJsonRequest msg) throws Exception {        HttpRequest request = msg.getRequest();        Order order = (Order) msg.getBody();        System.out.println("Http server receive request : " + order);        dobusiness(order);        ChannelFuture future = ctx.writeAndFlush(new HttpJsonResponse(null, order));        if (!HttpUtil.isKeepAlive(request)) {            future.addListener(new GenericFutureListener<Future<? super Void>>() {                public void operationComplete(Future future) throws Exception {                    ctx.close();                }            });        }    }    private void dobusiness(Order order) {        order.getCustomer().setFirstName("狄");        order.getCustomer().setLastName("仁杰");        List<String> midNames = new ArrayList<String>();        midNames.add("李元芳");        order.getCustomer().setMiddleNames(midNames);        Address address = order.getBillTo();        address.setCity("洛阳");        address.setCountry("大唐");        address.setState("河南道");        address.setPostCode("123456");        order.setBillTo(address);        order.setShipTo(address);    }    @Override    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)            throws Exception {        cause.printStackTrace();        if (ctx.channel().isActive()) {            sendError(ctx, INTERNAL_SERVER_ERROR);        }    }    private static void sendError(ChannelHandlerContext ctx,                                  HttpResponseStatus status) {        FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1,                status, Unpooled.copiedBuffer("失败: " + status.toString()                + "\r\n", CharsetUtil.UTF_8));        response.headers().set(CONTENT_TYPE, "text/plain; charset=UTF-8");        ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);    }}

import demo.protocol.http.json.codec.HttpJsonRequestEncoder;import demo.protocol.http.json.codec.HttpJsonResponseDecoder;import demo.protocol.http.json.pojo.Order;import io.netty.bootstrap.Bootstrap;import io.netty.channel.ChannelFuture;import io.netty.channel.ChannelInitializer;import io.netty.channel.ChannelOption;import io.netty.channel.EventLoopGroup;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.SocketChannel;import io.netty.channel.socket.nio.NioSocketChannel;import io.netty.handler.codec.http.HttpObjectAggregator;import io.netty.handler.codec.http.HttpRequestEncoder;import io.netty.handler.codec.http.HttpResponseDecoder;import java.net.InetSocketAddress;/** * Created by carl.yu on 2016/12/16. */public class HttpJsonClient {    public void connect(int port) throws Exception {        // 配置客户端NIO线程组        EventLoopGroup group = new NioEventLoopGroup();        try {            Bootstrap b = new Bootstrap();            b.group(group).channel(NioSocketChannel.class)                    .option(ChannelOption.TCP_NODELAY, true)                    .handler(new ChannelInitializer<SocketChannel>() {                        @Override                        public void initChannel(SocketChannel ch)                                throws Exception {                            ch.pipeline().addLast("http-decoder",                                    new HttpResponseDecoder());                            ch.pipeline().addLast("http-aggregator",                                    new HttpObjectAggregator(65536));                            // json解码器                            ch.pipeline().addLast("json-decoder", new HttpJsonResponseDecoder(Order.class, true));                            ch.pipeline().addLast("http-encoder",                                    new HttpRequestEncoder());                            ch.pipeline().addLast("json-encoder",                                    new HttpJsonRequestEncoder());                            ch.pipeline().addLast("jsonClientHandler",                                    new HttpJsonClientHandler());                        }                    });            // 发起异步连接操作            ChannelFuture f = b.connect(new InetSocketAddress(port)).sync();            // 当代客户端链路关闭            f.channel().closeFuture().sync();        } finally {            // 优雅退出，释放NIO线程组            group.shutdownGracefully();        }    }    /**     * @param args     * @throws Exception     */    public static void main(String[] args) throws Exception {        int port = 8080;        if (args != null && args.length > 0) {            try {                port = Integer.valueOf(args[0]);            } catch (NumberFormatException e) {                // 采用默认值            }        }        new HttpJsonClient().connect(port);    }}

import demo.protocol.http.json.codec.HttpJsonRequest;import demo.protocol.http.json.pojo.OrderFactory;import io.netty.channel.ChannelHandlerContext;import io.netty.channel.ChannelInboundHandlerAdapter;/** * Created by carl.yu on 2016/12/16. */public class HttpJsonClientHandler extends ChannelInboundHandlerAdapter {    @Override    public void channelActive(ChannelHandlerContext ctx) throws Exception {        System.out.println("连接上服务器...");        HttpJsonRequest request = new HttpJsonRequest(null, OrderFactory.create(123));        ctx.writeAndFlush(request);    }    @Override    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {        System.out.println(msg.getClass().getName());        System.out.println("接收到了数据..." + msg);    }    /*@Override    protected void channelRead0(ChannelHandlerContext ctx, HttpJsonResponse msg) throws Exception {        System.out.println("The client receive response of http header is : "                + msg.getHttpResponse().headers().names());        System.out.println("The client receive response of http body is : "                + msg.getResult());    }*/    @Override    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {        cause.printStackTrace();        ctx.close();    }}