前言
我们所编写的项目多以BS为主，用户通过浏览器访问我们的服务器
发送的请求以HTTP请求为主，本例就以Netty4来实现一个接收HTTP请求的服务器，并根据用户请求返回响应
1.Netty中HTTP请求和响应类
请求（FullHttpRequest）
public interface FullHttpRequest extends HttpRequest, FullHttpMessage {
可以看到，它结合了HttpRequest、FullHttpMessag，作为一个完整的HTTP请求体。
默认实现为DefaultFullHttpRequest
响应（FullHttpResponse）
public interface FullHttpResponse extends HttpResponse, FullHttpMessage {
同样，它结合了HttpResponse、FullHttpMessage
默认实现为DefaultFullHttpResponse
*
2.Netty中客户端、服务端的编解码器
作为服务端而言：
主要工作就是接收客户端请求，将客户端的请求内容解码；发送响应给客户端，并将发送内容编码
所以，服务端需要两个编解码器
* HttpRequestDecoder(将请求内容解码)
* HttpResponseEncoder(将响应内容编码)
作为客户端而言：
主要工作就是发送请求给服务端，并将发送内容编码；接收服务端响应，并将接收内容解码；
所以，客户端需要两个编解码器
* HttpResponseDecoder（将响应内容解码）
* HttpRequestEncoder（将请求内容编码）
3.Server端编写Handler类处理客户请求
创建Handler，命名为HttpHandler，具体内容如下：
import com.alibaba.fastjson.JSONObject;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
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.HttpHeaderNames;
import io.netty.handler.codec.http.HttpHeaders;
import io.netty.handler.codec.http.HttpMethod;
import io.netty.handler.codec.http.HttpResponseStatus;
import io.netty.handler.codec.http.HttpVersion;
import io.netty.util.CharsetUtil;
import lombok.Data;
public class HttpHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
if(msg instanceof FullHttpRequest){
FullHttpRequest req = (FullHttpRequest)msg;
try {
// 1.获取URI
String uri = req.uri();
// 2.获取请求体
ByteBuf buf = req.content();
String content = buf.toString(CharsetUtil.UTF_8);
// 3.获取请求方法
HttpMethod method = req.method();
// 4.获取请求头
HttpHeaders headers = req.headers();
// 5.根据method，确定不同的逻辑
if(method.equals(HttpMethod.GET)){
// TODO
}
if(method.equals(HttpMethod.POST)){
// 接收用户输入，并将输入返回给用户
Content c = new Content();
c.setUri(uri);
c.setContent(content);
response(ctx, c);
}
if(method.equals(HttpMethod.PUT)){
// TODO
}
if(method.equals(HttpMethod.DELETE)){
// TODO
}
} finally {
req.release();
}
}
}
private void response(ChannelHandlerContext ctx, Content c) {
// 1.设置响应
FullHttpResponse resp = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,
HttpResponseStatus.OK,
Unpooled.copiedBuffer(JSONObject.toJSONString(c), CharsetUtil.UTF_8));
resp.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/html; charset=UTF-8");
// 2.发送
// 注意必须在使用完之后，close channel
ctx.writeAndFlush(resp).addListener(ChannelFutureListener.CLOSE);
}
}
@Data
class Content{
String uri;
String content;
}
注意：
在处理过程中，把msg转换为FullHttpRequest，可以获取关于请求的所有内容；
在发送响应时必须要监听CLOSE
*
4.测试
启动Server类使用客户端发送请求
在这里，笔者不单独编写Netty客户端代码，直接使用PostMan来充当客户端发送请求，具体如下：
发送一个post请求，并填写body，点击send，可以看到响应如下所示：
参考：Netty in Action
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持编程网。
