修改短链接

This commit is contained in:
junj2.liang 2022-08-08 17:35:31 +08:00
parent 17385b5dec
commit 6949bd4b21
2 changed files with 25 additions and 11 deletions

View File

@ -43,8 +43,7 @@ public interface SydApi {
* @param iDealTimeOut 交易接口超时设定单位毫秒(不超过10ms) * @param iDealTimeOut 交易接口超时设定单位毫秒(不超过10ms)
* @return SydApi 的对象只要有设备可用则返回 * @return SydApi 的对象只要有设备可用则返回
*/ */
@Deprecated SydApi SYD_Short_Connect_Ex(
SydApi SYD_Connect_Ex(
String[] pcIpList, String[] pcIpList,
int[] iPortList, int[] iPortList,
int iConnectTimeOut, int iConnectTimeOut,

View File

@ -28,12 +28,23 @@ public class SydApi4Database implements SydApi {
} }
@Override @Override
public SydApi SYD_Connect_Ex(String[] pcIpList, int[] iPortList, int iConnectTimeOut, int iDealTimeOut) { public SydApi SYD_Short_Connect_Ex(String[] pcIpList, int[] iPortList, int iConnectTimeOut, int iDealTimeOut) {
if (LogFactory.iLogLevel==3) { if (LogFactory.iLogLevel==3) {
log.debug("SYD_Connect_Ex方法接收参数:pcIpList:{},iPortList:{},iConnectTimeOut:{},iDealTimeOut:{}", Arrays.toString(pcIpList), Arrays.toString(iPortList), iConnectTimeOut, iDealTimeOut); log.debug("SYD_Connect_Ex方法接收参数:pcIpList:{},iPortList:{},iConnectTimeOut:{},iDealTimeOut:{}", Arrays.toString(pcIpList), Arrays.toString(iPortList), iConnectTimeOut, iDealTimeOut);
} }
SydApi4j api = (SydApi4j) new SydApi4j().connect(pcIpList[0], iPortList[0], null, iConnectTimeOut); if (iPortList==null||iPortList.length==0){
throw new SydApiException("没有ip地址",-1);
}
if (iPortList.length!=iPortList.length) {
throw new SydApiException("ip与端口号数量不一致",-1);
}
SydApi4j api = null;
for (int i = 0; i < pcIpList.length ; i++) {
api = (SydApi4j) new SydApi4j().connect(pcIpList[i], iPortList[i], null, iConnectTimeOut);
}
hsms = new SydApi4j[]{api}; hsms = new SydApi4j[]{api};
isShortLinkMode = true;
return this; return this;
} }
@ -43,14 +54,18 @@ public class SydApi4Database implements SydApi {
if ( null == hsms ){ if ( null == hsms ){
return; return;
} }
SydApi4j api = null;
SydApi4j api = hsms[0]; for (int i = 0; i < hsms.length; i++) {
api = hsms[i];
if (null != api) { if (null != api) {
try { try {
api.disconnect(); api.disconnect();
} catch (Exception e) { } catch (Exception e) {
continue;
} }
} }
}
api = null; api = null;
} }
// 配合链接池不再需要释放 // 配合链接池不再需要释放