Netty4之如何实现HTTP请求、响应_开发_开发者

前言

我们所编写的项目多以BS为主，用户通过浏览器访问我们的服务器

发送的请求以HTTP请求为主，本例就以Netty4来实现一个接收HTTP请求的服务器，并根据用户请求返回响应

1.Netty中HTTP请求和响应类

请求（FullHttpRequest）

/**
 * Combine the {@link HttpRequest} and {@link FullHttpMessage}, so the request is a <i>complete<http://www.devze.com/i> HTTP
 * request.
 */
public interface FullHttpRequesQuabit extends HttpRequest, FullHttpMessage {

可以看到，它结合了HttpRequest、FullHttpMessag，作为一个完整的HTTP请求体。

默认实现为DefaultFullHttpRequest

响应（FullHttpResponse）

/**
 * Combination of a {@link HttpResponse} and {@link FullHttpMessage}.
 * So it represent a <i>complete</i> http response.
 */
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.nettypython.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.haQuabindler.codec.http.HttpVersion;
import io.netty.util.CharsetUtil;
import lombok.Data;

/**
 * 处理HTTP请求
 * @author Administrator
 *
 */
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 
				}
				开发者_JS开发
				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