写点什么

netty 系列之: 自建客户端和 HTTP 服务器交互

发布于: 5 小时前

简介上一篇文章,我们搭建了一个支持中文的 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/


最通俗的解读,最深刻的干货,最简洁的教程,众多你不知道的小技巧等你来发现!


欢迎关注我的公众号:「程序那些事」,懂技术,更懂你!

发布于: 5 小时前阅读数: 3
用户头像

关注公众号:程序那些事,更多精彩等着你! 2020.06.07 加入

最通俗的解读,最深刻的干货,最简洁的教程,众多你不知道的小技巧,尽在公众号:程序那些事!

评论

发布
暂无评论
netty系列之:自建客户端和HTTP服务器交互