Netty4之如何實(shí)現(xiàn)HTTP請(qǐng)求、響應(yīng)

更新時(shí)間：2023年04月04日 09:51:41 作者：恐龍弟旺仔

這篇文章主要介紹了Netty4之如何實(shí)現(xiàn)HTTP請(qǐng)求、響應(yīng)問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

前言

我們所編寫的項(xiàng)目多以BS為主，用戶通過(guò)瀏覽器訪問(wèn)我們的服務(wù)器

發(fā)送的請(qǐng)求以HTTP請(qǐng)求為主，本例就以Netty4來(lái)實(shí)現(xiàn)一個(gè)接收HTTP請(qǐng)求的服務(wù)器，并根據(jù)用戶請(qǐng)求返回響應(yīng)

1.Netty中HTTP請(qǐng)求和響應(yīng)類

請(qǐng)求（FullHttpRequest）

/**
 * Combine the {@link HttpRequest} and {@link FullHttpMessage}, so the request is a <i>complete</i> HTTP
 * request.
 */
public interface FullHttpRequest extends HttpRequest, FullHttpMessage {

可以看到，它結(jié)合了HttpRequest、FullHttpMessag，作為一個(gè)完整的HTTP請(qǐng)求體。

默認(rèn)實(shí)現(xiàn)為DefaultFullHttpRequest

響應(yīng)（FullHttpResponse）

/**
 * Combination of a {@link HttpResponse} and {@link FullHttpMessage}.
 * So it represent a <i>complete</i> http response.
 */
public interface FullHttpResponse extends HttpResponse, FullHttpMessage {

同樣，它結(jié)合了HttpResponse、FullHttpMessage

默認(rèn)實(shí)現(xiàn)為DefaultFullHttpResponse

*

2.Netty中客戶端、服務(wù)端的編解碼器

作為服務(wù)端而言：

主要工作就是接收客戶端請(qǐng)求，將客戶端的請(qǐng)求內(nèi)容解碼；發(fā)送響應(yīng)給客戶端，并將發(fā)送內(nèi)容編碼

所以，服務(wù)端需要兩個(gè)編解碼器

* HttpRequestDecoder(將請(qǐng)求內(nèi)容解碼)

* HttpResponseEncoder(將響應(yīng)內(nèi)容編碼)

作為客戶端而言：

主要工作就是發(fā)送請(qǐng)求給服務(wù)端，并將發(fā)送內(nèi)容編碼；接收服務(wù)端響應(yīng)，并將接收內(nèi)容解碼；

所以，客戶端需要兩個(gè)編解碼器

* HttpResponseDecoder（將響應(yīng)內(nèi)容解碼）

* HttpRequestEncoder（將請(qǐng)求內(nèi)容編碼）

3.Server端編寫Handler類處理客戶請(qǐng)求

創(chuàng)建Handler，命名為HttpHandler，具體內(nèi)容如下：

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;

/**
 * 處理HTTP請(qǐng)求
 * @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.獲取請(qǐng)求體
				ByteBuf buf = req.content();
				String content = buf.toString(CharsetUtil.UTF_8);
				
				// 3.獲取請(qǐng)求方法
				HttpMethod method = req.method();
				
				// 4.獲取請(qǐng)求頭
				HttpHeaders headers = req.headers();
				
				// 5.根據(jù)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.設(shè)置響應(yīng)
		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.發(fā)送
		// 注意必須在使用完之后，close channel
		ctx.writeAndFlush(resp).addListener(ChannelFutureListener.CLOSE);
	}
}

@Data
class Content{
	String uri;
	String content;
}

注意：

在處理過(guò)程中，把msg轉(zhuǎn)換為FullHttpRequest，可以獲取關(guān)于請(qǐng)求的所有內(nèi)容；

在發(fā)送響應(yīng)時(shí)必須要監(jiān)聽CLOSE

*