yexuejc007/wechat4j
2
0
Fork 0
mirror of https://gitee.com/hotlcc/wechat4j.git synced 2025-06-08 11:34:07 +08:00
Code Issues Releases Wiki Activity

提交代码

Browse Source
This commit is contained in:
Allen 2018-08-17 21:47:32 +08:00
parent 088eb6d162
commit c95cca27d5
2 changed files with 2 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/main/java/com/hotlcc/wechat4j/Wechat.java
View File

@ -14,13 +14,10 @@ import com.hotlcc.wechat4j.util.*;
import org.apache.http.HttpException; import org.apache.http.HttpException;
import org.apache.http.HttpRequest; import org.apache.http.HttpRequest;
import org.apache.http.HttpRequestInterceptor; import org.apache.http.HttpRequestInterceptor;
import org.apache.http.HttpResponse;
import org.apache.http.client.CookieStore; import org.apache.http.client.CookieStore;
import org.apache.http.client.HttpClient; import org.apache.http.client.HttpClient;
import org.apache.http.conn.ConnectionKeepAliveStrategy;
import org.apache.http.cookie.Cookie; import org.apache.http.cookie.Cookie;
import org.apache.http.impl.client.BasicCookieStore; import org.apache.http.impl.client.BasicCookieStore;
import org.apache.http.impl.client.DefaultConnectionKeepAliveStrategy;
import org.apache.http.impl.client.HttpClients; import org.apache.http.impl.client.HttpClients;
import org.apache.http.protocol.HttpContext; import org.apache.http.protocol.HttpContext;
import org.slf4j.Logger; import org.slf4j.Logger;
@ -154,17 +151,6 @@ public class Wechat {
} }
private HttpClient buildHttpClient(CookieStore cookieStore) { private HttpClient buildHttpClient(CookieStore cookieStore) {
ConnectionKeepAliveStrategy keepAliveStrategy = new DefaultConnectionKeepAliveStrategy() {
@Override
public long getKeepAliveDuration(HttpResponse response, HttpContext context) {
long keepAlive = super.getKeepAliveDuration(response, context);
if (keepAlive == -1) {
//如果服务器没有设置keep-alive这个参数，我们就把它设置成1分钟
keepAlive = 60000;
}
return keepAlive;
}
};
HttpRequestInterceptor interceptor = new HttpRequestInterceptor() { HttpRequestInterceptor interceptor = new HttpRequestInterceptor() {
@Override @Override
public void process(HttpRequest httpRequest, HttpContext httpContext) throws HttpException, IOException { public void process(HttpRequest httpRequest, HttpContext httpContext) throws HttpException, IOException {
@ -173,7 +159,6 @@ public class Wechat {
}; };
HttpClient httpClient = HttpClients.custom() HttpClient httpClient = HttpClients.custom()
.setDefaultCookieStore(cookieStore) .setDefaultCookieStore(cookieStore)
// .setKeepAliveStrategy(keepAliveStrategy)
.addInterceptorFirst(interceptor) .addInterceptorFirst(interceptor)
.build(); .build();
return httpClient; return httpClient;
@ -641,7 +626,7 @@ public class Wechat {
try { try {
JSONObject result = webWeixinApi.syncCheck(httpClient, urlVersion, new BaseRequest(wxsid, skey, wxuin), getSyncKeyList(false)); JSONObject result = webWeixinApi.syncCheck(httpClient, urlVersion, new BaseRequest(wxsid, skey, wxuin), getSyncKeyList(false));
logger.debug("微信同步监听心跳返回数据：{}", result); logger.info("微信同步监听心跳返回数据：{}", result);
if (result == null) { if (result == null) {
throw new RuntimeException("微信API调用异常"); throw new RuntimeException("微信API调用异常");
} else { } else {

1
src/main/java/com/hotlcc/wechat4j/api/WebWeixinApi.java
View File

@ -409,6 +409,7 @@ public class WebWeixinApi {
.setRedirectsEnabled(false) .setRedirectsEnabled(false)
.build(); .build();
httpGet.setConfig(config); httpGet.setConfig(config);
httpGet.addHeader("Connection", "Keep-Alive");
HttpResponse response = httpClient.execute(httpGet); HttpResponse response = httpClient.execute(httpGet);
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();