时间戳

首页 > 解决方案 > 如何处理 SI HttpRequestExecutingMessageHandler 中的“Transfer-Encoding=chunked”

spring - 如何处理 SI HttpRequestExecutingMessageHandler 中的“Transfer-Encoding=chunked”

问题描述

我正在使用HttpRequestExecutingMessageHandler调用外部服务器。我正在使用 JSON 到对象转换器来转换 JSON 数据。但我收到以下异常。

原因：com.fasterxml.jackson.core.JsonParseException：非法字符（（CTRL-CHAR，代码 31））：在 [Source: (String )"�</p>

当我检查标题时，我发现了以下内容。 传输编码=分块

这是异常日志的原因吗？

出站网关和 JsonToObjectTransformer 如下所示：

    @ServiceActivator(inputChannel = "channelOutboundRequest")
    @Bean
    public HttpRequestExecutingMessageHandler outboundGateway() {
        final HttpRequestExecutingMessageHandler handler = new HttpRequestExecutingMessageHandler(
                endpoint);
        handler.setExpectedResponseType(String.class);
        handler.setHttpMethod(HttpMethod.POST);
        handler.setOutputChannelName("channelResponse");
        handler.setAdviceChain(Collections.singletonList(advice()));
        return handler;
    }
    @Bean
    @Transformer(inputChannel = "channelResponse", outputChannel = "channelReply")
    public JsonToObjectTransformer transformer(ObjectMapper objectMapper) {
        final JsonObjectMapper<?, ?> mapper = new Jackson2JsonObjectMapper(objectMapper);
        return new JsonToObjectTransformer(DetailsDTO.class, mapper);
    }

如果标头导致问题，我该如何处理响应？

注意：如果我直接使用邮递员访问外部服务器，我会得到 JSON 结构的响应。

我不知道这里出了什么问题。如果我使用如下简单的 restemplate 调用，它可以正常工作。

JSONObject jsonObject = new JSONObject("{\"code\":\"F001\",\"transactionId\":\"1008566223232\"}");
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        headers.setBearerAuth("token");
        HttpEntity<String> request = 
                  new HttpEntity<String>(jsonObject.toString(), headers);
        String respns = restTemplt.postForObject("http://endpoint", request, String.class);
        System.out.println(respns);
        JSONObject response = new JSONObject(respns);

我能找到的一个区别是响应标头。这些在下面给出：

出站网关响应标头：- { Transfer-Encoding= chunked , http_requestMethod=GET, errorChannel=org.springframework.messaging.core.GenericMessagingTemplate$TemporaryReplyChannel@d8b195e, Server=nginx, Accept= / , Connection=keep-alive, User-Agent =PostmanRuntime/7.28.0, Host=localhost:8901, Accept-Encoding=gzip, deflate, br, http_statusCode=200 OK, Date=1622533072000, Authorization=Bearer token, replyChannel=org.springframework.messaging.core.GenericMessagingTemplate$TemporaryReplyChannel@d8b195e, Cache-Control=no-cache, ETag=W/"1009-5SzdL+uWyY6ZcMWht5dMtm2Sxlc" , Content-Encoding=gzip, http_requestUrl=http://inboundurl, id=be07fc8d-d478-5fa9-33e4-61a2b5f92468, Content-Length=207, contentType=application/json;charset=utf-8, Content-Type=application /json，requestFrom=CUSTOM_HEADER，时间戳=1622533092827}

正常的 restTemplate 调用响应头 [服务器：“nginx”，日期：“星期二，2021 年 6 月 1 日 07:34:54 GMT”，内容类型：“application/json; charset=utf-8”，内容长度：“4105”，连接：“ keep-alive"，访问控制允许来源："*"，内容安全策略："default-src 'self'；base-uri 'self'；block-all-mixed-content；font-src ' self' https: 数据:;frame-ancestors 'self';img-src 'self' 数据:;object-src 'none';script-src 'self';script-src-attr 'none';style-src' self' https: 'unsafe-inline';upgrade-insecure-requests", X-DNS-Prefetch-Control:"off", Expect-CT:"max-age=0", X-Frame-Options:"SAMEORIGIN" , Strict-Transport-Security:"max-age=15552000; includeSubDomains", X-Download-Options:"noopen",X-Content-Type-Options:"nosniff", X-Permitted-Cross-Domain-Policies:"none", Referrer-Policy:"no-referrer", X-XSS-Protection:"0", ETag:"W /"1009-llD9DqxYkEsjyikWajYk+16cb1k""]

有人可以帮忙吗？

标签： springspring-bootspring-integrationspring-integration-http

解决方案

经过多次尝试和错误，我找到了原因。Accept-Encoding=gzip, deflate, br这个头在出站网关请求是根本原因。我得到的响应是一个长字符串，并且由于此标头而被压缩。我在出站网关之前添加了一个标头过滤器以删除此标头。

    @Bean
    @Transformer(inputChannel = "channelHeaderFilterReq", outputChannel = "channelHeaderFilterRes")
    public HeaderFilter filter() {
        return new HeaderFilter("Accept-Encoding");
    }

现在一切正常..!!

推荐阅读