WebFlux WebClient：使用REST服务，该服务返回带有Content-Type"text/string"的JSON主体

Question

我正在消费一个REST服务，它返回一个JSON格式的字符串，但在头中给出了内容类型的“文本/字符串”。我试图去问题的根源，但代码似乎不再被维护。如果没有更好的解决方案，我需要分叉spaCy Rest Services项目，并把它放在自己的某种容器中...

我已经尝试了所有这些解决方案，但所使用的方法要么已被弃用，要么由于其他原因，这些解决方案不起作用：

Spring Responsive WebClient获取内容类型为“text/plain；charset=UTF-8”的json响应

带有文本/html响应的反应式WebClient获取请求

我收到的例外总是：org。springframework。网状物反应性。作用UnsupportedMediaTypeException:不支持内容类型“文本/字符串”

我的代码是：

public class SpacyClient {

    WebClient webClient;

    public SpacyClient() {
        webClient = WebClient.builder()
                .baseUrl("http://localhost:8081")
                .build();
    }

    public List<NamedEntity> spacyNamedEntities(String text) {

        HashMap<String, String> requestBody = new HashMap<>();
        requestBody.put("text", text);
        requestBody.put("model", "en_core_web_lg");

        Mono<List<NamedEntity>> responseMono = webClient.post()
                .uri("/ent")
                .accept(MediaType.APPLICATION_JSON)
                .body(BodyInserters.fromValue(requestBody))
                .exchangeToMono( response -> {
                   Mono<List<NamedEntity>>  = response.bodyToMono(new ParameterizedTypeReference<List<NamedEntity>>() {});
                   return lalala;
                });
        List<NamedEntity> entities = responseMono.block();
        return entities;

    }

}

Answer 1

这里是我做的变通方法，只是使用Jackson显式地反序列化字符串。虽然不漂亮，但确实管用。

    public List<NamedEntity> spacyNamedEntities(String text) {

        HashMap<String, String> requestBody = new HashMap<>();
        requestBody.put("text", text);
        requestBody.put("model", "en_core_web_lg");

        Mono<String> responseMono = webClient.post()
                .uri("/ent")
                .body(BodyInserters.fromValue(requestBody))
                .retrieve()
                .bodyToMono(String.class);
        String json = responseMono.block();

        ObjectMapper objectMapper = new ObjectMapper();

        List<NamedEntity> entities = new ArrayList<>();
        try {
            entities = objectMapper.readerForListOf(NamedEntity.class).readValue(json);
        } catch (JsonProcessingException e) {
            // ToDo: show information in frontend
        }

        return entities;

    }