c/c++语言开发共享使用RestTemplate 调用远程接口上传文件方式

目录

• resttemplate 调用远程接口上传文件
• resttemplate调用远程接口添加请求头

  import org.springframework.core.io.inputstreamresource;   import java.io.inputstream;   public class commoninputstreamresource extends inputstreamresource {      private long length;      private string filename;       public commoninputstreamresource(inputstream inputstream, long length, string filename) {          super(inputstream);          this.length = length;          this.filename = filename;      }         /**       * 覆写父类方法       * 如果不重写这个方法，并且文件有一定大小，那么服务端会出现异常       * {@code the multi-part request contained parameter data (excluding uploaded files) that exceeded}       */      @override      public string getfilename() {          return filename;      }         /**       * 覆写父类 contentlength 方法       * 因为 {@link org.springframework.core.io.abstractresource#contentlength()}方法会重新读取一遍文件，       * 而上传文件时，resttemplate 会通过这个方法获取大小。然后当真正需要读取内容的时候，发现已经读完，会报如下错误。       */      @override      public long contentlength() {          long estimate = length;          return estimate == 0 ? 1 : estimate;      }         public void setlength(long length) {          this.length = length;      }         public void setfilename(string filename) {          this.filename = filename;      }  }

  try{      string applyseqno = "123456";      string cookie="654321";      file file=new file("e:\1.rar");      fileinputstream fileinputstream=new fileinputstream(file);         //请求头设置为mediatype.multipart_form_data类型      httpheaders requestheaders = new httpheaders();      requestheaders.setcontenttype(mediatype.multipart_form_data);            //构建请求体      multivaluemap<string, object> requestbody = new linkedmultivaluemap<>();      commoninputstreamresource commoninputstreamresource = null;      try {          commoninputstreamresource = new commoninputstreamresource(fileinputstream,file.length(),file.getname());      } catch (exception e) {           log.error("文件输入流转换错误",e);      }      requestbody.add("cookie", cookie);      requestbody.add("seqnofile", applyseqno);      requestbody.add("file",commoninputstreamresource);      httpentity<multivaluemap> requestentity = new httpentity<multivaluemap>(requestbody, requestheaders);            //直接调用远程接口      responseentity<string> responseentity = resttemplate.postforentity("https://xxx.xxx.xxx.xxx:8080/test/upload",requestentity, string.class);      system.out.println("返回结果："+responseentity.getbody())  }catch (exception e){      log.error("远程调用出现异常：", e);  }

  @component  @feignclient(name = "taxrecodes", url = "${spider.url}", qualifier = "taxrecodefeignclient",fallback = taxrecodefallback.class)  public interface taxrecodefeignclient {          /**       * 单证申请-合同信息表附件上传       */      @postmapping(value = "/attachfile/upload",consumes = mediatype.multipart_form_data_value)      string attachfileupload(multivaluemap<string, object> multivaluemap);  }

  @postmapping("/upload")  public void upload(){      try {          file file=new file("e:\1.rar");          fileinputstream fileinputstream=new fileinputstream(file);           commoninputstreamresource commoninputstreamresource = null;          try {              commoninputstreamresource = new commoninputstreamresource(fileinputstream,fileinputstream.available(),file.getname());          } catch (exception e) {              log.error("文件输入流转换错误:",e);          }           multivaluemap<string, object> dto=new linkedmultivaluemap<string, object>();          dto.add("cookie","xxx");          dto.add("file",commoninputstreamresource);          dto.add("seqnofile","xxx");             string returninfo = taxrecodefeignclient.attachfileupload(dto);          jsonobject returninfojsonobject = jsonobject.parseobject(returninfo);      }catch (exception e){          log.error("异常：",e);      }  }

  // 获取第三方的authorization  string auth= oauthcontenthelper.getauthorizationheader();  httpheaders requestheader=new httpheaders();  // 将获取到的authorization添加到请求头  requestheader.add(authconstants.authorization_header,auth);  // 构建请求实体  httpentity<object> requestentity=new httpentity(requestparam,requestheaders);  // 使用resttemplate调用第三方接口  resttemplate.exchage(url,httpmethod.post,requestentity,responseclass);