From 53c1e93115059c78669d4f3417d2d91735d0469a Mon Sep 17 00:00:00 2001 From: "junj2.liang" Date: Tue, 13 Sep 2022 15:26:50 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=BF=9E=E6=8E=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/sunyard/sge/database/SydApiBuilder.java | 2 +- src/main/java/com/sunyard/sge/database/pool/HsmLinkInfo.java | 1 + src/main/java/com/sunyard/sge/database/pool/SydApiPool.java | 5 +++++ 3 files changed, 7 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/sunyard/sge/database/SydApiBuilder.java b/src/main/java/com/sunyard/sge/database/SydApiBuilder.java index c036133..fdf4337 100644 --- a/src/main/java/com/sunyard/sge/database/SydApiBuilder.java +++ b/src/main/java/com/sunyard/sge/database/SydApiBuilder.java @@ -38,7 +38,7 @@ public class SydApiBuilder { } HsmLinkInfo[] linkInfo = HsmLinkInfo.mutiHsmLinkInfo(pcIpList, iPortList, iConnectTimeOut, iDealTimeOut); - this.pool = new SydApiPool(linkInfo); + this.pool = new SydApiPool(config, linkInfo); longLinkWorks = new CommWorker(); warmUp( pcIpList, iPortList, iConnectTimeOut, iDealTimeOut ); } diff --git a/src/main/java/com/sunyard/sge/database/pool/HsmLinkInfo.java b/src/main/java/com/sunyard/sge/database/pool/HsmLinkInfo.java index f1f8f27..b8e50fd 100644 --- a/src/main/java/com/sunyard/sge/database/pool/HsmLinkInfo.java +++ b/src/main/java/com/sunyard/sge/database/pool/HsmLinkInfo.java @@ -14,6 +14,7 @@ public class HsmLinkInfo { private int iDealTimeOut; + public HsmLinkInfo(String pcIp, int iPort, int iConnectTimeOut, int iDealTimeOut) { this.pcIp = pcIp; this.iPort = iPort; diff --git a/src/main/java/com/sunyard/sge/database/pool/SydApiPool.java b/src/main/java/com/sunyard/sge/database/pool/SydApiPool.java index 5b57ace..1279220 100644 --- a/src/main/java/com/sunyard/sge/database/pool/SydApiPool.java +++ b/src/main/java/com/sunyard/sge/database/pool/SydApiPool.java @@ -6,6 +6,7 @@ import com.sunyard.sge.database.SydApi4Database; import com.sunyard.sge.database.SydApiBaseFunction; import com.sunyard.sge.log.LogFactory; import com.sunyard.sge.pool.ObjectInPool; +import com.sunyard.sge.pool.PoolConfig; import com.sunyard.sge.pool.ThreadBasedConnectPool; import org.apache.logging.log4j.Logger; import racal.sunyard.main.SydApi4j; @@ -16,6 +17,10 @@ public class SydApiPool extends ThreadBasedConnectPool { super(); this.linkInfos = linkInfos; } + public SydApiPool(PoolConfig config, HsmLinkInfo[] linkInfos) { + super(config); + this.linkInfos = linkInfos; + } // 继承 初始化 protected SydApi initialValue() {