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-08-09 15:38:34 +08:00
parent 004e6451ee
commit 5243ec1fe1
2 changed files with 35 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/sunyard/sge/database/SydApi4Database.java
View File

@ -114,6 +114,7 @@ public class SydApi4Database implements SydApi {
} catch (SydApiException e) { } catch (SydApiException e) {
le = e; le = e;
if (e.getRetCode() < 0) { if (e.getRetCode() < 0) {
log.error("HA 重试");
continue; continue;
} }
throw e; throw e;
@ -155,6 +156,7 @@ public class SydApi4Database implements SydApi {
} catch (SydApiException e) { } catch (SydApiException e) {
le = e; le = e;
if (e.getRetCode() < 0) { if (e.getRetCode() < 0) {
log.error("HA 重试");
continue; continue;
} }
throw e; throw e;
@ -199,6 +201,7 @@ public class SydApi4Database implements SydApi {
} catch (SydApiException e) { } catch (SydApiException e) {
le = e; le = e;
if (e.getRetCode() < 0) { if (e.getRetCode() < 0) {
log.error("HA 重试");
continue; continue;
} }
throw e; throw e;
@ -244,6 +247,7 @@ public class SydApi4Database implements SydApi {
} catch (SydApiException e) { } catch (SydApiException e) {
le = e; le = e;
if (e.getRetCode() < 0) { if (e.getRetCode() < 0) {
log.error("HA 重试");
continue; continue;
} }
throw e; throw e;
@ -291,6 +295,7 @@ public class SydApi4Database implements SydApi {
} catch (SydApiException e) { } catch (SydApiException e) {
le = e; le = e;
if (e.getRetCode() < 0) { if (e.getRetCode() < 0) {
log.error("HA 重试");
continue; continue;
} }
throw e; throw e;
@ -332,6 +337,7 @@ public class SydApi4Database implements SydApi {
} catch (SydApiException e) { } catch (SydApiException e) {
le = e; le = e;
if (e.getRetCode() < 0) { if (e.getRetCode() < 0) {
log.error("HA 重试");
continue; continue;
} }
throw e; throw e;
@ -373,6 +379,7 @@ public class SydApi4Database implements SydApi {
} catch (SydApiException e) { } catch (SydApiException e) {
le = e; le = e;
if (e.getRetCode() < 0) { if (e.getRetCode() < 0) {
log.error("HA 重试");
continue; continue;
} }
throw e; throw e;
@ -477,6 +484,7 @@ public class SydApi4Database implements SydApi {
} catch (SydApiException e) { } catch (SydApiException e) {
le = e; le = e;
if (e.getRetCode() < 0) { if (e.getRetCode() < 0) {
log.error("HA 重试");
continue; continue;
} }
throw e; throw e;

28
src/test/java/test/FuncTest.java
View File

@ -57,7 +57,7 @@ public class FuncTest {
@Test @Test
public void origin() throws Exception { public void originLong() throws Exception {
SydApiBuilder builder = new SydApiBuilder(new String[]{"192.168.0.200"}, new int[]{8889}, 10, 15); SydApiBuilder builder = new SydApiBuilder(new String[]{"192.168.0.200"}, new int[]{8889}, 10, 15);
SydApi.SYD_SetLogConfig("./logs/",3); SydApi.SYD_SetLogConfig("./logs/",3);
Logger log = LogFactory.getLogger(); Logger log = LogFactory.getLogger();
@ -73,4 +73,30 @@ public class FuncTest {
}, i + "t").start(); }, i + "t").start();
} }
} }
@Test
public void originShort() throws Exception {
SydApi.SYD_SetLogConfig("./logs/",3);
Logger log = LogFactory.getLogger();
String[] pcipList = {"192.168.0.200", "192.168.0.200", "192.168.0.200" };
int[] iportList ={8080,8889,8889};
for (int i = 0; i < 1000; i++) {
int tmp = i;
new Thread(() -> {
try {
SydApi api = new SydApi4Database();
for (int j = 0; j < 20; j++) {
api.SYD_Short_Connect_Ex(pcipList,iportList,10,15);
byte[] bytes = api.SYD_SM4_ShortData(0, (tmp + "t" + j).getBytes(), Consts.ECB_ENC);
byte[] result = api.SYD_SM4_ShortData(0, bytes, Consts.ECB_DEC);
System.out.println(Thread.currentThread().getName() + "," + new String(result));
}
}
finally {
if ( null != api ) {
api.SYD_Disconnect_Ex();
}
} } , i + "t").start();
}
}
} }