将 RestTemplate 用于 Rest API 时出现 400 错误代码

Question

我有一个 REST API 可以调用，并且我已经使用 REST 模板编写了客户端。执行时，我得到 400 状态码。使用 POSTMAN 时，相同的 REST API 工作正常。下面是 API 和调用者的代码 sn-ps。如果有人发现任何东西，请告诉我。

用于 POST 方法的 REST API-

@ApiOperation(value = "Download repository as zip")
    @ApiResponses({@ApiResponse(code = 200, message = ""), @ApiResponse(code = 400, message = "")})
    @PostMapping(value = "/download", produces = {MediaType.APPLICATION_OCTET_STREAM_VALUE})
    public ResponseEntity<StreamingResponseBody> downloadRepository(
            @RequestBody @Validated final RepositoriesRequest repositoriesRequest) {

        final Situation situation = this.situationsService.getSituationId(repositoriesRequest);
        if (isNull(situation)) {
            return ResponseEntity.notFound().build();
        } else {
            final ExtractionRequest extractionRequest = new ExtractionRequest(repositoriesRequest.getType(), situation,
                    repositoriesRequest.getDatabase());

            if (!this.validateRequest(extractionRequest)) {
                return ResponseEntity.badRequest().build();
            }
            final ExtractionResponse response = this.extractService.extractRepository(extractionRequest);

            if (null == response) {
                return ResponseEntity.notFound().build();
            }
            final InputStream inputStream = this.extractService.getFileFromS3(response.getRepositoryPath());

            if (null == inputStream) {
                return ResponseEntity.noContent().build();
            }

            final StreamingResponseBody bodyWriter = this.bodyWriter(inputStream);

            return ResponseEntity.ok()
                    .header("Content-Type", "application/zip")
                    .header(CONTENT_DISPOSITION, "attachment; filename=\"repository-" + situation.getId() + ".zip\"")
                    .body(bodyWriter);
        }
    }

REST CLIENT 使用带有身份验证令牌和请求正文作为输入的 Rest Template -

HttpEntity<MultiValueMap<String, Object>> buildLoadRepoRequest(
            final SimulationContext context,
            final List<String> tablesName,
            final String simulationId,
            final Integer offset) {
        final Token token = this.authenticateOkoye(simulationId, offset);
        LOGGER.info("Token Run: {}", token.getAccessToken());
        final String database = this.getDatabaseForEnvironment();

        final HttpHeaders httpHeaders = new HttpHeaders();
        httpHeaders.setContentType(APPLICATION_JSON_UTF8);
        httpHeaders.set(AUTHORIZATION, "Bearer " + token.getAccessToken());

        final MultiValueMap<String, Object> body = new LinkedMultiValueMap<>();
        body.add("database", database);
        body.add("monthlyClosingMonth", context.getMonthlyClosingDate());
        body.add("repositorySnapshot", context.getRepository());
        body.add("situationId", context.getSituationId());
        body.add("tableNames", tablesName);
        body.add("type", context.getRunType());

        return new HttpEntity<>(body, httpHeaders);
    }

异常处理程序 -

    @Override
    @ExceptionHandler(HttpClientErrorException.class)
    public void loadRepository(
            final SimulationContext context,
            final List<String> tablesName,
            final String simulationId,
            final Integer offset,
            final Path repositoryPath) throws IOException {
        LOGGER.info("[{}] [{}] repository tablesName: {}", simulationId, offset, tablesName);
        this.restTemplate.setRequestFactory(this.getClientHttpRequestFactory());
        final ClientHttpResponse response = this.restTemplate.postForObject(
                this.repositoriesUrl,
                this.buildLoadRepoRequest(context, tablesName, simulationId, offset),
                ClientHttpResponse.class);

        if (response != null && HttpStatus.OK == response.getStatusCode()) {
            LOGGER.info(
                    "response status on simulation : {}  - Context: {} - status: {}",
                    simulationId,
                    offset,
                    response.getStatusCode());
            //this.helper.copy(response.getBody(), repositoryPath);
        } else if (response != null && HttpStatus.NO_CONTENT != response.getStatusCode()) {
            throw new JarvisException(
                    "Can't retrieve RWA repository on simulation " + simulationId + " Context:" + offset);
        }
    }

我们从昨天开始就一直在研究这个问题，但仍然没有任何线索。到目前为止，我们已经尝试过 postForEntity、exchange、将标头更改为适当的 setter 方法，并尝试将参数也作为对象传递。他们都没有工作。

在调用 API 时，我强烈感觉标头级别出现问题。

Answer 1

你尝试使用httpHeaders.setContentType(MediaType.APPLICATION_JSON)

或者使用 APPLICATION_JSON_UTF8 值将消费添加到 @PostMapping 注释