importorg.junit.Test;
importjavax.mail.Message;
importjavax.mail.Session;
importjavax.mail.Transport;
importjavax.mail.internet.InternetAddress;
importjavax.mail.internet.MimeMessage;
importjava.io.PrintWriter;
importjava.io.StringWriter;
importjava.util.Properties;
publicclassSendMailDemo {
publicstaticvoidmain(String[] args) throwsException {
Propertiesprop=newProperties();
prop.setProperty("mail.host","smtp.163.com");//设置发送方邮箱服务器prop.setProperty("mail.transport.protocol","smtp");//邮件发送协议prop.setProperty("mail.smtp.auth","true");//需要验证用户名密码Sessionsession=Session.getDefaultInstance(prop);
Transportts=session.getTransport();
StringmailUser="xxx@163.com"; //邮箱的账号StringmailPasswd="123456789"; //邮箱的密码ts.connect("smtp.163.com", mailUser, mailPasswd);
MimeMessagemessage=newMimeMessage(session);
message.setFrom(newInternetAddress(mailUser));
//收件人的邮箱地址message.setRecipient(Message.RecipientType.TO,newInternetAddress("xxxx@163.com"));
//邮件的标题message.setSubject("自定义通知");
message.setContent("<h1 style='color:black'>邮件通知发送成功!</h1>","text/html;charset=UTF-8");
ts.sendMessage(message,message.getAllRecipients());
ts.close();
    }
}

/*** @Auther: tangtao* @Date: 2022/8/19 10:46* @Description:发送钉钉通知*/publicclassWebhookDemo {
publicstaticvoidmain(String[] args) throwsException {
CloseableHttpClienthttpClient=HttpClientBuilder.create().build();
HttpPosthttpPost=newHttpPost("https://oapi.dingtalk.com/robot/send?access_token=fcf4c30596a8b26d76a6d4dcd658b708066e23e877b285c784db2360660c97e0");
httpPost.setHeader("Content-Type", "application/json;charset=utf8");
JSONObjectresult=newJSONObject();
JSONObjecttext=newJSONObject();
text.put("content", "测试钉钉发送定时任务通知");
result.put("text", text);
result.put("msgtype", "text");
StringjsonString=JSON.toJSONString(result);
StringEntityentity=newStringEntity(jsonString, "UTF-8");
httpPost.setEntity(entity);
CloseableHttpResponseresponse=null;
response=httpClient.execute(httpPost);
HttpEntityresponseEntity=response.getEntity();
System.out.println("响应结果:"+EntityUtils.toString(responseEntity));
    }
}

<!--elasticjob--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId><version>2.2.0.RELEASE</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId><version>2.2.0.RELEASE</version></dependency><dependency><groupId>org.apache.shardingsphere.elasticjob</groupId><artifactId>elasticjob-lite-spring-boot-starter</artifactId><version>3.0.0-RC1</version></dependency><dependency><groupId>org.apache.shardingsphere.elasticjob</groupId><artifactId>elasticjob-error-handler-dingtalk</artifactId><version>3.0.0-RC1</version></dependency>

/*** @Auther: tangtao* @Date: 2022/8/17 14:33* @Description: elastic job 失败后发送钉钉通知*/@ComponentpublicclassErrorNoticeDingtalkJobimplementsSimpleJob {
@Overridepublicvoidexecute(finalShardingContextshardingContext) {
thrownewRuntimeException(String.format("An exception has occurred in Job, The parameter is %s", shardingContext.getShardingParameter()));
    }
}

jobs:
errorNoticeDingtalkJob:
elasticJobClass: com.springboottemplate.elasticjob.job.ErrorNoticeDingtalkJoboverwrite: trueshardingTotalCount: 3shardingItemParameters: 0=Beijing,1=Shanghai,2=GuangzhoujobErrorHandlerType: DINGTALKjobBootstrapBeanName: errorNoticeDingtalkBeanprops:
dingtalk:
webhook: you_webhookkeyword: you_keywordsecret: you_secretconnectTimeout: 3000readTimeout: 5000