feat: support set timeout before call api

Author: caojiajun

src/main/java/com/netease/nim/im/server/sdk/core/YunxinHttpClient.java

@@ -11,6 +11,7 @@
 import com.netease.nim.im.server.sdk.core.metrics.Stats;
 import com.netease.nim.im.server.sdk.core.metrics.YunxinApiSdkMetricsCollector;
 import com.netease.nim.im.server.sdk.core.trace.ApiVersion;
+import com.netease.nim.im.server.sdk.core.trace.TimeoutSetter;
 import com.netease.nim.im.server.sdk.core.trace.YunxinTraceId;
 import com.netease.nim.im.server.sdk.core.trace.TraceIdUtils;
 import com.netease.nim.im.server.sdk.core.utils.CheckSumBuilder;
@@ -99,6 +100,9 @@ public HttpResponse execute(HttpMethod method, ContextType contextType, ApiVersi
             if (maxRetry > 128) {
                 maxRetry = 128;
             }
+            Long timeoutMillis = TimeoutSetter.getAndClear();
+            OkHttpClient client = client(timeoutMillis);
+
             for (int i=0; i<=maxRetry; i++) {
                 //request
                 Request.Builder builder = new Request.Builder();
@@ -118,7 +122,7 @@ public HttpResponse execute(HttpMethod method, ContextType contextType, ApiVersi
                     logger.debug("execute, endpoint = {}, method = {}, contextType = {}, apiVersion= {}, uri = {}, traceId = {}",
                             endpoint, method, contextType, apiVersion, uri, traceId);
                 }
-                try (Response response = okHttpClient.newCall(request).execute()) {
+                try (Response response = client.newCall(request).execute()) {
                     int code = response.code();
                     String string = response.body().string();
                     if (code != 200) {
@@ -185,6 +189,17 @@ public HttpResponse execute(HttpMethod method, ContextType contextType, ApiVersi
         }
     }
 
+    private OkHttpClient client(Long timeoutMillis) {
+        if (timeoutMillis == null) {
+            return okHttpClient;
+        }
+        return okHttpClient.newBuilder()
+                .connectTimeout(timeoutMillis, TimeUnit.MILLISECONDS)
+                .readTimeout(timeoutMillis, TimeUnit.MILLISECONDS)
+                .writeTimeout(timeoutMillis, TimeUnit.MILLISECONDS)
+                .build();
+    }
+
     @Override
     public Stats getStats() {
         if (metricsCollector == null) {

src/main/java/com/netease/nim/im/server/sdk/core/trace/TimeoutSetter.java

@@ -0,0 +1,21 @@
+package com.netease.nim.im.server.sdk.core.trace;
+
+
+/**
+ * Created by caojiajun on 2025/2/10
+ */
+public class TimeoutSetter {
+
+    private static final ThreadLocal<Long> timeout = new ThreadLocal<>();
+
+    public static Long getAndClear() {
+        Long timeoutMillis = timeout.get();
+        timeout.remove();
+        return timeoutMillis;
+    }
+
+    public static void setTimeout(long timeoutMillis) {
+        timeout.set(timeoutMillis);
+    }
+
+}

src/main/java/com/netease/nim/im/server/sdk/core/version/YunxinApiSdkVersion.java

@@ -5,5 +5,5 @@
  */
 public class YunxinApiSdkVersion {
 
-    public static final String version = "0.1.0";
+    public static final String version = "0.2.0-SNAPSHOT";
 }