[Question] DashScopeChatModel使用call方法高频超时问题

[smile-shark]

Question

现在只要是使用到了call方法来进行接收，那么必然会出现这个超时的问题，DashScopeApi使用RestClientFactory构造RestClient也没有办法手动的设置超时时间，在使用某些类时，比如FactCheckingEvaluator评估器，其中内置使用call方法调用，虽然可以重写这个方法，但是还是不希望重复造轮子

2025-12-04T10:47:07.101+08:00 WARN 5068 --- [ main] o.s.a.r.a.SpringAiRetryAutoConfiguration : Retry error. Retry count: 1, Exception: I/O error on POST request for "https://dashscope.aliyuncs.com/api/v1/services/aigc/text-generation/generation": timeout

org.springframework.web.client.ResourceAccessException: I/O error on POST request for "https://dashscope.aliyuncs.com/api/v1/services/aigc/text-generation/generation": timeout
at org.springframework.web.client.DefaultRestClient$DefaultRequestBodyUriSpec.createResourceAccessException(DefaultRestClient.java:586) ~[spring-web-6.1.21.jar:6.1.21]
at org.springframework.web.client.DefaultRestClient$DefaultRequestBodyUriSpec.exchangeInternal(DefaultRestClient.java:500) ~[spring-web-6.1.21.jar:6.1.21]
at org.springframework.web.client.DefaultRestClient$DefaultRequestBodyUriSpec.retrieve(DefaultRestClient.java:456) ~[spring-web-6.1.21.jar:6.1.21]
at com.alibaba.cloud.ai.dashscope.api.DashScopeApi.chatCompletionEntity(DashScopeApi.java:1666) ~[spring-ai-alibaba-core-1.0.0.4.jar:1.0.0.4]

我尝试别人的建议添加了以下配置：
spring:
http:
client:
read-timeout: 60s
并且在代码中做了耗时统计：
long l = System.currentTimeMillis();
try {
EvaluationResponse evaluate = factCheckingEvaluator.evaluate(evaluationRequest);
System.out.println("evaluate = " + evaluate);
} catch (Exception e) {
System.out.println(e.getMessage());
}
System.out.println("耗时：" + (System.currentTimeMillis() - l));
最后结果还是不尽人意：
I/O error on POST request for "https://dashscope.aliyuncs.com/api/v1/services/aigc/text-generation/generation": timeout
耗时：10138

[zhanghl379]

最后怎么解决的？

[smile-shark]

call方法的话应该只需要配置上面的一个就行了

@SpringBootTest
public class AgentTest {

    @TestConfiguration
    public static class TestConfig {
        @Bean
        public RestClient.Builder restClientBuilderProvider() {
            SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
            factory.setConnectTimeout(Duration.ofMinutes(5));
            factory.setReadTimeout(Duration.ofMinutes(5));
            return RestClient.builder().requestFactory(factory);
        }
        @Bean
        public WebClient.Builder webClientBuilderProvider() {
            return WebClient.builder()
                    .clientConnector(new ReactorClientHttpConnector(
                            HttpClient.create()
                                    .responseTimeout(Duration.ofMinutes(5))
                                    .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 300_000)
                                    .doOnConnected(conn ->
                                            conn.addHandlerLast(new ReadTimeoutHandler(300))
                                                    .addHandlerLast(new WriteTimeoutHandler(300)))
                    ));
        }
    }

    @Autowired
    private DashScopeChatModel dashScopeChatModel;

    @Test
    public void test() {
        ChatClient chatClient = ChatClient.builder(dashScopeChatModel).build();
        System.out.println(chatClient.prompt()
                .user("请告诉我Ollama中的端口是多少")
                .call().content());

    }
}

[smile-shark]

现在里面不能直接通过RestClient，要注入RestClient.Builder

    @Bean
    @ConditionalOnMissingBean
    public DashScopeChatModel dashscopeChatModel(RetryTemplate retryTemplate, ToolCallingManager toolCallingManager, DashScopeChatProperties chatProperties, ResponseErrorHandler responseErrorHandler, DashScopeConnectionProperties commonProperties, ObjectProvider<ObservationRegistry> observationRegistry, ObjectProvider<WebClient.Builder> webClientBuilderProvider, ObjectProvider<RestClient.Builder> restClientBuilderProvider, ObjectProvider<ChatModelObservationConvention> observationConvention, ObjectProvider<ToolExecutionEligibilityPredicate> dashscopeToolExecutionEligibilityPredicate) {
        DashScopeApi dashscopeApi = this.dashscopeChatApi(commonProperties, chatProperties, (RestClient.Builder)restClientBuilderProvider.getIfAvailable(RestClient::builder), (WebClient.Builder)webClientBuilderProvider.getIfAvailable(WebClient::builder), responseErrorHandler, "chat");
        DashScopeChatModel dashscopeModel = DashScopeChatModel.builder().dashScopeApi(dashscopeApi).retryTemplate(retryTemplate).toolCallingManager(toolCallingManager).defaultOptions(chatProperties.getOptions()).observationRegistry((ObservationRegistry)observationRegistry.getIfUnique(() -> {
            return ObservationRegistry.NOOP;
        })).toolExecutionEligibilityPredicate((ToolExecutionEligibilityPredicate)dashscopeToolExecutionEligibilityPredicate.getIfUnique(DefaultToolExecutionEligibilityPredicate::new)).build();
        Objects.requireNonNull(dashscopeModel);
        observationConvention.ifAvailable(dashscopeModel::setObservationConvention);
        return dashscopeModel;
    }

    private DashScopeApi dashscopeChatApi(DashScopeConnectionProperties commonProperties, DashScopeChatProperties chatProperties, RestClient.Builder restClientBuilder, WebClient.Builder webClientBuilder, ResponseErrorHandler responseErrorHandler, String modelType) {
        ResolvedConnectionProperties resolved = DashScopeConnectionUtils.resolveConnectionProperties(commonProperties, chatProperties, modelType);
        return DashScopeApi.builder().apiKey(resolved.apiKey()).headers(resolved.headers()).baseUrl(resolved.baseUrl()).webClientBuilder(webClientBuilder).workSpaceId(resolved.workspaceId()).restClientBuilder(restClientBuilder).responseErrorHandler(responseErrorHandler).build();
    }