SpringBoot - WebFlux 获取 ClassCastException

问题描述

我正在尝试编写一个通用函数来执行一些 Webflux 操作，但遇到了一个我无法弄清楚的类转换异常

     * @param <T> Type of the contract
     * @param <U> Return type of this method
     * @param <V> Return type from the service
public <T,U,V> U sendRequest(String url,T contract,Function<V,U> transform) {

        ParameterizedTypeReference<T> contractType = new ParameterizedTypeReference<T>() {};
        ParameterizedTypeReference<V> returnType = new ParameterizedTypeReference<V>() {};
        final WebClient.ResponseSpec foo = webClient.post()
                .uri(url)
                .body(Mono.just(contract),contractType)
                .retrieve();

        Mono<V> mono =  foo.bodyToMono(returnType);

      final Mono<U> trans = mono.map(m -> transform.apply(m));
      return trans.block();
}

此代码在其非通用形式下运行良好。但是当我用这样的东西调用这个通用方法时

    requestRunner.<Contract,String,viewmodel>sendRequest(url,contract,v->(String)v.getResult().get("outputString"));

我得到一个例外：

java.lang.classCastException: java.util.LinkedHashMap cannot be cast to com.torchai.service.common.ui.viewmodel
    at com.torchai.service.orchestration.service.RequestRunner.lambda$sendRequest$0(RequestRunner.java:44)

我正在运行 SpringBoot 2.4.5 版，所以我认为这不适用：https://github.com/spring-projects/spring-framework/issues/20574

只是为了多一点上下文，在上面的示例中，viewmodel（通用类型 <V>）是服务返回其数据的格式。然后我只提取我需要的部分，在这种情况下是一个字符串（通用类型 <U>）传入的 lambda 函数从响应中获取相关字符串。但是由于某种原因，Mono 没有正确映射到 viewmodel。如果我取出 map() 并返回 viewmodel，它似乎可以工作。

再说一次，如果我以非通用方式执行此操作，则效果很好。我可以执行 map() 步骤并正确返回一个字符串

更新

只是想说明这对于像这样的非通用版本可以正常工作：

public String sendRequest(String url,Contract contract,Function<viewmodel,String> transform) {

        ParameterizedTypeReference<Contract> contractType = new ParameterizedTypeReference<Contract>() {};
        ParameterizedTypeReference<viewmodel> returnType = new ParameterizedTypeReference<viewmodel>() {};
        final WebClient.ResponseSpec foo = webClient.post()
                .uri(url)
                .body(Mono.just(contract),contractType)
                .retrieve();

        Mono<viewmodel> mono = foo.bodyToMono(returnType);

        final Mono<String> trans = mono.map(m -> transform.apply(m));
        return trans.block();
}

就是这样称呼

requestRunner.<Contract,viewmodel>sendRequest(textExtractorUrl,cloudContract,v -> (String) v.getResult().get("outputString"));

它正确返回一个字符串，这正是我想要的通用版本

解决方法

我能够在本地重现这个问题并开始一些调试，但真的很难看到 webflux 代码中发生了什么/哪里发生了什么。

ViewModel 的类型声明 V 只在调用者处知道，而在方法 sendRequest 中不知道。似乎使用 ParameterizedTypeReference<V> 是问题所在。在这种情况下，V 只是真实类型的通用占位符，因此 spring 只捕获 V 中的 ParameterizedTypeReference 并且不知道应该将响应反序列化为 { {1}}。相反，它尝试为类型 ViewModel 找到一个反序列化器，并且它可以找到的最接近的是类型 V。因此，在您的情况下，您最终得到了一个顶级 LinkedHashMap（而不是 LinkedHashMap），其中包含一个键 ViewModel，其值为 result 类型，其中包含您的结果条目。这就是您获得 LinkedHashMap 的原因。

我已经删除了 ClassCastException 并使用了显式 ParameterizedTypeReference<V> 版本，并且它可以工作。在这个版本中，您不必自己放入泛型类型，只需为方法提供参数，泛型将自动从上下文中派生。

Class<V>

调用：

public <T,U,V> U sendRequest(String url,T contract,Class<V> responseType,Function<V,U> transform)
{
    WebClient.ResponseSpec foo = webClient.post()
            .uri(url)
            .body(Mono.just(contract),contract.getClass())
            .retrieve();
    Mono<V> mono = foo.bodyToMono(responseType);
    Mono<U> trans = mono.map(transform);
    return trans.block();
}

如果有人想要进行更深入的调查，这是我的最小可重复示例。

pom.xml

requestRunner.sendRequest(url,contract,ViewModel.class,v -> (String) v.getResult().get("outputString"));

DemoApplication.java

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.4.5</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.example</groupId>
    <artifactId>demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>demo</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-webflux</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>io.projectreactor</groupId>
            <artifactId>reactor-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

控制器.java

@SpringBootApplication
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class,args);
    }
}

这是有效的，因此您可能不会从您的 webClient 主体返回 ViewModel，而是从 map 返回 ViewModel 参数（或其他内容）。

public class Play {
    private ViewModel viewModel = new ViewModel(); 
    public static void main(String[] args) {
        new Play().run();
    }
    static class ViewModel {
        private Map<String,Object> result;
        public ViewModel() {
            result = new LinkedHashMap<>(); 
            result.put("outputString","acb");
        }
        public Map<String,Object> getResult() {
            return result;
        }
    }
    private void run() {
        this.<String,String,ViewModel>sendRequest("http","contract",v->(String)v.getResult().get("outputString"))
        .subscribe(System.out::println);
    }
    public <T,V> Mono<U> sendRequest(String url,U> transform) {
        @SuppressWarnings("unchecked")
        Mono<V> mono =  Mono.just((V)viewModel);

      final Mono<U> trans = mono.map(m -> transform.apply(m));
      return trans; 
    }
}

即，如果我更改为：

        @SuppressWarnings("unchecked")
        Mono<V> mono =  Mono.just((V)viewModel.getResult());

然后我得到

reactor.core.Exceptions$ErrorCallbackNotImplemented: java.lang.ClassCastException: java.util.LinkedHashMap 不能被转换为fluxjunk.Play$ViewModel 引起：java.lang.ClassCastException：java.util.LinkedHashMap 不能转换为fluxjunk.Play$ViewModel 在fluxjunk.Play.lambda$2(Play.java:32)

classcastexception classcastexception spring-boot spring-webflux webflux