Jelajahi Sumber

增加http_interval

menglu 3 tahun lalu
induk
melakukan
a4187a4369

+ 6 - 0
ibms-data-sdk/src/main/java/com/persagy/ibms/data/sdk/util/Constant.java

@@ -33,6 +33,7 @@ public class Constant {
 
 	public static int compute_thread_count;
 	public static long compute_thread_sdv_interval;
+	public static long http_interval = 0L;
 
 	public static String sdk_version;
 
@@ -109,6 +110,11 @@ public class Constant {
 					element = (Element) iter.next();
 					compute_thread_sdv_interval = Long.parseLong(element.getText());
 				}
+				iter = document.selectNodes("/root/http_interval").iterator();
+				if (iter.hasNext()) {
+					element = (Element) iter.next();
+					http_interval = Long.parseLong(element.getText());
+				}
 
 				iter = document.selectNodes("/root/groupCode").iterator();
 				if (iter.hasNext()) {

+ 12 - 0
ibms-data-sdk/src/main/java/com/persagy/ibms/data/sdk/util/HttpClientUtil.java

@@ -46,6 +46,10 @@ public class HttpClientUtil {
 	}
 
 	public synchronized String put(String url, String content, Integer timeout, Map<String, String> headerMap) throws Exception {
+		if (Constant.http_interval > 0) {
+			Thread.sleep(Constant.http_interval);
+		}
+
 		HttpPut httpost = new HttpPut(url);
 		if (headerMap != null) {
 			for (String key : headerMap.keySet()) {
@@ -83,6 +87,10 @@ public class HttpClientUtil {
 	}
 
 	public synchronized String get(String url, Integer timeout, Map<String, String> headerMap) throws Exception {
+		if (Constant.http_interval > 0) {
+			Thread.sleep(Constant.http_interval);
+		}
+
 		HttpGet httpget = new HttpGet(url);
 		if (headerMap != null) {
 			for (String key : headerMap.keySet()) {
@@ -130,6 +138,10 @@ public class HttpClientUtil {
 	}
 
 	public synchronized String post(String url, String content, Integer timeout, Map<String, String> headerMap) throws Exception {
+		if (Constant.http_interval > 0) {
+			Thread.sleep(Constant.http_interval);
+		}
+
 		HttpPost httpost = new HttpPost(url);
 		if (headerMap != null) {
 			for (String key : headerMap.keySet()) {

+ 1 - 0
ibms-data-sdk/src/main/resources/config.xml

@@ -2,6 +2,7 @@
 <root>
     <compute_thread_count>16</compute_thread_count>
     <compute_thread_sdv_interval>10</compute_thread_sdv_interval>
+    <http_interval>0</http_interval>
 
     <groupCode>WD</groupCode>
     <projectId>Pj4403070003</projectId>