Sunyard/sydapi-java-sge-database
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改连接

Browse Source
This commit is contained in:
junj2.liang 2022-09-13 15:26:50 +08:00
parent 2f144badd5
commit 53c1e93115
3 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/sunyard/sge/database/SydApiBuilder.java
View File

@ -38,7 +38,7 @@ public class SydApiBuilder {
} }
HsmLinkInfo[] linkInfo = HsmLinkInfo.mutiHsmLinkInfo(pcIpList, iPortList, iConnectTimeOut, iDealTimeOut); HsmLinkInfo[] linkInfo = HsmLinkInfo.mutiHsmLinkInfo(pcIpList, iPortList, iConnectTimeOut, iDealTimeOut);
this.pool = new SydApiPool(linkInfo); this.pool = new SydApiPool(config, linkInfo);
longLinkWorks = new CommWorker(); longLinkWorks = new CommWorker();
warmUp( pcIpList, iPortList, iConnectTimeOut, iDealTimeOut ); warmUp( pcIpList, iPortList, iConnectTimeOut, iDealTimeOut );
} }

1
src/main/java/com/sunyard/sge/database/pool/HsmLinkInfo.java
View File

@ -14,6 +14,7 @@ public class HsmLinkInfo {
private int iDealTimeOut; private int iDealTimeOut;
public HsmLinkInfo(String pcIp, int iPort, int iConnectTimeOut, int iDealTimeOut) { public HsmLinkInfo(String pcIp, int iPort, int iConnectTimeOut, int iDealTimeOut) {
this.pcIp = pcIp; this.pcIp = pcIp;
this.iPort = iPort; this.iPort = iPort;

5
src/main/java/com/sunyard/sge/database/pool/SydApiPool.java
View File

@ -6,6 +6,7 @@ import com.sunyard.sge.database.SydApi4Database;
import com.sunyard.sge.database.SydApiBaseFunction; import com.sunyard.sge.database.SydApiBaseFunction;
import com.sunyard.sge.log.LogFactory; import com.sunyard.sge.log.LogFactory;
import com.sunyard.sge.pool.ObjectInPool; import com.sunyard.sge.pool.ObjectInPool;
import com.sunyard.sge.pool.PoolConfig;
import com.sunyard.sge.pool.ThreadBasedConnectPool; import com.sunyard.sge.pool.ThreadBasedConnectPool;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import racal.sunyard.main.SydApi4j; import racal.sunyard.main.SydApi4j;
@ -16,6 +17,10 @@ public class SydApiPool extends ThreadBasedConnectPool<SydApi> {
super(); super();
this.linkInfos = linkInfos; this.linkInfos = linkInfos;
} }
public SydApiPool(PoolConfig config, HsmLinkInfo[] linkInfos) {
super(config);
this.linkInfos = linkInfos;
}
// 继承 初始化 // 继承 初始化
protected SydApi initialValue() { protected SydApi initialValue() {