java - 向 Eureka 休息服务端点发送多部分文件请求时出现异常

标签 java spring spring-boot microservices netflix-eureka

我正在开发一个文件存储库来存储 pdf 文件。我正在使用生产者和消费者架构中的 eureka + spring boot。客户正在处理

public boolean uploadBooks(MultipartFile file, String fileLocation, String fileName) {
    boolean callResponse = false;
    try {
        if(!file.isEmpty()) {
            ByteArrayResource fileResource = new ByteArrayResource(file.getBytes()) {
                public String getFileName() {
                    return file.getOriginalFilename();
                }
            };
        LinkedMultiValueMap<String, Object> requestMap = new LinkedMultiValueMap<>();
        requestMap.add("file", fileResource);
        requestMap.add("repoLocation", fileLocation);
        requestMap.add("fileId", fileName);

        HttpHeaders requestHeader = new HttpHeaders();
        requestHeader.setContentType(MediaType.MULTIPART_FORM_DATA);
        HttpEntity<LinkedMultiValueMap<String, Object>> requestEntity = new HttpEntity<LinkedMultiValueMap<String, Object>>(
                requestMap, requestHeader);
        System.err.println(requestEntity.getBody());
        System.err.println(uploadBooks);
        ResponseEntity<Boolean> response = restTemplate.exchange(uploadBooks,HttpMethod.POST, requestEntity,
                Boolean.class);
        callResponse = response.getBody();
        }
    } catch (Exception ex) {
        ex.printStackTrace();
    }

    return callResponse;
}

剩下的终点是

@PostMapping("/uploadFile")

public boolean uploadFile(@RequestParam("file") MultipartFile file,
        @RequestParam("repoLocation") String repoLocation, @RequestParam("fileId") String fileId) {

    boolean process = false;
    try {
    System.out.println("---->"+fileId);
    process = fileServices.saveFile(file, repoLocation, fileId);
    } catch (RepoStorageException e) {

        e.printStackTrace();
    }
    if (process) {
        return true;
    }
    return false;

}

当我上传文件时，我得到

org.springframework.web.client.HttpClientErrorException$BadRequest: 400 null

异常。请帮助我编写处理客户端请求的端点。

错误堆栈跟踪

org.springframework.web.client.HttpClientErrorException$BadRequest: 400 null
at org.springframework.web.client.HttpClientErrorException.create(HttpClientErrorException.java:79)
at org.springframework.web.client.DefaultResponseErrorHandler.handleError(DefaultResponseErrorHandler.java:97)
at org.springframework.web.client.DefaultResponseErrorHandler.handleError(DefaultResponseErrorHandler.java:79)
at org.springframework.web.client.ResponseErrorHandler.handleError(ResponseErrorHandler.java:63)
at org.springframework.web.client.RestTemplate.handleResponse(RestTemplate.java:777)
at org.springframework.web.client.RestTemplate.doExecute(RestTemplate.java:735)
at org.springframework.web.client.RestTemplate.execute(RestTemplate.java:669)
at org.springframework.web.client.RestTemplate.exchange(RestTemplate.java:578)
at com.library.remoteservices.repository.LibraryFileRepository.uploadBooks(LibraryFileRepository.java:76)
at com.library.LibraryServiceDiscoveryClient.FileServiceController.uploadBooks(FileServiceController.java:28)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:215)
at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:142)
at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:102)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:800)
at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)
at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1038)
at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:942)
at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:998)
at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:901)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:660)
at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:875)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:741)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:92)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
at org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:93)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:200)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:199)
at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)
at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:490)
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139)
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74)
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343)
at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:408)
at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)
at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:770)
at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1415)
at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
at java.lang.Thread.run(Thread.java:748)

最佳答案

现在有像Spring Content这样的项目为非结构化数据(即文件、图像、视频等)提供与 Spring Data 为结构化数据非常相似的编程模型。另外，它允许您将这些文件与您的实体相关联。

因此(假设您使用的是 Spring Boot)，您将添加以下依赖项:

pom.xml

   <!-- Java API -->
   <dependency>
      <groupId>com.github.paulcwarren</groupId>
      <artifactId>spring-content-fs-boot-starter</artifactId>
      <version>0.4.0</version>
   </dependency>
   <!-- REST API -->
   <dependency>
      <groupId>com.github.paulcwarren</groupId>
      <artifactId>spring-content-rest-boot-starter</artifactId>
      <version>0.4.0</version>
   </dependency>

将以下属性添加到您的文件实体，以便内容可以与其关联。

File.java

@Entity
public class File {

   ...existing fields...

   @ContentId
   private UUID contentId;

   @ContentLength
   private long contentLength = 0L;

   // if you have rest endpoints
   @MimeType
   private String mimeType;

   ...
}

创建一个 ContentStore(相当于您的 FileRepository，但用于您的文件):

FileContentStore.java

@StoreRestResource(path="fileContents")
public interface FileContentStore extends ContentStore<File, UUID> {
}

当您运行应用程序时，Spring Content 将看到 FileContentStore 接口(interface)和 spring-content-fs 依赖项，并为您注入(inject)该接口(interface)的 Filesystem 实现。它还会看到 spring-content-rest 依赖项，并添加一个 @Controller 实现，将 GET、PUT、POST 和 DELETE REST 请求转发到 FileContentStore 上。这使您不必编写上面的任何 Controller 代码。 REST 端点将在 /fileContents 处可用，所以...

curl -X POST -F "image=@/path/to/local/file.pdf"/fileContents/{fileId}

将上传 file.pdf 并将其与您的文件实体关联。并且:

curl/fileContents/{fileId} 将再次获取它。

这个编程模型还创建了文件存储实现的抽象，允许您选择 Spring Content 支持的任何类型的存储(目前是文件系统、S3、JPA BLOB、Mongo 的 Gridfs 和 Google Storage)。无论如何，您的应用程序代码将保持不变。

HTH

关于java - 向 Eureka 休息服务端点发送多部分文件请求时出现异常，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/53367822/

上一篇：java - 使用 Java 将 Java Web 项目转换为 Angular

下一篇：java - 使ArrayList添加线程安全而不使用线程安全集合

相关文章：

java - 等距图 block 生成

java - RxJava2 : Alternative to rx. 可观察方法第一个(谓词)

java - kafka消费者组线程的线程顺序在每次启动时都不同

java - JPA-映射问题

java - Windows 10 不支持请求方法 'HEAD'

java - 如何将csrf token添加到html表单中？

java - 在Ubuntu中运行Hadoop Jar

java - 在 apache spark 中，如何在 groupBy() 之后将一列 mllib Vector 收集到列表中？

tomcat - Spring + thymeleaf 渲染HTML表单标签失败

node.js - 无法从 : https://nodejs. org/dist/v6.11.3/x64/node.exe 下载 Node.js:从服务器获取错误代码 404

©2024 IT工具网  联系我们