Vert.x 文件上传Client-白红宇

1. pom.xml


                
     
      io.vertx
                 
     
      vertx-core
                 
     
      3.4.2
             
            
                
     
      io.vertx
                 
     
      vertx-web-client
                 
     
      3.4.2
             
    复制代码

2. Client1.java

import com.xiaoniu.db.Runner;import io.vertx.core.AbstractVerticle;import io.vertx.core.Future;import io.vertx.core.buffer.Buffer;import io.vertx.core.file.FileSystem;import io.vertx.core.json.JsonObject;import io.vertx.ext.web.client.HttpRequest;import io.vertx.ext.web.client.WebClient;import io.vertx.ext.web.client.WebClientOptions;import java.net.URLEncoder;import java.util.UUID;/** * 文件上传 Java 客户端 */public class Client1 extends AbstractVerticle {  // Convenience method so you can run it in your IDE  public static void main(String[] args) {    Runner.runExample(Client1.class);  }  @Override  public void start() throws Exception {    // 只需要修改下面五个参数即可    final String path = "C:\\Users\\sweet\\Desktop\\png\\Java图标 - 副本.png";    final String fileName = "Java图标副本.png";    final String reqURI = "/api/fileUpload?name="+ URLEncoder.encode(fileName, "UTF-8");    final String host = "127.0.0.1";    final Integer port = 7777;    // -------------------------    FileSystem fs = vertx.fileSystem();    String uuid = UUID.randomUUID().toString();    WebClient webClient = WebClient.create(vertx, new WebClientOptions().setMaxPoolSize(2));    Buffer buffer = Buffer.buffer();    buffer.appendString("--"+uuid+"\n");    String h = "Content-Disposition: form-data; name=\"file\"; filename=\""+fileName+"\"\r\nContent-Type: application/octet-stream\r\nContent-Transfer-Encoding: binary\r\n\r\n";    buffer.appendString(h);    Future
    
      future = Future.future();    fs.readFile(path, future);    future.setHandler(buffer1 -> {      if (buffer1.succeeded()) {        buffer.appendBuffer(buffer1.result());        buffer.appendString("\r\n--"+ uuid +"--\r\n");        HttpRequest
     
       req = webClient.post(port, host, reqURI);        req.putHeader("Content-Length", "" + buffer.length());        req.putHeader("Content-Type", "multipart/form-data; boundary="+uuid);        req.sendBuffer(buffer, resp -> {          if (resp.succeeded()) {            System.out.println("resp : " + System.currentTimeMillis());            JsonObject jsonObject = resp.result().bodyAsJsonObject();            System.out.println(jsonObject.encodePrettily());          } else {            resp.cause().printStackTrace();          }        });      } else {        buffer1.cause().printStackTrace();      }    });  }}复制代码

3. Run Main方法

4. Runner.java

https://github.com/vert-x3/vertx-examples/blob/master/core-examples/src/main/java/io/vertx/example/util/Runner.java