🍭 v1.8.0版本的 MD5 值为：0229079aa4aa60e49c57f3c4c415ae2e
以下内容为反编译后的 NetworkConfig.java 源代码，内容仅作参考
package im.pkahdfyclb.tgnet;
import android.text.TextUtils;
import com.alibaba.fastjson.JSONObject;
import com.aliyun.security.yunceng.android.sdk.YunCeng;
import com.google.android.exoplayer2.util.Log;
import com.google.gson.Gson;
import com.king.zxing.util.LogUtils;
import com.qiniu.android.dns.DnsManager;
import com.qiniu.android.dns.IResolver;
import com.qiniu.android.dns.NetworkInfo;
import com.qiniu.android.dns.Record;
import com.qiniu.android.dns.dns.DohResolver;
import im.pkahdfyclb.messenger.AndroidUtilities;
import im.pkahdfyclb.messenger.BuildVars;
import im.pkahdfyclb.messenger.FileLog;
import im.pkahdfyclb.messenger.NotificationCenter;
import im.pkahdfyclb.messenger.UserConfig;
import im.pkahdfyclb.ui.utils.AesUtils;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.ArrayList;
import java.util.Arrays;
public class NetworkConfig {
private static final int ENV_LOCAL = 1000;
private static final int ENV_LOCAL_TEST = 1001;
private static final int ENV_NONE = 0;
private static final int ENV_ONLINE = 1002;
private static final int ENV_ONLINE_GREY = 1004;
private static final int ENV_ONLINE_TEST = 1003;
private DnsManager dnsManager;
private boolean inited;
private boolean inited_doh;
private boolean initing;
private boolean initing_doh;
public static final String[] IP_DEFALUT_ONLINE = {"119.91.42.93", "30509"};
public static final String[] HOST = {"https://8.212.58.93/dns-query", "https://8.212.58.238/dns-query"};
public static ArrayList<Record> recordsArray = new ArrayList<>();
private static volatile NetworkConfig sInstance = new NetworkConfig();
private String dohDomain = "cn.bw509.com";
private ArrayList<NetBean> connInfos = new ArrayList<>();
private int sCurrentConnection = -1;
protected int currentAccount = UserConfig.selectedAccount;
private boolean start = true;
@Retention(RetentionPolicy.SOURCE)
private @interface EnvNode {
}
public static NetworkConfig getInstance() {
NetworkConfig localInstance = sInstance;
if (localInstance == null) {
synchronized (NetworkConfig.class) {
localInstance = sInstance;
if (localInstance == null) {
NetworkConfig networkConfig = new NetworkConfig();
localInstance = networkConfig;
sInstance = networkConfig;
}
}
}
return localInstance;
}
public static void setIpPortDefaultAddress() {
String[] cfg;
if (BuildVars.RELEASE_VERSION) {
cfg = IP_DEFALUT_ONLINE;
} else {
cfg = getInstance().initNetconfig(1001);
}
if (BuildVars.DEBUG_VERSION) {
StringBuilder sb = new StringBuilder();
sb.append("java NetWorkConfig setIpPortDefaultAddress ===> address = ");
sb.append(cfg != null ? Arrays.toString(cfg) : "null");
Log.i("connection", sb.toString());
}
if (cfg != null && cfg[0] != null && cfg[1] != null) {
for (int a = 0; a < 3; a++) {
ConnectionsManager.native_setIpPortDefaultAddress(a, cfg[0], Integer.parseInt(cfg[1]));
}
}
}
private NetworkConfig() {
}
public void applyNetconfig(int instance) {
String[] cfg;
if (BuildVars.RELEASE_VERSION) {
cfg = initNetconfig(1002);
} else {
cfg = initNetconfig(1002);
}
if (BuildVars.DEBUG_VERSION) {
StringBuilder sb = new StringBuilder();
sb.append("java NetWorkConfig applyNetconfig ===> address = ");
sb.append(cfg != null ? Arrays.toString(cfg) : "null");
Log.i("connection", sb.toString());
}
if (cfg != null && cfg[0] != null && cfg[1] != null) {
ConnectionsManager.getInstance(instance).applyDatacenterAddress(2, cfg[0], Integer.parseInt(cfg[1]));
ConnectionsManager.getInstance(instance).resumeNetworkMaybe();
}
}
public void initUrlDOH() {
this.initing_doh = true;
try {
try {
IResolver[] resolvers = {new DohResolver(HOST[0]), new DohResolver(HOST[1])};
DnsManager dnsManager = new DnsManager(NetworkInfo.normal, resolvers);
this.dnsManager = dnsManager;
Record[] records = dnsManager.queryRecords(this.dohDomain);
String recordsStr = JSONObject.toJSONString(records);
LogUtils.e("doh获取成功====" + recordsStr);
if (records != null && records.length > 0) {
for (Record record : records) {
String ipAddress = record.value;
NetBean netBean = new NetBean(null, ipAddress, IP_DEFALUT_ONLINE[1]);
this.connInfos.add(netBean);
}
}
this.inited_doh = true;
this.sCurrentConnection = -1;
setServer2();
} catch (IOException e) {
e.printStackTrace();
}
} finally {
this.initing_doh = false;
}
}
private void setServer2() {
AndroidUtilities.runOnUIThread(new Runnable() {
@Override
public final void run() {
NetworkConfig.this.lambda$setServer2$0$NetworkConfig();
}
});
}
public void lambda$setServer2$0$NetworkConfig() {
String server2 = "server 2";
if (this.inited) {
server2 = "oss+server 2";
}
if (this.inited_doh) {
server2 = "doh+" + server2;
}
NotificationCenter.getInstance(this.currentAccount).postNotificationName(NotificationCenter.getBackupIpStatus, server2);
}
private String[] initNetconfig(int node) {
if (this.start) {
this.start = false;
AndroidUtilities.runOnUIThread(new Runnable() {
@Override
public final void run() {
NetworkConfig.this.lambda$initNetconfig$1$NetworkConfig();
}
});
}
switch (node) {
case 1000:
return new String[]{"47.104.243.76", "31537"};
case 1001:
return new String[]{"192.168.1.184", "31443"};
case 1002:
String[] address = initRemoteNetconfig();
if (address == null || address.length != 2 || TextUtils.isEmpty(address[0]) || TextUtils.isEmpty(address[1])) {
return IP_DEFALUT_ONLINE;
}
return address;
case 1003:
return new String[]{"183.230.11.65", "55555"};
case 1004:
return new String[]{"36.255.220.245", "31443"};
default:
return null;
}
}
public void lambda$initNetconfig$1$NetworkConfig() {
NotificationCenter.getInstance(this.currentAccount).postNotificationName(NotificationCenter.getBackupIpStatus, "server 1");
}
private String[] initRemoteNetconfig() {
if (!this.inited_doh && !this.initing_doh) {
initUrlDOH();
}
if (this.inited) {
return selecteRemoteConnInfo();
}
if (this.initing) {
return null;
}
initRemoteConnInfos();
return selecteRemoteConnInfo();
}
private synchronized String[] selecteRemoteConnInfo() {
if (this.connInfos.size() == 0) {
return null;
}
if (this.sCurrentConnection == -1) {
this.sCurrentConnection = 0;
}
System.out.println("连接地址表：" + new Gson().toJson(this.connInfos));
NetBean netBean = this.connInfos.get(this.sCurrentConnection);
if (this.sCurrentConnection != this.connInfos.size() - 1) {
this.sCurrentConnection++;
return new String[]{netBean.getdDomain(), netBean.getdPort()};
}
this.sCurrentConnection = -1;
this.connInfos = new ArrayList<>();
this.inited = false;
this.inited_doh = false;
return null;
}
private synchronized void initRemoteConnInfos() {
IOException iOException;
InputStream httpConnectionStream;
ByteArrayOutputStream bos;
int i = 1;
this.initing = true;
InputStream httpConnectionStream2 = null;
ByteArrayOutputStream bos2 = null;
char c = 0;
try {
URL url = new URL("https://asjias509.oss-accelerate.aliyuncs.com/basjncdasjkc.txt");
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.addRequestProperty("User-Agent", "Mozilla/5.0 (iPhone; CPU iPhone OS 10_0 like Mac OS X) AppleWebKit/602.1.38 (KHTML, like Gecko) Version/10.0 Mobile/14A5297c Safari/602.1");
conn.setRequestMethod("GET");
conn.setReadTimeout(5000);
conn.setConnectTimeout(5000);
conn.connect();
if (conn.getResponseCode() == 200) {
try {
httpConnectionStream2 = conn.getInputStream();
try {
byte[] bytes = new byte[1024];
bos2 = new ByteArrayOutputStream();
while (true) {
try {
int len = httpConnectionStream2.read(bytes);
if (len == -1) {
break;
} else {
bos2.write(bytes, 0, len);
}
} catch (Throwable th) {
e = th;
}
}
String txt = new String(bos2.toByteArray());
byte[] rets = AesUtils.decryptYunceng(txt);
String retStr = new String(rets);
LogUtils.e("oss获取成功====" + retStr);
String[] arrConn = retStr.split(",", 3);
int i2 = 0;
while (i2 < arrConn.length) {
String connInfo = arrConn[i2];
if (i2 != arrConn.length - i) {
String[] split = connInfo.split(LogUtils.COLON, 2);
httpConnectionStream = httpConnectionStream2;
try {
NetBean netBean = new NetBean(null, split[c], split[1]);
this.connInfos.add(netBean);
bos = bos2;
} catch (Throwable th2) {
e = th2;
httpConnectionStream2 = httpConnectionStream;
try {
FileLog.e(e);
this.initing = false;
if (httpConnectionStream2 != null) {
try {
httpConnectionStream2.close();
} catch (Throwable e) {
FileLog.e(e);
}
}
if (bos2 != null) {
try {
bos2.close();
} catch (IOException e2) {
iOException = e2;
IOException e3 = iOException;
FileLog.e(e3);
}
}
} catch (Throwable e4) {
this.initing = false;
if (httpConnectionStream2 != null) {
try {
httpConnectionStream2.close();
} catch (Throwable e5) {
FileLog.e(e5);
}
}
if (bos2 == null) {
throw e4;
}
try {
bos2.close();
throw e4;
} catch (IOException e6) {
FileLog.e(e6);
throw e4;
}
}
}
} else {
httpConnectionStream = httpConnectionStream2;
try {
String[] split2 = connInfo.split("#", 3);
bos = bos2;
try {
NetBean netBean2 = new NetBean(split2[0], split2[1], split2[2]);
this.connInfos.add(netBean2);
} catch (Throwable th3) {
e = th3;
httpConnectionStream2 = httpConnectionStream;
bos2 = bos;
FileLog.e(e);
this.initing = false;
if (httpConnectionStream2 != null) {
}
if (bos2 != null) {
}
}
} catch (Throwable th4) {
e = th4;
httpConnectionStream2 = httpConnectionStream;
FileLog.e(e);
this.initing = false;
if (httpConnectionStream2 != null) {
}
if (bos2 != null) {
}
}
}
i2++;
httpConnectionStream2 = httpConnectionStream;
bos2 = bos;
i = 1;
c = 0;
}
httpConnectionStream = httpConnectionStream2;
bos = bos2;
this.inited = true;
this.sCurrentConnection = -1;
setServer2();
httpConnectionStream2 = httpConnectionStream;
bos2 = bos;
} catch (Throwable th5) {
e = th5;
}
} catch (Throwable th6) {
e = th6;
}
}
this.initing = false;
if (httpConnectionStream2 != null) {
try {
httpConnectionStream2.close();
} catch (Throwable e7) {
FileLog.e(e7);
}
}
if (bos2 != null) {
try {
bos2.close();
} catch (IOException e8) {
iOException = e8;
IOException e32 = iOException;
FileLog.e(e32);
}
}
} catch (Throwable th7) {
e = th7;
}
}
private String[] getYuncengConfig(String groupName, String dDomain, String dPort) {
StringBuffer ip = new StringBuffer();
StringBuffer port = new StringBuffer();
int ret = YunCeng.getProxyTcpByDomain("Default", groupName, dDomain, dPort, ip, port);
if (ret == 0) {
return new String[]{ip.toString(), port.toString()};
}
FileLog.e("YunCeng get next ip failed: " + ret);
return null;
}
}