java实现HTTP的POST协议的方法

红太狼 2024-03-26 19:13 70阅读 0赞

**使用代码实现HTTP的POST协议流程。**

任何[HTTP服务器][HTTP]都会支持客户端将文件上传，该功能的实现往往要走POST协议流程。为了使用代码实现该协议，首先需要一个目的HTTP服务器，我选择iPhone版本的福昕pdf阅读器，它支持通过POST协议将文件从电脑上传到手机，在打开其上传功能后，在电脑输入相应网址就能看到如下画面：点击”选择文件“按钮，然后选择要上传的文件，最后点击”upload”按钮，那么浏览器就会执行POST协议实现数据上传。我们先通过抓包的方式了解POST协议数据包的结构，在执行文件上传并抓包后，wireshark抓到的数据包如下：

在简单情况下，post流程只有两次数据包发送，一次是POST，它是客户端将数据通过HTTP数据包发送给服务器，另一个是服务器接收数据后将结果回复给客户端，我们看看POST数据包的内容：

POST数据包分为两部分，第一部分涉及HTTP协议控制，也就是上图中的第一部分，第一行通过POST关键字指明数据包目的，并通过包头字段的形式填写了一系列用于数据传输和控制的信息，这些包头在前面章节都有描述过。第二部分就是MIME Multipart Media Encapsulation部分，它用于封装上传数据，这部分需要详细解读。第一个需要了解的是Boundary,这个字符串由客户端自己生成，它的作用是将上传数据分隔开，每次遇到该字符串开始的地方，服务器就知道那是客户端要提交的数据内容，我将其内容展开以便读者查看：

可以看到First Boundary处是给定的Boundary字符串，它下面对应要上传给服务器的第一部分信息，Content-Type用于指定数据的格式，从中可以看到我上传的是一个文本文件，接下来就是文本内容，如果文本是字符串，它则直接显示，如果内容是二进制数据，那么它包含的就是数据对应的数字内容，从上面可以看到，文本中只包含了一行内容，那就是”this is only one line”，这部分就对应要上传的数据内容。接着是第二部分要上传的内容，所以格式上再次以Boudary对应的字符串作为起始，关键字Content-Disposition用于说明数据的展现形式，数据内容应该是直接在网页中展示，还是作为附件呈现，在客户端以POST形式向服务器提交数据时，它的取值只能是form->第二部分数据没有通过字段Content-Type来指明，因此统一当做二进制数据，因此Data字段对应的就是一系列数字，实际上这些数字其实对应的是字符串”Upload”，因此第二部分数据用来告诉服务器，当前数据是通过点击了”Upload”按钮后上传的，笔者在模拟该数据包时，如果不包含这部分数据，手机上的福昕pdf应用会奔溃掉。接下来我们看看如何使用代码实现简单的POST功能，首先要实现的是MIME这部分数据的封装:

package Application;import java.util.Arrays;public class MIMETextPlainMediaEcnapusulation \{ //该类只封装简单的文本数据 private String boundary\_string = "----WebFormBoundaryAAABBBCCCDDD"; //用于传递数据的分割标志字符串 private String post\_file\_name = ""; private String content\_part\_header = "Content-Disposition: form-data; name=\\"button\\"; filename=\\""; private String content\_type = "Content-Type: text/plain\\r\\n\\r\\n"; private String content\_part = ""; private String last\_boundary = "\\r\\n--" + boundary\_string + "--\\r\\n"; public MIMETextPlainMediaEcnapusulation(String file\_name) \{ this.post\_file\_name = file\_name; //要上传的文件名 \} private void add\_content\_header() \{ //添加用于分割不同数据部分的boundary this.content\_part += "--"; this.content\_part += boundary\_string; this.content\_part += "\\r\\n"; this.content\_part += content\_part\_header; this.content\_part += post\_file\_name; this.content\_part += "\\r\\n"; this.content\_part += content\_type; \} public void add\_content(String content) \{ //调用该接口设置要上传给服务器的内容 this.add\_content\_header(); this.content\_part += content; this.content\_part += "\\r\\n"; this.content\_part += "--"; this.content\_part += boundary\_string; this.content\_part += "\\r\\n"; \} private void add\_last\_content\_part() \{ //模拟最后upload数据部分，这部分与数据传输无关，但与服务器对接收数据的解读有关 String last\_content\_disposition = "Content-Disposition: form-data; name=\\"button\\"\\r\\n\\r\\n"; content\_part += last\_content\_disposition; String content = "Upload\\r\\n"; content\_part += content; content\_part += last\_boundary; \} public String get\_mime\_part() \{ this.add\_last\_content\_part(); return content\_part; \} public String get\_boundary\_string() \{ return boundary\_string; \}\}

接下来实现的是数据的传输功能：

package Application;import [java.net][].InetAddress;import utils.ITCPHandler;public class HTTPPostClient implements ITCPHandler \{ private TCPThreeHandShakes tcp\_socket = null; private HTTPEncoder httpEncoder = new HTTPEncoder(); private String user\_agent = "Mozilla/5.0 (Macintosh; Intel Mac OS X 1-14\_0) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/81.0.4044.122 Safari/547.36"; private String accept = "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,\*/\*;q=0.8,application/signed-exchange;v=b3q=0.9"; private String accept\_encoding = "gzip, deflate"; private String accept\_language = "zh-CN,zh;q=0.9,en;q=0.8"; private String cache\_control = "max-age=0"; private String connection = "close"; private static int HTTP\_OK = 200; private String file\_name = "my\_test.txt"; private String content\_type = "multipart/form-data; boundary="; private MIMETextPlainMediaEcnapusulation mime\_encoded = new MIMETextPlainMediaEcnapusulation(file\_name); private void send\_content() throws Exception \{//设置http请求数据的头部信息 mime\_encoded.add\_content("This is test content for line1"); //文档里面的内容 String send\_content = mime\_encoded.get\_mime\_part(); String content\_length = Integer.toString(send\_content.length()); httpEncoder.set\_method(HTTPEncoder.HTTP\_METHOD.HTTP\_POST, "/"); httpEncoder.set\_header("Host","192.168.2.127:8888"); httpEncoder.set\_header("Connection", connection); httpEncoder.set\_header("User-Agent", user\_agent); httpEncoder.set\_header("Content-Length", content\_length); httpEncoder.set\_header("Accept", accept); httpEncoder.set\_header("Accept-Encoding", accept\_encoding); httpEncoder.set\_header("Accept-Language", accept\_language); httpEncoder.set\_header("Cache-Control", cache\_control); httpEncoder.set\_header("Content-type", content\_type + mime\_encoded.get\_boundary\_string()); httpEncoder.set\_header("Upgrade-Insecure-Requests", "1"); httpEncoder.set\_header("Origin", "[http://192.168.2.127:8888][http_192.168.2.127_8888]"); httpEncoder.set\_header("Referer", "[http://192.168.2.127:8888/");][http_192.168.2.127_8888 1] String http\_content = httpEncoder.get\_http\_content(); http\_content += send\_content; System.out.println(http\_content); byte\[\] send\_content\_bytes = http\_content.getBytes(); tcp\_socket.tcp\_send(send\_content\_bytes); \} @Override public void connect\_notify(boolean connect\_res) \{ if (connect\_res == true) \{ System.out.println("connect http server ok!"); try \{ send\_content(); \} catch (Exception e) \{ // TODO Auto-generated catch block e.printStackTrace(); \} \} else \{ System.out.println("connect http server fail!"); \} \} @Override public void send\_notify(boolean send\_res, byte\[\] packet\_send) \{ if (send\_res) \{ System.out.println("send request to http server!"); \} \} private void close\_connection() \{ try \{ tcp\_socket.tcp\_close(); \} catch (Exception e) \{ // TODO Auto-generated catch block e.printStackTrace(); \} \} @Override public void recv\_notify(byte\[\] packet\_recv) \{ String content = new String(packet\_recv); int code = httpEncoder.get\_return\_code(content); if (code != HTTP\_OK) \{ System.out.println("http return error: " + code); \} else \{ System.out.println("Http return 200 OK! Post Success!"); \} close\_connection(); \} @Override public void connect\_close\_notify(boolean close\_res) \{ if (close\_res) \{ System.out.println("Close connection with http server!"); \} \} public void run() \{ try \{ InetAddress ip = InetAddress.getByName("192.168.2.127"); //连接ftp服务器 short port = 8888; tcp\_socket = new TCPThreeHandShakes(ip.getAddress(), port, this); tcp\_socket.tcp\_connect(); \} catch (Exception e) \{ // TODO Auto-generated catch block e.printStackTrace(); \} \}\}

在代码中构造了一个虚拟的”my\_test.txt”文件上传给服务器，文件里面的内容就是代码设置的字符串”This is test content for line1”，执行上面代码[m.weidianyuedu.com][]后，就相当于前面展示的通过按钮上传给定文件的流程。

来源：[https://www.weidianyuedu.com][https_www.weidianyuedu.com]

[HTTP]: https://so.csdn.net/so/search?q=HTTP%E6%9C%8D%E5%8A%A1%E5%99%A8&spm=1001.2101.3001.7020
[java.net]: https://java.net
[http_192.168.2.127_8888]: http://192.168.2.127:8888
[http_192.168.2.127_8888 1]: http://192.168.2.127:8888/
[m.weidianyuedu.com]: https://m.weidianyuedu.com
[https_www.weidianyuedu.com]: https://www.weidianyuedu.com