diff --git a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/model/MailInfo.java b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/model/MailInfo.java index c774f6bb50c54ecbe8d44f18d1492d0019c98dd9..38f6eea36594f28a17d81e1012491c7adfea32b6 100644 --- a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/model/MailInfo.java +++ b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/model/MailInfo.java @@ -5,8 +5,6 @@ public class MailInfo { private String[] mailCc; - private String mailTemp; - public String[] getMailTo() { return mailTo; } @@ -23,11 +21,4 @@ public class MailInfo { this.mailCc = mailCc; } - public String getMailTemp() { - return mailTemp; - } - - public void setMailTemp(String mailTemp) { - this.mailTemp = mailTemp; - } } diff --git a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/procesor/AlarmMessageProcessor.java b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/procesor/AlarmMessageProcessor.java index 4d53a4a6d7fc91c167e30f4a8e8a8e8af216ef86..c755388dcfa2cf8f474db065958751590382114b 100644 --- a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/procesor/AlarmMessageProcessor.java +++ b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/procesor/AlarmMessageProcessor.java @@ -1,6 +1,5 @@ package com.ai.cloud.skywalking.alarm.procesor; -import com.ai.cloud.skywalking.alarm.dao.AlarmMessageDao; import com.ai.cloud.skywalking.alarm.model.AlarmRule; import com.ai.cloud.skywalking.alarm.model.ApplicationInfo; import com.ai.cloud.skywalking.alarm.model.MailInfo; @@ -20,13 +19,25 @@ import java.io.StringWriter; import java.sql.SQLException; import java.text.SimpleDateFormat; import java.util.*; -import java.util.concurrent.ConcurrentHashMap; public class AlarmMessageProcessor { private static Logger logger = LogManager .getLogger(AlarmMessageProcessor.class); + static String mailTemplate = ""; + + static { + Properties properties = new Properties(); + try { + properties.load(AlarmMessageProcessor.class.getResourceAsStream("/mail-template_new.config")); + mailTemplate = properties.getProperty("template.default"); + } catch (IOException e) { + e.printStackTrace(); + } + } + + public void process(UserInfo userInfo, AlarmRule rule) throws TemplateException, IOException, SQLException { Set warningTracingIds = new HashSet(); Set warningMessageKeys = new HashSet(); @@ -63,9 +74,9 @@ public class AlarmMessageProcessor { rule.getPreviousFireTimeM() * 10000 * 6))); parameter.put("endDate", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date( currentFireMinuteTime * 10000 * 6))); - String mailContext = generateContent(rule + String mailContext = generateContent(/*rule .getConfigArgsDescriber().getMailInfo() - .getMailTemp(), parameter); + .getMailTemp()*/mailTemplate, parameter); if (mailContext.length() > 0) { MailInfo mailInfo = rule.getConfigArgsDescriber() .getMailInfo(); @@ -142,6 +153,4 @@ public class AlarmMessageProcessor { t.process(parameter, out); return out.getBuffer().toString(); } - - private static Map idCodeMapper = new ConcurrentHashMap(); } diff --git a/skywalking-alarm/src/main/resources/config.properties b/skywalking-alarm/src/main/resources/config.properties index 80810ead9b9dbe9c87525a003515b75d9914dd3d..568abe80921c75d433c4b358a30d8d3ed15b5e5c 100644 --- a/skywalking-alarm/src/main/resources/config.properties +++ b/skywalking-alarm/src/main/resources/config.properties @@ -7,7 +7,8 @@ server.daemon_thread_wait_interval=50000 processthread.thread_wait_interval=5000 #zookeeper连接地址 -zkpath.connect_str=10.1.241.18:29181,10.1.241.19:29181,10.1.241.20:29181 +#zkpath.connect_str=10.1.241.18:29181,10.1.241.19:29181,10.1.241.20:29181 +zkpath.connect_str=127.0.0.1:29181 #zookeeper连接超时时间(单位:毫秒) zkpath.connect_timeout=1000 #zookeeper重试次数 @@ -46,7 +47,8 @@ db.max_pool_size=20 db.connect_timeout=10000 #告警信息存在的redis服务器地址 -alarm.redis_server=10.1.241.18:16379 +#alarm.redis_server=10.1.241.18:16379 +alarm.redis_server=127.0.0.1:6379 #redis的最大空闲连接数 alarm.redis_max_idle=20 #redis的最小空闲连接数 diff --git a/skywalking-alarm/src/main/resources/mail-template.config b/skywalking-alarm/src/main/resources/mail-template.config new file mode 100644 index 0000000000000000000000000000000000000000..cf00b1bc65d62c2f2b8c6a9e1b96b616d777770c --- /dev/null +++ b/skywalking-alarm/src/main/resources/mail-template.config @@ -0,0 +1 @@ +template.default=templete1_welcome

\u5c0a\u656c\u7684SkyWalking\u7528\u6237\u60a8\u597d:

\u81ea${startDate!}\u8d77\uff0c\u5230${endDate!}\u6b62\uff0c\u5e73\u53f0\u63a5\u6536\u5230\u76d1\u63a7\u544a\u8b66\u4fe1\u606f\u5982\u4e0b\uff1a

<#if warningTracingIds??><#list warningTracingIds as traceId>

  • ${traceId!}
  • \ No newline at end of file