瀏覽代碼

调度失败邮件报警

xueli.xue 9 年之前
父節點
當前提交
1e0ae9e573

+ 7 - 0
xxl-job-admin/pom.xml 查看文件

@@ -130,6 +130,13 @@
130 130
 			<version>4.3.6</version>
131 131
 		</dependency>
132 132
 		
133
+		<!-- javax.mail -->
134
+		<dependency>
135
+			<groupId>javax.mail</groupId>
136
+			<artifactId>mail</artifactId>
137
+			<version>1.4.6</version>
138
+		</dependency>
139
+		
133 140
 		<!-- quartz :quartz-2.2.1/c3p0-0.9.1.1/slf4j-api-1.6.6 -->
134 141
 		<dependency>
135 142
 			<groupId>org.quartz-scheduler</groupId>

xxl-job-admin/src/main/java/com/xxl/job/core/resolver/WebExceptionResolver.java → xxl-job-admin/src/main/java/com/xxl/job/controller/resolver/WebExceptionResolver.java 查看文件

@@ -1,4 +1,4 @@
1
-package com.xxl.job.core.resolver;
1
+package com.xxl.job.controller.resolver;
2 2
 
3 3
 import javax.servlet.http.HttpServletRequest;
4 4
 import javax.servlet.http.HttpServletResponse;

+ 82 - 0
xxl-job-admin/src/main/java/com/xxl/job/core/thread/JobMonitorHelper.java 查看文件

@@ -0,0 +1,82 @@
1
+package com.xxl.job.core.thread;
2
+
3
+import java.text.MessageFormat;
4
+import java.util.concurrent.ConcurrentHashMap;
5
+import java.util.concurrent.ExecutorService;
6
+import java.util.concurrent.Executors;
7
+import java.util.concurrent.LinkedBlockingQueue;
8
+import java.util.concurrent.TimeUnit;
9
+
10
+import org.apache.commons.lang.StringUtils;
11
+import org.slf4j.Logger;
12
+import org.slf4j.LoggerFactory;
13
+
14
+import com.xxl.job.client.util.HttpUtil;
15
+import com.xxl.job.core.model.XxlJobInfo;
16
+import com.xxl.job.core.model.XxlJobLog;
17
+import com.xxl.job.core.util.DynamicSchedulerUtil;
18
+import com.xxl.job.core.util.MailUtil;
19
+
20
+/**
21
+ * job monitor helper
22
+ * @author xuxueli 2015-9-1 18:05:56
23
+ */
24
+public class JobMonitorHelper {
25
+	private static Logger logger = LoggerFactory.getLogger(JobMonitorHelper.class);
26
+	
27
+	public static JobMonitorHelper helper = new JobMonitorHelper();
28
+	private ExecutorService executor = Executors.newCachedThreadPool();
29
+	private LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue<Integer>(0xfff8);
30
+	private ConcurrentHashMap<String, Integer> countMap = new ConcurrentHashMap<String, Integer>();
31
+	
32
+	public JobMonitorHelper(){
33
+		// consumer
34
+		executor.execute(new Runnable() {
35
+			@Override
36
+			public void run() {
37
+				while (true) {
38
+					logger.info(">>>>>>>>>>> job monitor run ... ");
39
+					Integer jobLogId = JobMonitorHelper.helper.queue.poll();
40
+					if (jobLogId != null && jobLogId > 0) {
41
+						XxlJobLog log = DynamicSchedulerUtil.xxlJobLogDao.load(jobLogId);
42
+						if (log!=null) {
43
+							if (HttpUtil.SUCCESS.equals(log.getTriggerStatus()) && StringUtils.isBlank(log.getHandleStatus())) {
44
+								JobMonitorHelper.monitor(jobLogId);
45
+							}
46
+							if (HttpUtil.SUCCESS.equals(log.getTriggerStatus()) && HttpUtil.SUCCESS.equals(log.getHandleStatus())) {
47
+								// pass
48
+							}
49
+							if (HttpUtil.FAIL.equals(log.getTriggerStatus()) || HttpUtil.FAIL.equals(log.getHandleStatus())) {
50
+								String monotorKey = log.getJobGroup().concat("_").concat(log.getJobName());
51
+								Integer count = countMap.get(monotorKey);
52
+								if (count == null) {
53
+									count = new Integer(0);
54
+								}
55
+								count += 1;
56
+								countMap.put(monotorKey, count);
57
+								XxlJobInfo info = DynamicSchedulerUtil.xxlJobInfoDao.load(log.getJobGroup(), log.getJobName());
58
+								if (count >= info.getAlarmThreshold()) {
59
+									MailUtil.sendMail(info.getAlarmEmail(), "《调度平台中心-监控报警》", 
60
+											MessageFormat.format("调度任务[{0}]失败报警", monotorKey), false, null);
61
+									countMap.remove(monotorKey);
62
+								}
63
+							}
64
+						}
65
+					} else {
66
+						try {
67
+							TimeUnit.SECONDS.sleep(20);
68
+						} catch (InterruptedException e) {
69
+							e.printStackTrace();
70
+						}
71
+					}
72
+				}
73
+			}
74
+		});
75
+	}
76
+	
77
+	// producer
78
+	public static void monitor(int jobLogId){
79
+		JobMonitorHelper.helper.queue.offer(jobLogId);
80
+	}
81
+	
82
+}

+ 1 - 0
xxl-job-admin/src/main/java/com/xxl/job/core/util/DynamicSchedulerUtil.java 查看文件

@@ -67,6 +67,7 @@ public final class DynamicSchedulerUtil implements ApplicationContextAware, Init
67 67
     }
68 68
 	
69 69
 	// getJobKeys
70
+	@Deprecated
70 71
 	public static List<Map<String, Object>> getJobList(){
71 72
 		List<Map<String, Object>> jobList = new ArrayList<Map<String,Object>>();
72 73
 		

+ 181 - 0
xxl-job-admin/src/main/java/com/xxl/job/core/util/MailUtil.java 查看文件

@@ -0,0 +1,181 @@
1
+package com.xxl.job.core.util;
2
+
3
+import java.io.File;
4
+import java.util.Properties;
5
+import java.util.concurrent.ExecutorService;
6
+import java.util.concurrent.Executors;
7
+
8
+import javax.mail.internet.MimeMessage;
9
+import javax.mail.internet.MimeUtility;
10
+
11
+import org.apache.commons.lang.ArrayUtils;
12
+import org.slf4j.Logger;
13
+import org.slf4j.LoggerFactory;
14
+import org.springframework.mail.javamail.JavaMailSender;
15
+import org.springframework.mail.javamail.JavaMailSenderImpl;
16
+import org.springframework.mail.javamail.MimeMessageHelper;
17
+
18
+/**
19
+ * 邮件发送.Util
20
+ * @author xuxueli 2016-3-12 15:06:20
21
+ */
22
+public class MailUtil {
23
+	private static Logger logger = LoggerFactory.getLogger(MailUtil.class);
24
+	
25
+	private static String host;
26
+	private static String port;
27
+	private static String username;
28
+	private static String password;
29
+	private static String sendFrom;
30
+	private static String sendNick;
31
+	static{
32
+		host = PropertiesUtil.getString("mail.host");
33
+		port = PropertiesUtil.getString("mail.port");
34
+		username = PropertiesUtil.getString("mail.username");
35
+		password = PropertiesUtil.getString("mail.password");
36
+		sendFrom = PropertiesUtil.getString("mail.sendFrom");
37
+		sendNick = PropertiesUtil.getString("mail.sendNick");
38
+	}
39
+	
40
+	/**
41
+	<!-- spring mail sender -->
42
+	<bean id="javaMailSender" class="org.springframework.mail.javamail.JavaMailSenderImpl"  scope="singleton" >
43
+		<property name="host" value="${mail.host}" />			<!-- SMTP发送邮件的服务器的IP和端口 -->
44
+		<property name="port" value="${mail.port}" />
45
+		<property name="username" value="${mail.username}" />	<!-- 登陆SMTP邮件发送服务器的用户名和密码 -->
46
+		<property name="password" value="${mail.password}" />
47
+		<property name="javaMailProperties">					<!-- 获得邮件会话属性,验证登录邮件服务器是否成功 -->
48
+			<props>
49
+				<prop key="mail.smtp.auth">true</prop>
50
+				<prop key="prop">true</prop>
51
+				<!-- <prop key="mail.smtp.timeout">25000</prop> -->
52
+			</props>
53
+		</property>
54
+	</bean>
55
+	 */
56
+	/**
57
+	 * 发送邮件 (完整版)(结合Spring)
58
+	 * 
59
+	 * @param javaMailSender: 发送Bean
60
+	 * @param sendFrom		: 发送人邮箱
61
+	 * @param sendNick		: 发送人昵称
62
+	 * @param toAddress		: 收件人邮箱
63
+	 * @param mailSubject	: 邮件主题
64
+	 * @param mailBody		: 邮件正文
65
+	 * @param mailBodyIsHtml: 邮件正文格式,true:HTML格式;false:文本格式
66
+	 * @param files[]		: 附件
67
+	 */
68
+	@SuppressWarnings("null")
69
+	public static boolean sendMailSpring(String toAddress, String mailSubject, String mailBody, boolean mailBodyIsHtml,File[] attachments) {
70
+		JavaMailSender javaMailSender = null;//ResourceBundle.getInstance().getJavaMailSender();
71
+		try {
72
+			MimeMessage mimeMessage = javaMailSender.createMimeMessage();
73
+			MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, ArrayUtils.isNotEmpty(attachments), "UTF-8"); // 设置utf-8或GBK编码,否则邮件会有乱码;multipart,true表示文件上传
74
+			
75
+			helper.setFrom(sendFrom, sendNick);
76
+			helper.setTo(toAddress);
77
+
78
+			// 设置收件人抄送的名片和地址(相当于群发了)
79
+			//helper.setCc(InternetAddress.parse(MimeUtility.encodeText("邮箱001") + " <@163.com>," + MimeUtility.encodeText("邮箱002") + " <@foxmail.com>"));
80
+
81
+			helper.setSubject(mailSubject);
82
+			helper.setText(mailBody, mailBodyIsHtml);
83
+			
84
+			// 添加附件
85
+			if (ArrayUtils.isNotEmpty(attachments)) {
86
+				for (File file : attachments) {
87
+					helper.addAttachment(MimeUtility.encodeText(file.getName()), file);	
88
+				}
89
+			}
90
+			
91
+			// 群发
92
+			//MimeMessage[] mailMessages = { mimeMessage };
93
+			
94
+			javaMailSender.send(mimeMessage);
95
+			return true;
96
+		} catch (Exception e) {
97
+			logger.info("{}", e);
98
+		}
99
+		return false;
100
+	}
101
+	
102
+	/**
103
+	 * 发送邮件 (完整版) (纯JavaMail)
104
+	 * 
105
+	 * @param toAddress		: 收件人邮箱
106
+	 * @param mailSubject	: 邮件主题
107
+	 * @param mailBody		: 邮件正文
108
+	 * @param mailBodyIsHtml: 邮件正文格式,true:HTML格式;false:文本格式
109
+	 * @param inLineFile	: 内嵌文件
110
+	 * @param files[]		: 附件
111
+	 */
112
+	public static boolean sendMail (String toAddress, String mailSubject, String mailBody, 
113
+			boolean mailBodyIsHtml, File[] attachments){
114
+        try {
115
+			// 创建邮件发送类 JavaMailSender (用于发送多元化邮件,包括附件,图片,html 等    )
116
+        	JavaMailSenderImpl mailSender = new JavaMailSenderImpl();
117
+        	mailSender.setHost(host); 			// 设置邮件服务主机    
118
+        	mailSender.setUsername(username); 	// 发送者邮箱的用户名    
119
+        	mailSender.setPassword(password); 	// 发送者邮箱的密码    
120
+        	
121
+			//配置文件,用于实例化java.mail.session    
122
+			Properties pro = System.getProperties();
123
+			pro.put("mail.smtp.auth", "true");		// 登录SMTP服务器,需要获得授权 (网易163邮箱新近注册的邮箱均不能授权,测试 sohu 的邮箱可以获得授权)
124
+			pro.put("mail.smtp.socketFactory.port", port);
125
+			pro.put("mail.smtp.socketFactory.fallback", "false");
126
+			mailSender.setJavaMailProperties(pro);
127
+			
128
+			//创建多元化邮件 (创建 mimeMessage 帮助类,用于封装信息至 mimeMessage)
129
+			MimeMessage mimeMessage = mailSender.createMimeMessage();						
130
+			MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, ArrayUtils.isNotEmpty(attachments), "UTF-8");
131
+			
132
+			helper.setFrom(sendFrom, sendNick);
133
+			helper.setTo(toAddress);
134
+
135
+			helper.setSubject(mailSubject);
136
+			helper.setText(mailBody, mailBodyIsHtml); 
137
+			
138
+			// 添加内嵌文件,第1个参数为cid标识这个文件,第2个参数为资源
139
+			//helper.addInline(MimeUtility.encodeText(inLineFile.getName()), inLineFile);	
140
+			
141
+			// 添加附件    
142
+			if (ArrayUtils.isNotEmpty(attachments)) {
143
+				for (File file : attachments) {
144
+					helper.addAttachment(MimeUtility.encodeText(file.getName()), file);	
145
+				}
146
+			}
147
+			
148
+			mailSender.send(mimeMessage);
149
+			return true;
150
+		} catch (Exception e) {
151
+			e.printStackTrace();
152
+		}
153
+		return false;
154
+	}
155
+	
156
+	static int total = 0;
157
+	public static void main(String[] args) {
158
+		
159
+		ExecutorService exec = Executors.newCachedThreadPool();
160
+		for (int i = 0; i < 20; i++) {
161
+			exec.execute(new Thread(new Runnable() {
162
+				@Override
163
+				public void run() {
164
+					while(total < 10){
165
+						String mailBody = "<html><head><meta http-equiv="
166
+								+ "Content-Type"
167
+								+ " content="
168
+								+ "text/html; charset=gb2312"
169
+								+ "></head><body><h1>新书快递通知</h1>你的新书快递申请已推送新书,请到<a href=''>空间"
170
+								+ "</a>中查看</body></html>";
171
+						
172
+						sendMail("ovono802302@163.com", "测试邮件", mailBody, false, null);
173
+						System.out.println(total);
174
+						total++;
175
+					}
176
+				}
177
+			}));
178
+		}
179
+	}
180
+	
181
+}

+ 2 - 0
xxl-job-admin/src/main/java/com/xxl/job/service/job/LocalNomalJobBean.java 查看文件

@@ -19,6 +19,7 @@ import com.xxl.job.client.util.HttpUtil;
19 19
 import com.xxl.job.client.util.JacksonUtil;
20 20
 import com.xxl.job.core.model.XxlJobInfo;
21 21
 import com.xxl.job.core.model.XxlJobLog;
22
+import com.xxl.job.core.thread.JobMonitorHelper;
22 23
 import com.xxl.job.core.util.DynamicSchedulerUtil;
23 24
 
24 25
 /**
@@ -81,6 +82,7 @@ public abstract class LocalNomalJobBean extends QuartzJobBean {
81 82
 		// update trigger info
82 83
 		DynamicSchedulerUtil.xxlJobLogDao.updateTriggerInfo(jobLog);
83 84
 		DynamicSchedulerUtil.xxlJobLogDao.updateHandleInfo(jobLog);
85
+		JobMonitorHelper.monitor(jobLog.getId());
84 86
 		logger.info(">>>>>>>>>>> xxl-job trigger end, jobLog.id:{}, jobLog:{}", jobLog.getId(), jobLog);
85 87
 		
86 88
     }

+ 2 - 0
xxl-job-admin/src/main/java/com/xxl/job/service/job/RemoteHttpJobBean.java 查看文件

@@ -18,6 +18,7 @@ import com.xxl.job.client.util.HttpUtil;
18 18
 import com.xxl.job.client.util.JacksonUtil;
19 19
 import com.xxl.job.core.model.XxlJobInfo;
20 20
 import com.xxl.job.core.model.XxlJobLog;
21
+import com.xxl.job.core.thread.JobMonitorHelper;
21 22
 import com.xxl.job.core.util.DynamicSchedulerUtil;
22 23
 import com.xxl.job.core.util.PropertiesUtil;
23 24
 
@@ -85,6 +86,7 @@ public class RemoteHttpJobBean extends QuartzJobBean {
85 86
 		
86 87
 		// update trigger info
87 88
 		DynamicSchedulerUtil.xxlJobLogDao.updateTriggerInfo(jobLog);
89
+		JobMonitorHelper.monitor(jobLog.getId());
88 90
 		logger.info(">>>>>>>>>>> xxl-job trigger end, jobLog.id:{}, jobLog:{}", jobLog.getId(), jobLog);
89 91
 		
90 92
     }

+ 10 - 1
xxl-job-admin/src/main/resources/config.properties 查看文件

@@ -1 +1,10 @@
1
-trigger_log_url=http://localhost:8080/joblog/save
1
+# for trigger log callback
2
+trigger_log_url=http://localhost:8080/joblog/save
3
+
4
+# for email
5
+mail.host=smtp.163.com
6
+mail.port=25
7
+mail.username=ovono802302@163.com
8
+mail.password=asdfzxcv
9
+mail.sendFrom=ovono802302@163.com
10
+mail.sendNick=《任务调度中心xxl-job》

+ 1 - 2
xxl-job-admin/src/main/resources/springmvc-context.xml 查看文件

@@ -38,7 +38,7 @@
38 38
 		<property name="order" value="0" />
39 39
 	</bean>
40 40
 	
41
-	<bean id="exceptionResolver" class="com.xxl.job.core.resolver.WebExceptionResolver" />
41
+	<bean id="exceptionResolver" class="com.xxl.job.controller.resolver.WebExceptionResolver" />
42 42
 	
43 43
 	<!--
44 44
 	// 自定义拦截器,支持SSO登陆拦截 
@@ -48,7 +48,6 @@
48 48
 			<bean class="com.xxl.controller.interceptor.PermissionInterceptor"/>
49 49
 		</mvc:interceptor>
50 50
 	</mvc:interceptors>
51
- 	<bean id="exceptionResolver" class="com.xxl.controller.resolver.WebExceptionResolver" /> 
52 51
  	-->
53 52
 	
54 53
 </beans>