经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » 其他 » 职业生涯 » 查看文章
Springboot进行Http接口交互实现邮件告警
来源：cnblogs　　作者：大耳根图图　　时间：2021/4/6 9:38:57　　对本文有异议

本项目采用idea编辑器，依赖maven环境，相关搭建请自行百度

一、引入相关依赖
    本文Http接口交互使用hutool工具类与阿里FastJson解析报文。

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
 
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
 
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>RELEASE</version>
            <scope>compile</scope>
        </dependency>
 
        <!-- json -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.75</version>
        </dependency>
 
        <!-- hutool工具类-->
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.3.8</version>
        </dependency>
 
        <!-- https://mvnrepository.com/artifact/com.sun.mail/javax.mail -->
        <dependency>
            <groupId>com.sun.mail</groupId>
            <artifactId>javax.mail</artifactId>
            <version>1.6.2</version>
        </dependency>
</dependencies>

二、编写相关配置
#本文使用163邮箱演示，邮箱需要开启IMAP/SMTP服务

 

 

 #在yml文件中配置相关参数

server:
  port: 8080
spring:
  mail:
    host: smtp.163.com
    port: 465
    username: @163.com
    password:
    properties:
      mail:
        smtp:
          auth: true
          starttls:
            enable: true
            required: true
scripturl:
  url[0]:
    sort: 0
    url: https://gitee.com/login
    type: post
    params:
      account: 123456
      password: 123456
emailParams: @163.com

三、编写工具类
#编写发送邮件工具类SendEmailUtils
#邮件发送方法最好使用异步方式，这样可以保证调用方法执行后及时回馈

package com.auto.script.util;
 
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import javax.mail.*;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import java.security.Security;
import java.util.Date;
import java.util.Properties;
 
/**
 * @Description: 发送邮件
 * @Author: bigearchart
 * @Date: 2021/4/2
 * @return
 */
@Service
public class SendEmailUtils {
    /** yml中配置的地址 */
    @Value(value = "${spring.mail.host}")
    private  String host;
 
    /** yml中配置的端口 */
    @Value(value = "${spring.mail.port}")
    private  String port;
 
    /** yml中配置的发件邮箱 */
    @Value(value = "${spring.mail.username}")
    private  String userName;
 
    /** yml中配置的发件邮箱密码 */
    @Value(value = "${spring.mail.password}")
    private  String passWord;
 
    /**
     * 使用加密的方式,利用465端口进行传输邮件,开启ssl
     * @param to    为收件人邮箱
     * @param message    发送的消息
     */
    @Async
    public  void sendEmil(String to,String subject, String message) {
        try {
            Security.addProvider(new com.sun.net.ssl.internal.ssl.Provider());
            final String SSL_FACTORY = "javax.net.ssl.SSLSocketFactory";
            //设置邮件会话参数
            Properties props = new Properties();
            //邮箱的发送服务器地址
            props.setProperty("mail.smtp.host", host);
            props.setProperty("mail.smtp.socketFactory.class", SSL_FACTORY);
            props.setProperty("mail.smtp.socketFactory.fallback", "false");
            //邮箱发送服务器端口,这里设置为465端口
            props.setProperty("mail.smtp.port", port);
            props.setProperty("mail.smtp.socketFactory.port", port);
            props.put("mail.smtp.auth", "true");
            final String username = userName;
            final String password = passWord;
            //获取到邮箱会话,利用匿名内部类的方式,将发送者邮箱用户名和密码授权给jvm
            Session session = Session.getDefaultInstance(props, new Authenticator() {
                @Override
                protected PasswordAuthentication getPasswordAuthentication() {
                    return new PasswordAuthentication(username, password);
                }
            });
            //通过会话,得到一个邮件,用于发送
            Message msg = new MimeMessage(session);
            //设置发件人
            msg.setFrom(new InternetAddress(userName));
            //设置收件人
            msg.setRecipients(Message.RecipientType.TO, InternetAddress.parse(to, false));
 
            //设置邮件消息
            msg.setContent(message, "text/html; charset=utf-8");
            //设置邮件标题
            msg.setSubject(subject);
 
            //设置发送的日期
            msg.setSentDate(new Date());
 
            //调用Transport的send方法去发送邮件
            Transport.send(msg);
 
        } catch (Exception e) {
            e.printStackTrace();
        }
 
    }
}

四、业务代码实现
#编写接口接收类ScriptUrl 需要注意字段名与yml中配置的字段名必须一致，不然会
#自动解析失败

package com.auto.script.entity;
 
import java.util.Map;
 
/**
 * @author ：bigearchart
 * @date ：Created in 2021/4/1 16:31
 * @description： 脚本检查接口类
 * @version: 1.0
 */
public class ScriptUrl {
    /** 排序字段*/
    public int sort;
    /** 请求路径*/
    public String url;
    /** 请求类型*/
    public String type;
    /** 请求参数*/
    public Map<String, Object> params;
 
 
    public int getSort() {
        return sort;
    }
 
    public void setSort(int sort) {
        this.sort = sort;
    }
 
    public String getUrl() {
        return url;
    }
 
    public void setUrl(String url) {
        this.url = url;
    }
 
    public String getType() {
        return type;
    }
 
    public void setType(String type) {
        this.type = type;
    }
 
    public Map<String, Object> getParams() {
        return params;
    }
 
    public void setParams(Map<String, Object> params) {
        this.params = params;
    }
}

#编写参数注入类

package com.auto.script.util;
 
import com.auto.script.entity.ScriptUrl;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import java.util.List;
 
/**
 * @Description: 脚本检查接口参数注入类
 * @Author: bigearchart
 * @Date: 2021/4/1
 * @return
 */
@Configuration
@ConfigurationProperties(prefix = "scripturl")
@EnableConfigurationProperties(ScriptUrlEnum.class)
public class ScriptUrlEnum {
 
    private List<ScriptUrl> url;
 
 
    public List<ScriptUrl> getUrl() {
        return url;
    }
 
    public void setUrl(List<ScriptUrl> url) {
        this.url = url;
    }
}

#定义接口

package com.auto.script.service;
 
/**
 * @author ：bigearchart
 * @date ：Created in 2021/4/1 15:53
 * @description： 定时任务配置类
 * @version: 1.0
 */
public interface QuazrtAutoService {
 
    /**
     * 定时任务每隔一分钟执行验证接口服务是否正常
     */
    public void autoCrontab();
}

#编写接口实现类

package com.auto.script.service.impl;
 
import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSONObject;
import com.auto.script.entity.ScriptUrl;
import com.auto.script.service.QuazrtAutoService;
import com.auto.script.util.ScriptUrlEnum;
import com.auto.script.util.SendEmailUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.List;
 
/**
 * @author ：bigearchart
 * @date ：Created in 2021/4/1 15:53
 * @description： 定时任务配置实现类
 * @version: 1.0
 */
@Slf4j
@Component
public class QuazrtAutoServiceImpl implements QuazrtAutoService {
 
    @Value(value = "${emailParams:}")
    private String[] emailParams;
 
    @Resource
    private ScriptUrlEnum scriptUrlEnum;
    @Resource
    private SendEmailUtils sendEmailUtils;
 
    /**
     * 定时任务每隔一分钟执行验证接口服务是否正常
     */
    @Override
    @Scheduled(cron = "0 */1 * * * ?")
    public void autoCrontab() {
        try{
            //读取配置接口参数
            List<ScriptUrl> url = scriptUrlEnum.getUrl();
 
            //循环测试接口
            for (ScriptUrl scriptUrl: url) {
                String urlStr = scriptUrl.getUrl();
                String type = scriptUrl.getType();
                //验证参数非空
                if(StrUtil.hasEmpty(urlStr, type)){
                    throw new RuntimeException("接口路径、请求类型不能为空，返回结果为空");
                }
 
                log.info("============================本次测试接口【" + urlStr +"】==================");
 
                //参数转json字符串
                String paramsStr = JSONObject.toJSONString(scriptUrl.getParams());
 
                String jsonStr = null;
                //验证请求类型
                if(type.equals("post")){
                    //进行接口交互
                    jsonStr = HttpUtil.post(scriptUrl.getUrl(), paramsStr);
                }else{
                    //验证参数是否为空
                    if(scriptUrl.getParams().isEmpty() || scriptUrl.getParams().size() <= 0){
                        //进行接口交互
                        jsonStr = HttpUtil.get(scriptUrl.getUrl()).toString();
                    }else {
                        //进行接口交互
                        jsonStr = HttpUtil.get(scriptUrl.getUrl(), scriptUrl.getParams());
                    }
 
                }
 
                log.info("=============================接口返回结果为:" );
                log.info(jsonStr);
 
                //验证返回结果是否为空
                if(StrUtil.isEmpty(jsonStr)){
                    throw new RuntimeException("接口路径为【" + urlStr + "】的接口，返回结果为空");
                }
 
                //解析返回结果
                JSONObject jsonObject = JSONObject.parseObject(jsonStr);
                //获取响应码
                String code = jsonObject.get("code").toString();
                //判断响应码是否正确
                if(StrUtil.isEmpty(code) || ! code.equals("200")){
                    throw new RuntimeException("接口路径为【" + urlStr + "】的接口请求错误，接口返回结果为:" + jsonStr);
                }
            }
 
        }catch (Exception e){
            //发送邮件
            sendEmail(e.getMessage());
            //控制台输出
            log.info(e.toString());
        }
    }
 
    /**
     * 封装邮件参数方法
     * @param msg --- 发送文本
     */
    public void sendEmail(String msg){
        //循环待发送邮件集合
        for (String email: emailParams ) {
            //非空情况再执行
            if(StrUtil.isNotEmpty(email)){
                sendEmailUtils.sendEmil(email, "接口测试告警邮件", msg);
            }
        }
 
    }
}

五、启动类配置
#在启动类添加相关配置
# @EnableScheduling --- 开启对定时任务支持
# @EnableAsync --- 开启异步注解支持

/**
 * @Description: 定时任务实现自动执行接口测试项目启动类
 * @Author: bigearchart
 * @Date: 2021/4/1
 * @return
 */
@SpringBootApplication
@EnableScheduling
@EnableAsync
public class ScriptApplication {
 
    public static void main(String[] args) {
        SpringApplication.run(ScriptApplication.class, args);
    }
 
}

六、启动项目
#项目启动后，查看控制台输出结果

#静等一分钟就可以看到接口请求的输出信息

#然后查看邮箱会收到一封告警邮件

 

 

本次的学习到这里就结束了，会根据实际使用更新文章。

如果对您有帮助 请点个关注，万分感谢
项目源码地址：
https://gitee.com/bigearchart_admin/script.git



原文链接：http://www.cnblogs.com/bigearchart/p/14610549.html

职业生涯热门文章

  • 2019 上半年软件设计师真题及参考答案
  • 读哪些书可以提高思维逻辑和语言表达能力？
  • 那些年踩过的坑之Redis报错:All sentinels down, cannot determine where is mymaster master is running...
  • 个人整理可编辑PDF电子书下载（持续更新）
  • ThoughtWorks 面试三连挂，以后再也不去了
  • 个人总结2019 ASP.NET面试题
  • 2019计算机专业408考研经验帖
  • 记一次灰产创业史
  • 巴菲特、比尔·盖茨都在遵循的成功法则
  • Thief-Book 上班摸鱼神器

    • 职业生涯推荐文章

  • Springboot进行Http接口交互实现邮件告警
  • 5 个简单的投资技巧：了解行业，不要频繁操作
  • Unity 基于 WebRTC 的云功能
  • 头条面试题：求用户在线峰值和持续时间
  • JVM学习笔记之class文件结构【七】
  • 有多少人跳完槽后悔了？
  • 坚持年初设下的目标，试试这 5 条小技巧吧
  • 养成新习惯更好的办法：回归纸笔打卡
  • 那些年我们一起追过的大佬
  • Picgo + Gitee +Typora（自动上传）搭建markdown免费图库
    •  友情链接： NPS