diff --git a/common/src/main/java/org/dromara/dynamictp/common/entity/NotifyPlatform.java b/common/src/main/java/org/dromara/dynamictp/common/entity/NotifyPlatform.java index 2faebc1ab421bae567e1c368bf09445d603eebf4..a8efabb8532ab6d8ad6556271187f9181346a6aa 100644 --- a/common/src/main/java/org/dromara/dynamictp/common/entity/NotifyPlatform.java +++ b/common/src/main/java/org/dromara/dynamictp/common/entity/NotifyPlatform.java @@ -54,4 +54,10 @@ public class NotifyPlatform { * Receivers, split by , */ private String receivers = "all"; + + /** + * http请求超时时间,单位(毫秒)
+ * 默认5000毫秒 + */ + private Integer timeOut = 5000; } diff --git a/core/src/main/java/org/dromara/dynamictp/core/notifier/base/AbstractHttpNotifier.java b/core/src/main/java/org/dromara/dynamictp/core/notifier/base/AbstractHttpNotifier.java index 398fc7267d859682b503f2bcce568ad774d50dda..92412a8680037fc2cae98a661d7b15611f5276a3 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/notifier/base/AbstractHttpNotifier.java +++ b/core/src/main/java/org/dromara/dynamictp/core/notifier/base/AbstractHttpNotifier.java @@ -38,7 +38,11 @@ public abstract class AbstractHttpNotifier extends AbstractNotifier { protected void send0(NotifyPlatform platform, String content) { val url = buildUrl(platform); val msgBody = buildMsgBody(platform, content); - HttpResponse response = HttpRequest.post(url).body(msgBody).execute(); + HttpRequest request = HttpRequest.post(url) + .setConnectionTimeout(platform.getTimeOut()) + .setReadTimeout(platform.getTimeOut()) + .body(msgBody); + HttpResponse response = request.execute(); if (Objects.nonNull(response)) { log.info("DynamicTp notify, {} send success, response: {}, request: {}", platform(), response.body(), msgBody);