From a3048fa6fa72fa3cc5da2c43c59bd000e00c9599 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期四, 18 九月 2025 23:13:32 +0800
Subject: [PATCH] 工控网分析程序状态问题修复
---
blade-service/blade-mdm/src/main/java/org/springblade/mdm/commons/service/InternalEmailService.java | 17 +++++++++++++++--
1 files changed, 15 insertions(+), 2 deletions(-)
diff --git a/blade-service/blade-mdm/src/main/java/org/springblade/mdm/commons/service/InternalEmailService.java b/blade-service/blade-mdm/src/main/java/org/springblade/mdm/commons/service/InternalEmailService.java
index b20aaed..50b42e2 100644
--- a/blade-service/blade-mdm/src/main/java/org/springblade/mdm/commons/service/InternalEmailService.java
+++ b/blade-service/blade-mdm/src/main/java/org/springblade/mdm/commons/service/InternalEmailService.java
@@ -1,6 +1,8 @@
package org.springblade.mdm.commons.service;
import lombok.extern.slf4j.Slf4j;
+import org.apache.cxf.transport.http.HTTPConduit;
+import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.apache.cxf.endpoint.Client;
@@ -13,7 +15,6 @@
public void send(String fromid,String toids, String ccids, String bccids, String subject, String content, String[] paths) {
try {
-
// 鍒涘缓鍔ㄦ�佸鎴风宸ュ巶
JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
@@ -21,12 +22,24 @@
//Client client = dcf.createClient("http://localhost:8080/services/EmailService?wsdl");
Object[] result;
try (Client client = dcf.createClient(internalEmailProperties.getMailServiceAddr())) {
+ // 鑾峰彇 HTTPConduit 骞堕厤缃瓥鐣�
+ HTTPConduit conduit = (HTTPConduit) client.getConduit();
+ HTTPClientPolicy policy = new HTTPClientPolicy();
+
+ // 璁剧疆杩炴帴瓒呮椂锛堟绉掞級
+ policy.setConnectionTimeout(10000);
+ // 璁剧疆鎺ユ敹鍝嶅簲瓒呮椂锛堟绉掞級
+ policy.setReceiveTimeout(10000);
+ // 璁剧疆閲嶄紶娆℃暟
+ policy.setMaxRetransmits(2);
+ conduit.setClient(policy);
+
// 璋冪敤鏂规硶
result = client.invoke("sendInternalMail", fromid, toids, ccids, bccids, subject, content, null);
// 澶勭悊鍝嶅簲
if (result != null && result.length > 0) {
- System.out.println("鍝嶅簲: " + result[0]);
+ log.info("鍙戦�侀偖浠跺搷搴�:{} " ,result[0]);
}
}
}catch(Exception e) {
--
Gitblit v1.9.3