简介

上一篇的文章中，咱们讲到了如何从HTTP服务器中下载文件，和搭建下载文件服务器应该留神的问题，应用的GET办法。本文将会讨论一下罕用的向服务器提交数据的POST办法和如何向服务器上传文件。

GET办法上传数据

依照HTTP的标准，PUT个别是向服务器上传数据，尽管不提倡，然而也能够应用GET向服务器端上传数据。

先看下GET客户端的构建中须要留神的问题。

GET申请实际上就是一个URI，URI前面带有申请的参数，netty提供了一个QueryStringEncoder专门用来构建参数内容：

// HTTP申请        QueryStringEncoder encoder = new QueryStringEncoder(get);        // 增加申请参数        encoder.addParam("method", "GET");        encoder.addParam("name", "flydean");        encoder.addParam("site", "www.flydean.com");        URI uriGet = new URI(encoder.toString());

有了申请URI，就能够创立HttpRequest了，当然这个HttpRequest中还须要有对应的HTTP head数据：

HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, uriGet.toASCIIString());        HttpHeaders headers = request.headers();        headers.set(HttpHeaderNames.HOST, host);        headers.set(HttpHeaderNames.CONNECTION, HttpHeaderValues.CLOSE);        headers.set(HttpHeaderNames.ACCEPT_ENCODING, HttpHeaderValues.GZIP + "," + HttpHeaderValues.DEFLATE);        headers.set(HttpHeaderNames.ACCEPT_LANGUAGE, "zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2");        headers.set(HttpHeaderNames.REFERER, uriSimple.toString());        headers.set(HttpHeaderNames.USER_AGENT, "Netty Simple Http Client side");        headers.set(HttpHeaderNames.ACCEPT, "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8");        headers.set(                HttpHeaderNames.COOKIE, ClientCookieEncoder.STRICT.encode(                        new DefaultCookie("name", "flydean"),                        new DefaultCookie("site", "www.flydean.com"))        );

咱们晓得HttpRequest中只有两局部数据，别离是HttpVersion和HttpHeaders。HttpVersion就是HTTP协定的版本号，HttpHeaders就是设置的header内容。

对于GET申请来说，因为所有的内容都蕴含在URI中，所以不须要额定的HTTPContent，间接发送HttpRequest到服务器就能够了。

channel.writeAndFlush(request);

而后看下服务器端接管GET申请之后怎么进行解决。

服务器端收到HttpObject对象的msg之后，须要将其转换成HttpRequest对象，就能够通过protocolVersion(),uri()和headers()拿到相应的信息。

对于URI中的参数，netty提供了QueryStringDecoder类能够不便的对URI中参数进行解析：

//解析URL中的参数            QueryStringDecoder decoderQuery = new QueryStringDecoder(request.uri());            Map<String, List<String>> uriAttributes = decoderQuery.parameters();            for (Entry<String, List<String>> attr: uriAttributes.entrySet()) {                for (String attrVal: attr.getValue()) {                    responseContent.append("URI: ").append(attr.getKey()).append('=').append(attrVal).append("\r\n");                }            }

POST办法上传数据

对于POST申请，它比GET申请多了一个HTTPContent，也就是说除了根本的HttpRequest数据之外，还须要一个PostBody。

如果只是一个一般的POST，也就是POST内容都是key=value的模式，则比较简单，如果POST中蕴含有文件，那么会比较复杂，须要用到ENCTYPE="multipart/form-data"。

netty提供了一个HttpPostRequestEncoder类，用于疾速对request body进行编码，先看下HttpPostRequestEncoder类的残缺构造函数：

public HttpPostRequestEncoder(            HttpDataFactory factory, HttpRequest request, boolean multipart, Charset charset,            EncoderMode encoderMode)

其中request就是要编码的HttpRequest，multipart示意是否是"multipart/form-data"的格局，charset编码方式，默认状况下是CharsetUtil.UTF_8。encoderMode是编码的模式，目前有三种编码模式，别离是RFC1738，RFC3986和HTML5。

默认状况下的编码模式是RFC1738，这也是大多数form提交数据的编码方式。然而它并不适用于OAUTH，如果要应用OAUTH的话，则能够应用RFC3986。HTML5禁用了multipart/form-data的混合模式。

最初，咱们讲讲HttpDataFactory。factory次要用来创立InterfaceHttpData。它有一个minSize参数，如果创立的HttpData大小大于minSize则会寄存在磁盘中，否则间接在内存中创立。

InterfaceHttpData有三种HttpData的类型，别离是Attribute, FileUpload和InternalAttribute。

Attribute就是POST申请中传入的属性值。FileUpload就是POST申请中传入的文件，还有InternalAttribute是在encoder外部应用的，这里不过多探讨。

因而，依据传入的minSize参数大小，Attribute和FileUpload能够被分成上面几种：

MemoryAttribute, DiskAttribute or MixedAttribute
MemoryFileUpload, DiskFileUpload or MixedFileUpload

在这一节咱们先看一下在POST申请中并不上传文件的解决形式，首先创立HTTP request和PostBody encoder：

// 构建HTTP request        HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST, uriSimple.toASCIIString()); HttpPostRequestEncoder bodyRequestEncoder =                new HttpPostRequestEncoder(factory, request, false);

向request中增加headers：

// 增加headers        for (Entry<String, String> entry : headers) {            request.headers().set(entry.getKey(), entry.getValue());        }

而后再向bodyRequestEncoder中增加form属性：

// 增加form属性        bodyRequestEncoder.addBodyAttribute("method", "POST");        bodyRequestEncoder.addBodyAttribute("name", "flydean");        bodyRequestEncoder.addBodyAttribute("site", "www.flydean.com");        bodyRequestEncoder.addBodyFileUpload("myfile", file, "application/x-zip-compressed", false);

留神，下面咱们向bodyRequestEncoder中增加了method,name和site这几个属性。而后增加了一个FileUpload。然而因为咱们的编码方式并不是"multipart/form-data"，所以这里传递的只是文件名，并不是整个文件。

最初，咱们要调用bodyRequestEncoder的finalizeRequest办法，返回最终要发送的request。在finalizeRequest的过程中，还会依据传输数据的大小来设置transfer-encoding是否为chunked。

如果传输的内容比拟大，则须要分段进行传输，这时候须要设置transfer-encoding = chunked，否则不进行设置。

最初发送申请：

// 发送申请        channel.write(request);

在server端，咱们同样须要结构一个HttpDataFactory，而后应用这个factory来结构一个HttpPostRequestDecoder，来对encoder进去的数据进行decode：

HttpDataFactory factory =            new DefaultHttpDataFactory(DefaultHttpDataFactory.MINSIZE);//POST申请decoder = new HttpPostRequestDecoder(factory, request);

因为server端收到的音讯依据发送音讯的长度能够能是HttpContent，也可能是LastHttpContent。如果是HttpContent，咱们将解析的后果放到一个StringBuilder中缓存起来，等接管到LastHttpContent再一起发送进来即可。

在收到HttpContent之后，咱们调用decoder.offer办法，对HttpContent进行解码：

decoder.offer(chunk);

在decoder外部有两个存储HttpData数据的容器，别离是：

List<InterfaceHttpData> bodyListHttpData和Map<String, List<InterfaceHttpData>> bodyMapHttpData

decoder.offer就是对chunk进行解析，而后将解析过后的数据填充到bodyListHttpData和bodyMapHttpData中。

解析过后，就能够对解析过后的数据进行读取了。

能够通过decoder的hasNext和next办法对bodyListHttpData进行遍历，从而获取到对应的InterfaceHttpData。

通过data.getHttpDataType()能够拿到InterfaceHttpData的数据类型，下面也讲过了有Attribute和FileUpload两种类型。

POST办法上传文件

如果要POST文件，客户端在创立HttpPostRequestEncoder的时候传入multipart=true即可：

 HttpPostRequestEncoder bodyRequestEncoder =                new HttpPostRequestEncoder(factory, request, true);

而后别离调用setBodyHttpDatas和finalizeRequest办法，生成HttpRequest就能够向channel写入了：

// 增加body http data        bodyRequestEncoder.setBodyHttpDatas(bodylist);        // finalize request，判断是否须要chunk        request = bodyRequestEncoder.finalizeRequest();        // 发送申请头        channel.write(request);

要留神，如果是transfer-encoding = chunked，那么这个HttpRequest只是申请头的信息，咱们还须要手动将HttpContent写入到channel中：

        // 判断bodyRequestEncoder是否是Chunked，发送申请内容        if (bodyRequestEncoder.isChunked()) {            channel.write(bodyRequestEncoder);        }

在server端，通过判断InterfaceHttpData的getHttpDataType，如果是FileUpload类型，则阐明拿到了上传的文件，则能够通过上面的办法来读取到文件的内容：

FileUpload fileUpload = (FileUpload) data;responseContent.append(fileUpload.getString(fileUpload.getCharset()));

这样咱们就能够在服务器端拿到客户端传过来的文件了。

总结

HTTP的文件上传须要思考的问题比拟多，大家有不明确的能够参考我的例子。或者留言给我一起探讨。

本文的例子能够参考：learn-netty4

本文已收录于 http://www.flydean.com/21-netty-http-fileupload/
最艰深的解读，最粗浅的干货，最简洁的教程，泛滥你不晓得的小技巧等你来发现！
欢送关注我的公众号:「程序那些事」,懂技术，更懂你！