使用Klaviyo邮件服务时遭遇Timeout Exception问题求助

问题描述 #

通过Klaviyo邮件服务发送邮件时，尽管生成用户档案与发送邮件的耗时较短，但仍触发超时异常，报错信息如下：

java.util.concurrent.TimeoutException: Did not observe any item or terminal signal within 60000ms in 'flatMap' (and no fallback has been configured)

相关代码：

public Boolean sendUpdatedReferralToRegisteredUsers(UserProfileDTO userProfileDTO, KlaviyoProperties klaviyoProperties, KlaviyoEmailType klaviyoEmailType) {
    WebClient client = WebClient.builder().baseUrl(KLAVIYO_BASE_URL)
            .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE).build();
    KlaviyoProfile klaviyoUser = null;
    
    klaviyoUser = checkKlaviyoProfilePresent(userProfileDTO.getUser().getEmail());
    
    if(klaviyoUser != null && klaviyoUser.getData().getId() != null) {
        klaviyoUser.getData().getAttributes().setFirst_name(userProfileDTO.getUser().getFirstName());
        klaviyoUser.getData().getAttributes().setLast_name(userProfileDTO.getUser().getLastName());
        try {
            klaviyoUser = client.patch().uri(KLAVIYO_PROFILE_ENDPOINT.concat(klaviyoUser.getData().getId()))
                    .headers(h -> h.addAll(getHeaders())).body(Mono.just(klaviyoUser), KlaviyoProfile.class)
                    .retrieve().bodyToMono(KlaviyoProfile.class).timeout(Duration.ofSeconds(60)).block();
            
            KlaviyoEvent klaviyoEvent = klaviyoEventPayload(klaviyoEmailType, klaviyoUser, klaviyoProperties);
            client.post().uri(KLAVIYO_EVENT_ENDPOINT)
            .headers(h -> h.addAll(getHeaders())).body(Mono.just(klaviyoEvent), KlaviyoEvent.class)
            .retrieve().bodyToMono(KlaviyoProfile.class).timeout(Duration.ofSeconds(60))
            .block();
        } catch(WebClientResponseException e) {
            log.debug(e.toString());
            return false;
        }
    } else {
        KlaviyoProfile profile = createKlaviyoProfile(userProfileDTO);
        profile.getData().getAttributes().setFirst_name(userProfileDTO.getUser().getFirstName());
        profile.getData().getAttributes().setLast_name(userProfileDTO.getUser().getLastName());
        try {
            klaviyoUser = client.post().uri(KLAVIYO_PROFILE_ENDPOINT).headers(h -> h.addAll(getHeaders()))
                    .body(Mono.just(profile), KlaviyoProfile.class).retrieve().bodyToMono(KlaviyoProfile.class)
                    .timeout(Duration.ofSeconds(60)).block();
            
            KlaviyoEvent klaviyoEvent = klaviyoEventPayload(KlaviyoEmailType.UPDATEREFERRAL, klaviyoUser, klaviyoProperties);
            
            client.post().uri(KLAVIYO_EVENT_ENDPOINT)
            .headers(h -> h.addAll(getHeaders())).body(Mono.just(klaviyoEvent), KlaviyoEvent.class)
            .retrieve().bodyToMono(KlaviyoProfile.class).timeout(Duration.ofSeconds(60))
            .block();               
        } catch (WebClientResponseException e) {
            log.debug(e.toString());
            return false;
        }
    }
    return true;
}

可能的原因 #

• 响应解析不匹配：发送事件的请求中，用bodyToMono(KlaviyoProfile.class)解析响应，但Klaviyo事件API返回的是事件结构而非用户档案，导致解析失败，Mono一直无法完成，最终触发超时。
• 异常捕获范围过窄：当前仅捕获WebClientResponseException，超时、连接等异常未被处理，且timeout()未配置fallback，一旦超时直接抛出未处理异常。
• WebClient重复创建：每次请求都新建WebClient，可能导致配置不一致，或底层HTTP客户端的全局超时覆盖了请求级别的60秒设置。
• 同步阻塞风险：多次调用block()阻塞线程，若线程池资源不足，请求排队间接引发超时。
• Klaviyo API隐性延迟：主观感知耗时短，但实际请求可能遇到Klaviyo后端排队、网络波动，或API未正确返回响应信号，导致Mono超时。

解决办法 #

• 修复响应解析错误：将发送事件请求的bodyToMono(KlaviyoProfile.class)改为对应事件响应类（如KlaviyoEventResponse），若不需要响应内容，直接用bodyToMono(Void.class)，避免解析失败导致Mono挂起。
• 完善超时与异常处理：给timeout()添加fallback逻辑，比如.timeout(Duration.ofSeconds(60), Mono.error(new RuntimeException("Klaviyo请求超时")))，同时扩大异常捕获范围，捕获TimeoutException、RuntimeException等，避免未处理异常扩散。
• 复用WebClient实例：将WebClient改为单例（比如通过@Bean注入），避免重复创建导致的配置问题，同时检查底层HTTP客户端的全局超时设置，确保不覆盖请求级别的超时配置。
• 减少同步阻塞：如果是Spring WebFlux环境，将方法改为返回Mono<Boolean>，用flatMap链式处理异步请求，避免block()阻塞线程，减少资源竞争。
• 增加日志排查：在每个请求前后添加日志，记录请求URL、参数、开始/结束时间、响应状态码，定位具体是哪个请求超时，以及是否有隐性错误响应。
• 临时调整超时时间：若确认是Klaviyo API偶尔延迟，可适当延长超时时间（如90秒），但这只是临时方案，核心还是要解决根本问题。

内容的提问来源于stack exchange，提问作者Amit Thelkar