簡介
上一篇文章，我們搭建了一個支持中文的HTTP服務器，並且能夠從瀏覽器訪問，並獲取到相應的結果。雖然瀏覽器在日常的應用中很普遍，但是有時候我們也有可能從自建的客戶端來調用HTTP服務器的服務。
今天給大家介紹如何自建一個HTTP客戶端來和HTTP服務器進行交互。
使用客戶端構建請求
在上一篇文章中，我們使用瀏覽器來訪問服務器，並得到到了響應的結果，那么如何在客戶端構建請求呢？
netty中的HTTP請求可以分成兩個部分，分別是HttpRequest和HttpContent。其中HttpRequest只包含了請求的版本號和消息頭的信息，HttpContent才包含了真正的請求內容信息。
但是如果要構建一個請求的話，需要同時包含HttpRequest和HttpContent的信息。netty提供了一個請求類叫做DefaultFullHttpRequest，這個類同時包含了兩部分的信息，可以直接使用。
使用DefaultFullHttpRequest的構造函數，我們就可以構造出一個HttpRequest請求如下：
HttpRequest request = new DefaultFullHttpRequest(
HttpVersion.HTTP_1_1, HttpMethod.GET, uri.getRawPath(), Unpooled.EMPTY_BUFFER);
上面的代碼中，我們使用的協議是HTTP1.1，方法是GET，請求的content是一個空的buffer。
構建好基本的request信息之后，我們可能還需要在header中添加一下額外的信息，比如connection，accept-encoding還有cookie的信息。
比如設置下面的信息：
request.headers().set(HttpHeaderNames.HOST, host);
request.headers().set(HttpHeaderNames.CONNECTION, HttpHeaderValues.CLOSE);
request.headers().set(HttpHeaderNames.ACCEPT_ENCODING, HttpHeaderValues.GZIP);
還有設置cookie：
request.headers().set(
HttpHeaderNames.COOKIE,
ClientCookieEncoder.STRICT.encode(
new DefaultCookie("name", "flydean"),
new DefaultCookie("site", "www.flydean.com")));
設置cookie我們使用的是ClientCookieEncoder.encode方法，ClientCookieEncoder有兩種encoder模式，一種是STRICT，一種是LAX。
在STRICT模式下，會對cookie的name和value進行校驗和排序。
和encoder對應的就是ClientCookieDecoder，用於對cookie進行解析。
設置好我們所有的request之后就可以寫入到channel中了。
accept-encoding
在客戶端寫入請求的時候，我們在請求頭上添加了accept-encoding，並將其值設置為GZIP，表示客戶端接收的編碼方式是GZIP。
如果服務器端發送了GZIP的編碼內容之后，客戶端怎么進行解析呢？我們需要對GZIP的編碼格式進行解碼。
netty提供了HttpContentDecompressor類，可以對gzip或者deflate格式的編碼進行解碼。在解碼之后，會同時修改響應頭中的“Content-Encoding”和“Content-Length”。
我們只需要將其添加到pipline中即可。
和它對應的類是HttpContentCompressor，用於對HttpMessage和HttpContent進行gzip或者deflate編碼。
所以說HttpContentDecompressor應該被添加到client的pipline中，而HttpContentCompressor應該被添加到server端的pipline中。
server解析HTTP請求
server需要一個handler來解析客戶端請求過來的消息。對於服務器來說，解析客戶端的請求應該注意哪些問題呢？
首先要注意的是客戶端100 Continue請求的問題。
在HTTP中有一個獨特的功能叫做，100 (Continue) Status，就是說client在不確定server端是否會接收請求的時候，可以先發送一個請求頭，並在這個頭上加一個"100-continue"字段，但是暫時還不發送請求body。直到接收到服務器端的響應之后再發送請求body。
如果服務器收到100Continue請求的話，直接返回確認即可：
if (HttpUtil.is100ContinueExpected(request)) {
send100Continue(ctx);
}
private static void send100Continue(ChannelHandlerContext ctx) {
FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1, CONTINUE, Unpooled.EMPTY_BUFFER);
ctx.write(response);
}
如果不是100請求的話，server端就可以准備要返回的內容了：
這里用一個StringBuilder來存儲要返回的內容：
StringBuilder buf = new StringBuilder();
為什么要用StringBuf呢？是因為有可能server端一次並不能完全接受客戶端的請求，所以將所有的要返回的內容都放到buffer中，等全部接受之后再一起返回。
我們可以向server端添加歡迎信息，可以可以添加從客戶端獲取的各種信息：
buf.setLength(0);
buf.append("歡迎來到www.flydean.com\r\n");
buf.append("===================================\r\n");
buf.append("VERSION: ").append(request.protocolVersion()).append("\r\n");
buf.append("HOSTNAME: ").append(request.headers().get(HttpHeaderNames.HOST, "unknown")).append("\r\n");
buf.append("REQUEST_URI: ").append(request.uri()).append("\r\n\r\n");
還可以向buffer中添加請求頭信息：
HttpHeaders headers = request.headers();
if (!headers.isEmpty()) {
for (Entry<String, String> h: headers) {
CharSequence key = h.getKey();
CharSequence value = h.getValue();
buf.append("HEADER: ").append(key).append(" = ").append(value).append("\r\n");
}
buf.append("\r\n");
}
可以向buffer中添加請求參數信息：
QueryStringDecoder queryStringDecoder = new QueryStringDecoder(request.uri());
Map<String, List<String>> params = queryStringDecoder.parameters();
if (!params.isEmpty()) {
for (Entry<String, List<String>> p: params.entrySet()) {
String key = p.getKey();
List<String> vals = p.getValue();
for (String val : vals) {
buf.append("PARAM: ").append(key).append(" = ").append(val).append("\r\n");
}
}
buf.append("\r\n");
}
要注意的是當讀取到HttpContent的時候的處理方式。如果讀取的消息是HttpContent，那么將content的內容添加到buffer中：
if (msg instanceof HttpContent) {
HttpContent httpContent = (HttpContent) msg;
ByteBuf content = httpContent.content();
if (content.isReadable()) {
buf.append("CONTENT: ");
buf.append(content.toString(CharsetUtil.UTF_8));
buf.append("\r\n");
appendDecoderResult(buf, request);
}
那么怎么判斷一個請求是否結束了呢？netty提供了一個類叫做LastHttpContent，這個類表示的是消息的最后一部分，當收到這一部分消息之后，我們就可以判斷一個HTTP請求已經完成了，可以正式的返回消息了：
if (msg instanceof LastHttpContent) {
log.info("LastHttpContent:{}",msg);
buf.append("END OF CONTENT\r\n");
要寫回channel，同樣需要構建一個DefaultFullHttpResponse，這里使用buffer來進行構建：
FullHttpResponse response = new DefaultFullHttpResponse(
HTTP_1_1, currentObj.decoderResult().isSuccess()? OK : BAD_REQUEST,
Unpooled.copiedBuffer(buf.toString(), CharsetUtil.UTF_8));
然后添加一些必須的header信息就可以調用ctx.write進行回寫了。
總結
本文介紹了如何在client構建HTTP請求，並詳細講解了HTTP server對HTTP請求的解析流程。
本文的例子可以參考：learn-netty4
本文已收錄於 http://www.flydean.com/19-netty-http-client-request-2/
最通俗的解讀，最深刻的干貨，最簡潔的教程，眾多你不知道的小技巧等你來發現！
歡迎關注我的公眾號:「程序那些事」,懂技術，更懂你！