九州仙境 v3.0.0版本的 MD5 值为：7b5ce5daab0f4a38a386ae4309157477
以下内容为反编译后的 q.java 源代码，内容仅作参考
package com.alipay.android.phone.mrpc.core;
import android.content.Context;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.net.Proxy;
import android.text.TextUtils;
import android.webkit.CookieManager;
import android.webkit.CookieSyncManager;
import com.wechat.pay.java.core.http.Constant;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.SocketTimeoutException;
import java.net.URI;
import java.net.URISyntaxException;
import java.net.URL;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.Callable;
import javax.net.ssl.SSLException;
import javax.net.ssl.SSLHandshakeException;
import javax.net.ssl.SSLPeerUnverifiedException;
import org.apache.http.Header;
import org.apache.http.HttpEntity;
import org.apache.http.HttpHost;
import org.apache.http.HttpRequest;
import org.apache.http.HttpResponse;
import org.apache.http.NoHttpResponseException;
import org.apache.http.client.CookieStore;
import org.apache.http.client.HttpRequestRetryHandler;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpUriRequest;
import org.apache.http.conn.ConnectTimeoutException;
import org.apache.http.conn.ConnectionPoolTimeoutException;
import org.apache.http.conn.HttpHostConnectException;
import org.apache.http.cookie.Cookie;
import org.apache.http.entity.AbstractHttpEntity;
import org.apache.http.entity.ByteArrayEntity;
import org.apache.http.impl.client.BasicCookieStore;
import org.apache.http.params.HttpParams;
import org.apache.http.protocol.BasicHttpContext;
import org.apache.http.protocol.HttpContext;
public final class q implements Callable<u> {
public static final HttpRequestRetryHandler e = new ad();
public l a;
public Context b;
public o c;
public String d;
public HttpUriRequest f;
public CookieManager i;
public AbstractHttpEntity j;
public HttpHost k;
public URL l;
public String q;
public HttpContext g = new BasicHttpContext();
public CookieStore h = new BasicCookieStore();
public int m = 0;
public boolean n = false;
public boolean o = false;
public String p = null;
public q(l lVar, o oVar) {
this.a = lVar;
this.b = lVar.a;
this.c = oVar;
}
public static long a(String[] strArr) {
for (int i = 0; i < strArr.length; i++) {
if ("max-age".equalsIgnoreCase(strArr[i])) {
int i2 = i + 1;
if (strArr[i2] != null) {
try {
return Long.parseLong(strArr[i2]);
} catch (Exception unused) {
continue;
}
} else {
continue;
}
}
}
return 0L;
}
public static HttpUrlHeader a(HttpResponse httpResponse) {
Header[] allHeaders;
HttpUrlHeader httpUrlHeader = new HttpUrlHeader();
for (Header header : httpResponse.getAllHeaders()) {
httpUrlHeader.setHead(header.getName(), header.getValue());
}
return httpUrlHeader;
}
private u a(HttpResponse httpResponse, int i, String str) {
String str2;
new StringBuilder("开始handle，handleResponse-1,").append(Thread.currentThread().getId());
HttpEntity entity = httpResponse.getEntity();
ByteArrayOutputStream byteArrayOutputStream = null;
String str3 = null;
if (entity == null || httpResponse.getStatusLine().getStatusCode() != 200) {
if (entity == null) {
httpResponse.getStatusLine().getStatusCode();
return null;
}
return null;
}
new StringBuilder("200，开始处理，handleResponse-2,threadid = ").append(Thread.currentThread().getId());
try {
ByteArrayOutputStream byteArrayOutputStream2 = new ByteArrayOutputStream();
try {
long currentTimeMillis = System.currentTimeMillis();
a(entity, byteArrayOutputStream2);
byte[] byteArray = byteArrayOutputStream2.toByteArray();
this.o = false;
this.a.c(System.currentTimeMillis() - currentTimeMillis);
this.a.a(byteArray.length);
new StringBuilder("res:").append(byteArray.length);
p pVar = new p(a(httpResponse), i, str, byteArray);
long b = b(httpResponse);
Header contentType = httpResponse.getEntity().getContentType();
if (contentType != null) {
HashMap<String, String> a = a(contentType.getValue());
str3 = a.get("charset");
str2 = a.get(Constant.CONTENT_TYPE);
} else {
str2 = null;
}
pVar.b(str2);
pVar.a(str3);
pVar.a(System.currentTimeMillis());
pVar.b(b);
try {
byteArrayOutputStream2.close();
return pVar;
} catch (IOException e2) {
throw new RuntimeException("ArrayOutputStream close error!", e2.getCause());
}
} catch (Throwable th) {
th = th;
byteArrayOutputStream = byteArrayOutputStream2;
if (byteArrayOutputStream != null) {
try {
byteArrayOutputStream.close();
} catch (IOException e3) {
throw new RuntimeException("ArrayOutputStream close error!", e3.getCause());
}
}
throw th;
}
} catch (Throwable th2) {
th = th2;
}
}
public static HashMap<String, String> a(String str) {
String[] split;
HashMap<String, String> hashMap = new HashMap<>();
for (String str2 : str.split(com.alipay.sdk.m.u.i.b)) {
String[] split2 = str2.indexOf(61) == -1 ? new String[]{Constant.CONTENT_TYPE, str2} : str2.split("=");
hashMap.put(split2[0], split2[1]);
}
return hashMap;
}
private void a(HttpEntity httpEntity, OutputStream outputStream) {
InputStream a = b.a(httpEntity);
httpEntity.getContentLength();
try {
try {
byte[] bArr = new byte[2048];
while (true) {
int read = a.read(bArr);
if (read == -1 || this.c.h()) {
break;
}
outputStream.write(bArr, 0, read);
this.c.f();
}
outputStream.flush();
} catch (Exception e2) {
e2.getCause();
throw new IOException("HttpWorker Request Error!" + e2.getLocalizedMessage());
}
} finally {
r.a(a);
}
}
public static long b(HttpResponse httpResponse) {
Header firstHeader = httpResponse.getFirstHeader("Cache-Control");
if (firstHeader != null) {
String[] split = firstHeader.getValue().split("=");
if (split.length >= 2) {
try {
return a(split);
} catch (NumberFormatException unused) {
}
}
}
Header firstHeader2 = httpResponse.getFirstHeader("Expires");
if (firstHeader2 != null) {
return b.b(firstHeader2.getValue()) - System.currentTimeMillis();
}
return 0L;
}
private URI b() {
String a = this.c.a();
String str = this.d;
if (str != null) {
a = str;
}
if (a != null) {
return new URI(a);
}
throw new RuntimeException("url should not be null");
}
private HttpUriRequest c() {
HttpUriRequest httpUriRequest = this.f;
if (httpUriRequest != null) {
return httpUriRequest;
}
if (this.j == null) {
byte[] b = this.c.b();
String b2 = this.c.b("gzip");
if (b != null) {
if (TextUtils.equals(b2, "true")) {
this.j = b.a(b);
} else {
this.j = new ByteArrayEntity(b);
}
this.j.setContentType(this.c.c());
}
}
AbstractHttpEntity abstractHttpEntity = this.j;
if (abstractHttpEntity != null) {
HttpPost httpPost = new HttpPost(b());
httpPost.setEntity(abstractHttpEntity);
this.f = httpPost;
} else {
this.f = new HttpGet(b());
}
return this.f;
}
@Override
public u call() {
boolean z;
HttpHost httpHost;
HttpHost httpHost2;
List<Cookie> cookies;
int statusCode;
u a;
String a2;
while (true) {
try {
NetworkInfo[] allNetworkInfo = ((ConnectivityManager) this.b.getSystemService("connectivity")).getAllNetworkInfo();
boolean z2 = true;
if (allNetworkInfo != null) {
for (NetworkInfo networkInfo : allNetworkInfo) {
if (networkInfo != null && networkInfo.isAvailable() && networkInfo.isConnectedOrConnecting()) {
z = true;
break;
}
}
}
z = false;
if (z) {
ArrayList<Header> d = this.c.d();
if (d != null && !d.isEmpty()) {
Iterator<Header> it = d.iterator();
while (it.hasNext()) {
c().addHeader(it.next());
}
}
b.a((HttpRequest) c());
b.b((HttpRequest) c());
c().addHeader("cookie", i().getCookie(this.c.a()));
this.g.setAttribute("http.cookie-store", this.h);
this.a.a().a(e);
long currentTimeMillis = System.currentTimeMillis();
StringBuilder sb = new StringBuilder("By Http/Https to request. operationType=");
sb.append(f());
sb.append(" url=");
sb.append(this.f.getURI().toString());
HttpParams params = this.a.a().getParams();
NetworkInfo activeNetworkInfo = ((ConnectivityManager) this.b.getSystemService("connectivity")).getActiveNetworkInfo();
HttpHost httpHost3 = null;
if (activeNetworkInfo != null && activeNetworkInfo.isAvailable()) {
String defaultHost = Proxy.getDefaultHost();
int defaultPort = Proxy.getDefaultPort();
if (defaultHost != null) {
httpHost = new HttpHost(defaultHost, defaultPort);
if (httpHost != null || !TextUtils.equals(httpHost.getHostName(), "127.0.0.1") || httpHost.getPort() != 8087) {
httpHost3 = httpHost;
}
params.setParameter("http.route.default-proxy", httpHost3);
if (this.k == null) {
httpHost2 = this.k;
} else {
URL h = h();
HttpHost httpHost4 = new HttpHost(h.getHost(), g(), h.getProtocol());
this.k = httpHost4;
httpHost2 = httpHost4;
}
if (g() == 80) {
httpHost2 = new HttpHost(h().getHost());
}
HttpResponse execute = this.a.a().execute(httpHost2, (HttpRequest) this.f, this.g);
this.a.b(System.currentTimeMillis() - currentTimeMillis);
cookies = this.h.getCookies();
if (this.c.e()) {
i().removeAllCookie();
}
if (!cookies.isEmpty()) {
for (Cookie cookie : cookies) {
if (cookie.getDomain() != null) {
StringBuilder sb2 = new StringBuilder();
sb2.append(cookie.getName());
sb2.append("=");
sb2.append(cookie.getValue());
sb2.append("; domain=");
sb2.append(cookie.getDomain());
sb2.append(cookie.isSecure() ? "; Secure" : "");
i().setCookie(this.c.a(), sb2.toString());
CookieSyncManager.getInstance().sync();
}
}
}
statusCode = execute.getStatusLine().getStatusCode();
String reasonPhrase = execute.getStatusLine().getReasonPhrase();
if (statusCode != 200) {
if (statusCode != 304) {
z2 = false;
}
if (!z2) {
throw new HttpException(Integer.valueOf(execute.getStatusLine().getStatusCode()), execute.getStatusLine().getReasonPhrase());
}
}
a = a(execute, statusCode, reasonPhrase);
if (((a != null || a.b() == null) ? -1L : a.b().length) == -1 && (a instanceof p)) {
try {
Long.parseLong(((p) a).a().getHead("Content-Length"));
} catch (Exception unused) {
}
}
a2 = this.c.a();
if (a2 != null && !TextUtils.isEmpty(f())) {
StringBuilder sb3 = new StringBuilder();
sb3.append(a2);
sb3.append("#");
sb3.append(f());
}
return a;
}
}
httpHost = null;
if (httpHost != null) {
}
httpHost3 = httpHost;
params.setParameter("http.route.default-proxy", httpHost3);
if (this.k == null) {
}
if (g() == 80) {
}
HttpResponse execute2 = this.a.a().execute(httpHost2, (HttpRequest) this.f, this.g);
this.a.b(System.currentTimeMillis() - currentTimeMillis);
cookies = this.h.getCookies();
if (this.c.e()) {
}
if (!cookies.isEmpty()) {
}
statusCode = execute2.getStatusLine().getStatusCode();
String reasonPhrase2 = execute2.getStatusLine().getReasonPhrase();
if (statusCode != 200) {
}
a = a(execute2, statusCode, reasonPhrase2);
if (((a != null || a.b() == null) ? -1L : a.b().length) == -1) {
Long.parseLong(((p) a).a().getHead("Content-Length"));
}
a2 = this.c.a();
if (a2 != null) {
StringBuilder sb32 = new StringBuilder();
sb32.append(a2);
sb32.append("#");
sb32.append(f());
}
return a;
}
throw new HttpException(1, "The network is not available");
} catch (HttpException e2) {
e();
if (this.c.f() != null) {
e2.getCode();
e2.getMsg();
}
new StringBuilder().append(e2);
throw e2;
} catch (NullPointerException e3) {
e();
int i = this.m;
if (i > 0) {
new StringBuilder().append(e3);
throw new HttpException(0, String.valueOf(e3));
}
this.m = i + 1;
} catch (SocketTimeoutException e4) {
e();
if (this.c.f() != null) {
new StringBuilder().append(e4);
}
new StringBuilder().append(e4);
throw new HttpException(4, String.valueOf(e4));
} catch (URISyntaxException e5) {
throw new RuntimeException("Url parser error!", e5.getCause());
} catch (UnknownHostException e6) {
e();
if (this.c.f() != null) {
new StringBuilder().append(e6);
}
new StringBuilder().append(e6);
throw new HttpException(9, String.valueOf(e6));
} catch (SSLHandshakeException e7) {
e();
if (this.c.f() != null) {
new StringBuilder().append(e7);
}
new StringBuilder().append(e7);
throw new HttpException(2, String.valueOf(e7));
} catch (SSLException e8) {
e();
if (this.c.f() != null) {
new StringBuilder().append(e8);
}
new StringBuilder().append(e8);
throw new HttpException(6, String.valueOf(e8));
} catch (ConnectTimeoutException e9) {
e();
if (this.c.f() != null) {
new StringBuilder().append(e9);
}
new StringBuilder().append(e9);
throw new HttpException(3, String.valueOf(e9));
} catch (Exception e10) {
e();
if (this.c.f() != null) {
new StringBuilder().append(e10);
}
throw new HttpException(0, String.valueOf(e10));
} catch (HttpHostConnectException e11) {
e();
if (this.c.f() != null) {
new StringBuilder().append(e11);
}
throw new HttpException(8, String.valueOf(e11));
} catch (ConnectionPoolTimeoutException e12) {
e();
if (this.c.f() != null) {
new StringBuilder().append(e12);
}
new StringBuilder().append(e12);
throw new HttpException(3, String.valueOf(e12));
} catch (SSLPeerUnverifiedException e13) {
e();
if (this.c.f() != null) {
new StringBuilder().append(e13);
}
new StringBuilder().append(e13);
throw new HttpException(2, String.valueOf(e13));
} catch (IOException e14) {
e();
if (this.c.f() != null) {
new StringBuilder().append(e14);
}
new StringBuilder().append(e14);
throw new HttpException(6, String.valueOf(e14));
} catch (NoHttpResponseException e15) {
e();
if (this.c.f() != null) {
new StringBuilder().append(e15);
}
new StringBuilder().append(e15);
throw new HttpException(5, String.valueOf(e15));
}
}
}
private void e() {
HttpUriRequest httpUriRequest = this.f;
if (httpUriRequest != null) {
httpUriRequest.abort();
}
}
private String f() {
if (TextUtils.isEmpty(this.q)) {
String b = this.c.b("operationType");
this.q = b;
return b;
}
return this.q;
}
private int g() {
URL h = h();
return h.getPort() == -1 ? h.getDefaultPort() : h.getPort();
}
private URL h() {
URL url = this.l;
if (url != null) {
return url;
}
URL url2 = new URL(this.c.a());
this.l = url2;
return url2;
}
private CookieManager i() {
CookieManager cookieManager = this.i;
if (cookieManager != null) {
return cookieManager;
}
CookieManager cookieManager2 = CookieManager.getInstance();
this.i = cookieManager2;
return cookieManager2;
}
public final o a() {
return this.c;
}
}