Java 利用 Spring 实现带 MultipartFile 的 HttpServletRequest 请求原封不动转发到其他服务

在Java中，要将带有MultipartFile的HttpServletRequest请求原封不动地转发到另一个服务，你可以使用Spring的`ForwardingClientHttpRequestFactory`。下面是一个示例： 1. 首先，添加Spring Web和Spring Core依赖项到你的项目中。 2. 创建一个新的类，例如`ForwardingClientHttpRequestFactory`，并实现`ClientHttpRequestFactory`接口。在这个类中，你需要重写`createRequest`方法以处理原始请求和转发请求。 ```java import org.springframework.http.HttpMethod; import org.springframework.http.client.ClientHttpRequest; import org.springframework.http.client.ClientHttpRequestFactory; import org.springframework.http.client.SimpleClientHttpRequestFactory; import org.springframework.util.Assert; import org.springframework.web.multipart.MultipartHttpServletRequest; import javax.servlet.http.HttpServletRequest; import java.io.IOException; import java.net.URI; public class ForwardingClientHttpRequestFactory implements ClientHttpRequestFactory { private final HttpServletRequest request; private final SimpleClientHttpRequestFactory delegate = new SimpleClientHttpRequestFactory(); public ForwardingClientHttpRequestFactory(HttpServletRequest request) { Assert.notNull(request, "HttpServletRequest must not be null"); this.request = request; } @Override public ClientHttpRequest createRequest(URI uri, HttpMethod httpMethod) throws IOException { if (request instanceof MultipartHttpServletRequest && HttpMethod.POST.equals(httpMethod)) { return new ForwardingClientHttpRequest((MultipartHttpServletRequest) request, delegate.createRequest(uri, httpMethod)); } else { return delegate.createRequest(uri, httpMethod); } } } ``` 3. 然后创建一个名为`ForwardingClientHttpRequest`的新类，该类扩展了`BufferingClientHttpRequest`。这个类负责转发MultipartHttpServletRequest请求。 ```java import org.springframework.http.HttpHeaders; import org.springframework.http.HttpOutputMessage; import org.springframework.http.client.BufferingClientHttpRequest; import org.springframework.http.client.ClientHttpResponse; import org.springframework.util.StreamUtils; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.support.StandardMultipartHttpServletRequest; import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.InputStream; import java.nio.charset.Charset; import java.util.List; public class ForwardingClientHttpRequest extends BufferingClientHttpRequest { private final StandardMultipartHttpServletRequest multipartRequest; private final HttpHeaders headers; public ForwardingClientHttpRequest(StandardMultipartHttpServletRequest multipartRequest, HttpOutputMessage outputMessage) { super(outputMessage); this.multipartRequest = multipartRequest; this.headers = outputMessage.getHeaders(); } @Override protected ClientHttpResponse executeInternal(HttpHeaders headers, byte[] bufferedOutput) throws IOException { for (String headerName : this.headers.keySet()) { headers.add(headerName, this.headers.get(headerName)); } List<MultipartFile> files = multipartRequest.getFiles("file"); for (MultipartFile file : files) { headers.setContentLength(file.getSize()); headers.setContentType(file.getContentType()); InputStream body = new ByteArrayInputStream(file.getBytes()); StreamUtils.copy(body, getBody()); } return getDelegate().execute(getInternalRequest(), headers); } } ``` 4. 在你的代码中，你可以使用`RestTemplate`将带有MultipartFile的HttpServletRequest请求转发到另一个服务。 ```java import org.springframework.http.HttpEntity; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.servlet.support.ServletUriComponentsBuilder; import org.springframework.web.client.RestTemplate; @RestController public class YourController { @PostMapping("/forward") public ResponseEntity<String> forward(@RequestParam("file") MultipartFile file) { // 获取原始请求 HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); // 创建一个转发请求工厂 ForwardingClientHttpRequestFactory factory = new ForwardingClientHttpRequestFactory(request); // 创建一个RestTemplate实例 RestTemplate restTemplate = new RestTemplate(factory); // 设置目标URL String url = ServletUriComponentsBuilder.fromCurrentContextPath().path("/target-service").toUriString(); // 构建HttpEntity用于转发请求 HttpEntity<MultipartFile> entity = new HttpEntity<>(file); // 转发请求并获取响应 ResponseEntity<String> response = restTemplate.postForEntity(url, entity, String.class); return response; } } ``` 注意：确保将`/target-service`替换为你要转发到的实际服务URL。 ######[AI写代码神器 | 932点数解答 | 2023-12-14 13:49:17]