feat: support proxy (#14)

Author: caojiajun

docs/others.md

@@ -119,4 +119,63 @@ public class Test6 {
     }
 }
 
+```
+
+
+### 关于代理
+
+* sdk初始化时支持设置代理
+* 可以使用Proxy，也可以使用ProxySelector
+
+```java
+
+public class Test6 {
+
+    public static void main(String[] args) {
+        String appkey = "xx";
+        String appsecret = "xx";
+        int timeoutMillis = 5000;
+
+        Proxy proxy = new Proxy(Proxy.Type.SOCKS, "10.0.0.0", 1080);
+
+        //
+        YunxinApiHttpClient client = new YunxinApiHttpClient.Builder(BizName.IM, appkey, appsecret)
+                .timeoutMillis(timeoutMillis)
+                .proxy(proxy)
+                .build();
+    }
+}
+
+```
+
+```java
+
+public class Test6 {
+
+    public static void main(String[] args) {
+        String appkey = "xx";
+        String appsecret = "xx";
+        int timeoutMillis = 5000;
+
+        ProxySelector proxySelector = new ProxySelector() {
+            @Override
+            public List<Proxy> select(URI uri) {
+                // your custom logic
+                return null;
+            }
+
+            @Override
+            public void connectFailed(URI uri, SocketAddress sa, IOException ioe) {
+                // your custom logic
+            }
+        };
+
+        //
+        YunxinApiHttpClient client = new YunxinApiHttpClient.Builder(BizName.IM, appkey, appsecret)
+                .timeoutMillis(timeoutMillis)
+                .proxySelector(proxySelector)
+                .build();
+    }
+}
+
 ```

src/main/java/com/netease/nim/server/sdk/core/YunxinApiHttpClient.java

@@ -11,6 +11,8 @@
 import com.netease.nim.server.sdk.core.metrics.MetricsCallback;
 import com.netease.nim.server.sdk.core.trace.ApiVersion;
 
+import java.net.Proxy;
+import java.net.ProxySelector;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
@@ -102,6 +104,22 @@ public Builder httpClientConfig(YunxinHttpClientConfig httpClientConfig) {
             return this;
         }
 
+        public Builder proxy(Proxy proxy) {
+            if (proxy == null) {
+                throw new IllegalArgumentException("proxy is null");
+            }
+            httpClientConfig.setProxy(proxy);
+            return this;
+        }
+
+        public Builder proxySelector(ProxySelector proxySelector) {
+            if (proxySelector == null) {
+                throw new IllegalArgumentException("proxySelector is null");
+            }
+            httpClientConfig.setProxySelector(proxySelector);
+            return this;
+        }
+
         public Builder metricEnable(boolean enable) {
             this.metricsConfig.setEnable(enable);
             return this;

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

@@ -62,13 +62,19 @@ public YunxinHttpClient(BizName bizName, String appkey, String appsecret, Endpoi
         Dispatcher dispatcher = new Dispatcher();
         dispatcher.setMaxRequests(httpClientConfig.getMaxRequests());
         dispatcher.setMaxRequestsPerHost(httpClientConfig.getMaxRequestsPerHost());
-        this.okHttpClient = new OkHttpClient.Builder()
+        OkHttpClient.Builder builder = new OkHttpClient.Builder()
                 .connectTimeout(httpClientConfig.getConnectTimeoutMillis(), TimeUnit.MILLISECONDS)
                 .readTimeout(httpClientConfig.getReadTimeoutMillis(), TimeUnit.MILLISECONDS)
                 .writeTimeout(httpClientConfig.getWriteTimeoutMillis(), TimeUnit.MILLISECONDS)
                 .dispatcher(dispatcher)
-                .connectionPool(new ConnectionPool(httpClientConfig.getMaxIdleConnections(), httpClientConfig.getKeepAliveSeconds(), TimeUnit.SECONDS))
-                .build();
+                .connectionPool(new ConnectionPool(httpClientConfig.getMaxIdleConnections(), httpClientConfig.getKeepAliveSeconds(), TimeUnit.SECONDS));
+        if (httpClientConfig.getProxy() != null) {
+            builder.proxy(httpClientConfig.getProxy());
+        }
+        if (httpClientConfig.getProxySelector() != null) {
+            builder.proxySelector(httpClientConfig.getProxySelector());
+        }
+        this.okHttpClient = builder.build();
         this.endpointSelector.init(okHttpClient);
     }
 

src/main/java/com/netease/nim/server/sdk/core/YunxinHttpClientConfig.java

@@ -1,6 +1,9 @@
 package com.netease.nim.server.sdk.core;
 
 
+import java.net.Proxy;
+import java.net.ProxySelector;
+
 /**
  * Created by caojiajun on 2024/11/27
  */
@@ -13,6 +16,8 @@ public class YunxinHttpClientConfig {
     private int maxRequestsPerHost = Constants.Http.maxRequestsPerHost;
     private int keepAliveSeconds = Constants.Http.keepAliveSeconds;
     private int maxIdleConnections = Constants.Http.maxIdleConnections;
+    private Proxy proxy;
+    private ProxySelector proxySelector;
 
     public long getConnectTimeoutMillis() {
         return connectTimeoutMillis;
@@ -69,4 +74,20 @@ public int getMaxIdleConnections() {
     public void setMaxIdleConnections(int maxIdleConnections) {
         this.maxIdleConnections = maxIdleConnections;
     }
+
+    public Proxy getProxy() {
+        return proxy;
+    }
+
+    public void setProxy(Proxy proxy) {
+        this.proxy = proxy;
+    }
+
+    public ProxySelector getProxySelector() {
+        return proxySelector;
+    }
+
+    public void setProxySelector(ProxySelector proxySelector) {
+        this.proxySelector = proxySelector;
+    }
 }