[update]

  1. sdk支持设置长连接有效期

Author: liuyj

README.md

@@ -22,7 +22,7 @@
     <dependency>
         <groupId>com.getui.push</groupId>
         <artifactId>restful-sdk</artifactId>
-        <version>1.0.0.3</version>
+        <version>1.0.0.4</version>
     </dependency>
 ```
 

pom.xml

@@ -7,7 +7,7 @@
     <groupId>com.getui.push</groupId>
     <artifactId>restful-sdk</artifactId>
     <packaging>jar</packaging>
-    <version>1.0.0.3</version>
+    <version>1.0.0.4</version>
     <url>https://github.com/GetuiLaboratory/getui-pushapi-java-client-v2</url>
     <name>Getui Push API Java Client</name>
     <description>Getui's officially supported Java client library for accessing Getui APIs.</description>

src/main/java/com/getui/push/v2/sdk/GtApiConfiguration.java

@@ -65,6 +65,10 @@ public class GtApiConfiguration {
      * http请求失败，最大尝试次数
      */
     private int maxHttpTryTime = 1;
+    /**
+     * 保持长连接的时长，默认10分钟
+     */
+    private long keepAliveMinutes = 10;
 
     /**
      * http请求时是否需要信任https
@@ -183,6 +187,14 @@ public void setMaxHttpTryTime(int maxHttpTryTime) {
         this.maxHttpTryTime = maxHttpTryTime;
     }
 
+    public long getKeepAliveMinutes() {
+        return keepAliveMinutes;
+    }
+
+    public void setKeepAliveMinutes(long keepAliveMinutes) {
+        this.keepAliveMinutes = keepAliveMinutes;
+    }
+
     public GtHttpProxyConfig getProxyConfig() {
         return proxyConfig;
     }

src/main/java/com/getui/push/v2/sdk/common/http/GtHttpClient.java

@@ -30,12 +30,13 @@
 import java.security.cert.CertificateException;
 import java.security.cert.X509Certificate;
 import java.util.Map;
+import java.util.concurrent.TimeUnit;
 
 public class GtHttpClient {
     private int maxHttpTryTime;
     CloseableHttpClient httpclient;
 
-    public GtHttpClient(int connectTimeout, int soTimeout, int maxHttpTryTime, GtHttpProxyConfig proxyConfig, boolean trustSSL) {
+    public GtHttpClient(int connectTimeout, int soTimeout, int maxHttpTryTime, long keepAliveMinutes, GtHttpProxyConfig proxyConfig, boolean trustSSL) {
         if (connectTimeout <= 0) {
             throw new IllegalArgumentException("connectTimeout must be > 0.");
         }
@@ -63,7 +64,9 @@ public GtHttpClient(int connectTimeout, int soTimeout, int maxHttpTryTime, GtHtt
                 .setSocketTimeout(soTimeout)
                 .setMaxRedirects(0)
                 .build();
-        builder.setDefaultRequestConfig(config).useSystemProperties();
+        builder.setDefaultRequestConfig(config)
+                .setConnectionTimeToLive(keepAliveMinutes, TimeUnit.MINUTES)
+                .useSystemProperties();
         this.httpclient = builder.build();
     }
 

src/main/java/com/getui/push/v2/sdk/common/http/HttpManager.java

@@ -21,8 +21,8 @@ public class HttpManager {
      * @param maxHttpTryTime    失败最大尝试次数
      * @param trustSSL
      */
-    public HttpManager(int connectionTimeOut, int readTimeout, int maxHttpTryTime, GtHttpProxyConfig proxyConfig, boolean trustSSL) {
-        this.client = new GtHttpClient(connectionTimeOut, readTimeout, maxHttpTryTime, proxyConfig, trustSSL);
+    public HttpManager(int connectionTimeOut, int readTimeout, int maxHttpTryTime, long keepAliveMinutes, GtHttpProxyConfig proxyConfig, boolean trustSSL) {
+        this.client = new GtHttpClient(connectionTimeOut, readTimeout, maxHttpTryTime, keepAliveMinutes, proxyConfig, trustSSL);
     }
 
     public String syncHttps(String url, String method, Map<String, Object> headers, String body, String contentType) {

src/main/java/com/getui/push/v2/sdk/core/client/DefaultApiClient.java

@@ -131,7 +131,8 @@ private DefaultApiClient(GtApiConfiguration apiConfiguration, IJson json) {
 
         this.httpManager = new HttpManager(apiConfiguration.getConnectTimeout(),
                 apiConfiguration.getSoTimeout(), apiConfiguration.getMaxHttpTryTime(),
-                apiConfiguration.getProxyConfig(), apiConfiguration.isTrustSSL());
+                apiConfiguration.getKeepAliveMinutes(), apiConfiguration.getProxyConfig(),
+                apiConfiguration.isTrustSSL());
 
         this.hostManager = new HostManager(apiConfiguration, this.httpManager);
         // 分析最稳定域名