Spring定时任务使用及如何使用邮件监控服务器
更新时间：2019年07月23日 14:45:10 作者：挑战者V
这篇文章主要介绍了Spring定时任务使用及如何使用邮件监控服务器,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
Spring相关的依赖导入进去，即可使用spring的定时任务！
<!-- spring核心包 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>4.3.13.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>4.3.13.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>4.3.13.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>4.3.13.RELEASE</version>
</dependency>
定时任务是开发中常用的，比如订单查询，一位客人订购的某个东西，但是尚未支付，超过订单时效期自动失效，那么又是怎么样知道订单的时效性过呢?定时任务，可以每分钟或者每秒钟进行查询。
定时任务的应用是非常广的，下面应用下监控服务器，虽然说现在开源监控软件挺多的，什么zabbix,nagios或者其他等等。下面我将使用代码监控服务器:
首先准备邮件的依赖:
<!-- 发邮件 -->
<dependency>
<groupId>com.sun.mail</groupId>
<artifactId>javax.mail</artifactId>
<version>1.5.2</version>
<scope>provided</scope>
</dependency>
邮件工具类:
import java.util.Properties;
import javax.mail.Authenticator;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.PasswordAuthentication;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.AddressException;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeMessage.RecipientType;
public class MailUtils {
public static void sendMail(String email, String emailMsg)
throws AddressException, MessagingException {
// 1.创建一个程序与邮件服务器会话对象 Session
Properties props = new Properties();
props.setProperty("mail.transport.protocol", "SMTP");
props.setProperty("mail.host", "smtp.163.com");
props.setProperty("mail.smtp.auth", "true");// 指定验证为true
// 创建验证器
Authenticator auth = new Authenticator() {
public PasswordAuthentication getPasswordAuthentication() {
return new PasswordAuthentication("123@163.com", "123");
}
};
Session session = Session.getInstance(props, auth);
// 2.创建一个Message，它相当于是邮件内容
Message message = new MimeMessage(session);
message.setFrom(new InternetAddress("123@163.com")); // 设置发送者
message.setRecipient(RecipientType.TO, new InternetAddress(email)); // 设置发送方式与接收者
message.setSubject("邮件告警");
message.setContent(emailMsg, "text/html;charset=utf-8");
// 3.创建 Transport用于将邮件发送
Transport.send(message);
}
}
监控服务器类:
package cn.pms.monitor;
import java.io.InputStream;
import java.net.URL;
import java.net.URLConnection;
import javax.mail.MessagingException;
import javax.mail.internet.AddressException;
import cn.pms.util.MailUtils;
public class MonitorUrl {
public static void testUrlWithTimeOut2016(String urlString,int timeOutMillSeconds){
long lo = System.currentTimeMillis();
URL url;
try {
url = new URL(urlString);
URLConnection co = url.openConnection();
co.setConnectTimeout(timeOutMillSeconds);
co.connect();
System.out.println("连接可用");
} catch (Exception e1) {
System.out.println("连接打不开!");
url = null;
emailMonitor2016();
}
System.out.println(System.currentTimeMillis()-lo);
}
public static void testUrlWithTimeOut2018(String urlString,int timeOutMillSeconds){
long lo = System.currentTimeMillis();
URL url;
try {
url = new URL(urlString);
URLConnection co = url.openConnection();
co.setConnectTimeout(timeOutMillSeconds);
co.connect();
System.out.println("连接可用");
} catch (Exception e1) {
System.out.println("连接打不开!");
url = null;
emailMonitor2018();
}
System.out.println(System.currentTimeMillis()-lo);
}
public static void testUrlWithTimeOut1818(String urlString,int timeOutMillSeconds){
long lo = System.currentTimeMillis();
URL url;
try {
url = new URL(urlString);
URLConnection co = url.openConnection();
co.setConnectTimeout(timeOutMillSeconds);
co.connect();
System.out.println("连接可用");
} catch (Exception e1) {
System.out.println("连接打不开!");
url = null;
emailMonitor1818();;
}
System.out.println(System.currentTimeMillis()-lo);
}
public static void testUrlWithTimeOut1616(String urlString,int timeOutMillSeconds){
long lo = System.currentTimeMillis();
URL url;
try {
url = new URL(urlString);
URLConnection co = url.openConnection();
co.setConnectTimeout(timeOutMillSeconds);
co.connect();
System.out.println("连接可用");
} catch (Exception e1) {
System.out.println("连接打不开!");
url = null;
emailMonitor1616();
}
System.out.println(System.currentTimeMillis()-lo);
}
public static void emailMonitor2016() {
try {
MailUtils.sendMail("123@qq.com", "tomcat服务器端口为2016宕机了");
} catch (AddressException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (MessagingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void emailMonitor2018() {
try {
MailUtils.sendMail("123@qq.com", "tomcat服务器端口为2018宕机了");
} catch (AddressException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (MessagingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void emailMonitor1818() {
try {
MailUtils.sendMail("1236@qq.com", "tomcat服务器端口为1818宕机了");
} catch (AddressException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (MessagingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void emailMonitor1616() {
try {
MailUtils.sendMail("123@qq.com", "tomcat服务器端口为1616宕机了");
} catch (AddressException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (MessagingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
具体定时任务类:
@Component
public class QuartzJob {
private static Logger logger = Logger.getLogger(QuartzJob.class);
@Scheduled(cron = "0 0/1 * * * ? ")
public void test() {
MonitorUrl.testUrlWithTimeOut2018("http://www.yc520.com:2018/", 2000);
MonitorUrl.testUrlWithTimeOut1616("http://www.yc520.com:1616/", 2000);
logger.info("每分钟执行" + System.currentTimeMillis());
}
@Scheduled(cron = "0 10 0 * * ?")
public void monitorServerTest() {
System.out.println("每10分钟监控一次2018服务器和1616服务器");
MonitorUrl.testUrlWithTimeOut2018("http://www.yc520.com:2018/", 2000);
MonitorUrl.testUrlWithTimeOut1616("http://www.yc520.com:1616/", 2000);
}
@Scheduled(cron="0 30 0 * * ?")
public void monitorServer() {
System.out.println("每30分钟监控一次1818测试服务器");
MonitorUrl.testUrlWithTimeOut1818("http://www.yc520:1818/", 2000);
}
}
由此就可以达到监控服务器的目的，当然这只是小试牛刀，而且也不够全面，当然也存在问题，如果是每分钟定时任务检测，突然一台服务器挂了，那么将会源源不断的发送邮件，163邮件是有限的，而且频繁的可能会被当成垃圾邮件，我只需要知道一条信息，某某服务器宕机了，一遍就可以，最后给我发三十遍，如此的话，大量的无效邮件很浪费资源，而且浪费时间。
所以说，本文只是一个服务器监控小示例，实际开发中，切勿直接拿来用，最好要有相关的判断和逻辑。这样才能比较高效，达到预期期望。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
SpringCloud-Alibaba-Sentinel服务降级,热点限流,服务熔断
这篇文章主要介绍了SpringCloud-Alibaba-Sentinel服务降级,热点限流,服务熔断,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-12-12
这篇文章主要介绍了Apache Shrio安全框架实现原理及实例详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-04-04
JavaSE static final及abstract修饰符实例解析
这篇文章主要介绍了JavaSE static final及abstract修饰符实例解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-06-06
下面小编就为大家分享一篇Java遍历json字符串取值的实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-03-03
这篇文章主要介绍了Spring Boot Web应用程序配置详解，本文中将介绍一些Web应用程序最常用的配置，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-05-05
SpringBoot整合Drools规则引擎动态生成业务规则的实现
本文主要介绍了SpringBoot整合Drools规则引擎动态生成业务规则的实现，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-12-12
分布式缓存系统是三高架构中不可或缺的部分，极大地提高了整个项目的并发量、响应速度，但它也带来了新的需要解决的问题，分别是： 缓存穿透、缓存击穿、缓存雪崩和缓存一致性问题。本文将详细讲解一下这四大问题，需要的可以参考一下2022-04-04
这篇文章主要为大家介绍了分布式事务CAP、两阶段提交及三阶段提交的内容详解有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-01-01
在java编写过程中，我们会使用到各种各样的表达式，在使用表达式的过程中，有哪些安全问题需要我们注意的呢？对java判断integer是否为空相关知识感兴趣的朋友一起来看看吧2023-02-02
今天小编就为大家分享一篇关于SpringBoot项目整合mybatis的方法步骤与实例，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧2019-03-03
最新评论