Java項目啟動成功、失敗信息實時反饋提醒問題(郵件或者短信)

更新時間：2024年06月12日 09:47:12 作者：程序猿楊鮑

這篇文章主要介紹了Java項目啟動成功、失敗信息實時反饋提醒問題(郵件或者短信),具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

場景說明

1、純后臺應用，現(xiàn)在項目基本都是前后端分離，因為一個前端服務可能會對應多個后端服務的支持，隨著整個開發(fā)大環(huán)境的完善和技術的成熟，之前那種前后端耦合的應用很少，這里不在做具體的考慮。

2、項目的基本架構是Spring+Spring MVC+Mybatis，其實主要是Spring+Spring MVC，因為下面的實現(xiàn)方式在這種模式下模擬，其他環(huán)境可以根據(jù)這個模式仿照，但是照搬可能存在問題，因為現(xiàn)在很多公司都開始使用SpringBoot相關的前沿技術。

3、環(huán)境說明

本地測試環(huán)境，就是IDEA的啟動測試，不多說；
開發(fā)測試環(huán)境，這個環(huán)境基本用來聯(lián)調，開發(fā)人員發(fā)布項目使用的；
測試環(huán)境，這個是測試人員來用，將開發(fā)的代碼拉到測試環(huán)境，進行各種姿勢的測試；
演示環(huán)境，這個環(huán)境看各個公司的定義可能不同，也就是上線前的最后一個環(huán)境，基本模擬線上環(huán)境，最終驗證項目的完整性，有時候所說的灰度、冒煙測試都會在這個環(huán)境執(zhí)行；
線上環(huán)境，不解釋。

4、下面的內容數(shù)據(jù)自己歪歪，如果存在問題，歡迎提建議。

簡單實現(xiàn)的幾種方式

在項目中添加一個主頁，當發(fā)布完成后，訪問該頁面是OK就表示發(fā)布成功，反之就是失敗，但是這樣存在很多問題，比如在線上環(huán)境，這個頁面可能就訪問不到(純后臺應用可能不會提供這個訪問功能)。在本地測試和開發(fā)環(huán)境可以湊合使用。

定時任務請求項目，這個不僅能監(jiān)控到項目啟動是否成功，也可以監(jiān)控服務器宕機問題，但是也存在問題，那就是要重新開一個項目，用于發(fā)送請求，另外當項目啟動的時候，剛好定時任務發(fā)起，此時是請求不通的，系統(tǒng)會誤報啟動失敗或者宕機，其實不是這樣。

日志掃描，通過對日志的分析查看日志中的異常，并做分析，給予開發(fā)或者維護人員一個通知，可以通過Python腳本等方式執(zhí)行，設計到整體項目架構的問題，不做太多的討論，也不是這個博客的主要討論范疇，不做太多贅述。

項目中添加邏輯代碼，用于捕獲項目啟動加載是否正常，從而判斷項目是否啟動成功。(主要討論)

項目啟動反饋提醒實現(xiàn)

web.xml文件中的配置

<servlet>
    <servlet-name>spring-dispatcher</servlet-name>
    <servlet-class>com.minuor.service.notice.LocalDispatcherServletDemo</servlet-class>
    <!-- 配置SpringMVC需要加載的配置文件 spring-xxx.xml -->
    <init-param>
      <param-name>contextConfigLocation</param-name>
      <param-value>classpath:spring-web.xml</param-value>
    </init-param>
    <load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
	<servlet-name>spring-dispatcher</servlet-name>
	<!--默認匹配所有的請求 -->
	<url-pattern>/</url-pattern>
</servlet-mapping>

正常應該配置spring默認的DispatcherServlet，這里需要改為加載重新后的LocalDispatcherServletDemo。

LocalDispatcherServletDemo類代碼

package com.minuor.service.notice;

import com.minuor.common.utils.JavaMailSendUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationContext;
import org.springframework.context.i18n.LocaleContext;
import org.springframework.web.context.WebApplicationContext;
import org.springframework.web.context.support.XmlWebApplicationContext;
import org.springframework.web.multipart.MultipartException;
import org.springframework.web.servlet.*;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.net.InetAddress;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Locale;
import java.util.Map;

/**
 * @Author: Joker
 * @Date: 2018/3/19
 * @Desc: 重寫DispatcherServlet，做系統(tǒng)啟動成功失敗監(jiān)控并通知
 */
@Slf4j
public class LocalDispatcherServletDemo extends DispatcherServlet {

    public LocalDispatcherServletDemo() {
        super();
    }

    public LocalDispatcherServletDemo(WebApplicationContext webApplicationContext) {
        super(webApplicationContext);
    }

    @Override
    protected WebApplicationContext initWebApplicationContext() {
        WebApplicationContext webApplicationContext;
        try {
            webApplicationContext = super.initWebApplicationContext();
            sendMsg(Boolean.TRUE);
            log.info(">>>>>>>webApplicationContext初始化成功~");
        } catch (Exception e) {
            sendMsg(Boolean.FALSE);
            webApplicationContext = new XmlWebApplicationContext();//設置臨時值，避免重復初始化
            log.info(">>>>>>>webApplicationContext初始化失敗~");
        }
        return webApplicationContext;
    }

    /**
     * 發(fā)送郵件
     *
     * @param flag
     */
    private void sendMsg(boolean flag) {
        try {
            JavaMailSendUtil sender = new JavaMailSendUtil();
            //成功失敗信息
            String result = "FAIL";
            if (flag) result = "SUCCESS";
            //模塊名
            String ip = InetAddress.getLocalHost().getHostAddress();
            String userDir = System.getProperty("user.dir");
            String tempStr = userDir.substring(0, userDir.indexOf(File.separator + "bin"));
            String userDirModel = tempStr.substring(tempStr.lastIndexOf(File.separator) + 1);
            //組裝并推送信息
            String mailTest = "發(fā)布系統(tǒng)：" + "Minuor個人博客系統(tǒng)" + "<br/>" +
                    "發(fā)布環(huán)境：" + ip + "<br/>" +
                    "模塊名稱：" + userDirModel + "<br/>" +
                    "發(fā)布時間：" + new SimpleDateFormat("yyyyMMdd HH:mm:ss").format(new Date()) + "<br/>" +
                    "發(fā)布結果：" + result + "<br/>" +
                    "溫馨提示：" + "此郵件僅為系統(tǒng)發(fā)布通知郵件，請勿回復！";
            sender.sendEmail("個人博客系統(tǒng)發(fā)布結果提醒", mailTest, "xxxx@163.com");
        } catch (Exception e) {
            log.info(">>>>>個人博客系統(tǒng)發(fā)布結果預警郵件推送失??！異常信息：{}", e);
        }
    }

    @Override
    public void setDetectAllHandlerMappings(boolean detectAllHandlerMappings) {
        super.setDetectAllHandlerMappings(detectAllHandlerMappings);
    }

    @Override
    protected void initFrameworkServlet() throws ServletException {
        super.initFrameworkServlet();
    }

    @Override
    public void setDetectAllHandlerAdapters(boolean detectAllHandlerAdapters) {
        super.setDetectAllHandlerAdapters(detectAllHandlerAdapters);
    }

    @Override
    public void setDetectAllHandlerExceptionResolvers(boolean detectAllHandlerExceptionResolvers) {
        super.setDetectAllHandlerExceptionResolvers(detectAllHandlerExceptionResolvers);
    }

    @Override
    public void setDetectAllViewResolvers(boolean detectAllViewResolvers) {
        super.setDetectAllViewResolvers(detectAllViewResolvers);
    }

    @Override
    public void setThrowExceptionIfNoHandlerFound(boolean throwExceptionIfNoHandlerFound) {
        super.setThrowExceptionIfNoHandlerFound(throwExceptionIfNoHandlerFound);
    }

    @Override
    public void setCleanupAfterInclude(boolean cleanupAfterInclude) {
        super.setCleanupAfterInclude(cleanupAfterInclude);
    }

    @Override
    protected void onRefresh(ApplicationContext context) {
        super.onRefresh(context);
    }

    @Override
    protected void initStrategies(ApplicationContext context) {
        super.initStrategies(context);
    }

    @Override
    protected <T> T getDefaultStrategy(ApplicationContext context, Class<T> strategyInterface) {
        return super.getDefaultStrategy(context, strategyInterface);
    }

    @Override
    protected <T> List<T> getDefaultStrategies(ApplicationContext context, Class<T> strategyInterface) {
        return super.getDefaultStrategies(context, strategyInterface);
    }

    @Override
    protected Object createDefaultStrategy(ApplicationContext context, Class<?> clazz) {
        return super.createDefaultStrategy(context, clazz);
    }

    @Override
    protected void doService(HttpServletRequest request, HttpServletResponse response) throws Exception {
        super.doService(request, response);
    }

    @Override
    protected void doDispatch(HttpServletRequest request, HttpServletResponse response) throws Exception {
        super.doDispatch(request, response);
    }

    @Override
    protected LocaleContext buildLocaleContext(HttpServletRequest request) {
        return super.buildLocaleContext(request);
    }

    @Override
    protected HttpServletRequest checkMultipart(HttpServletRequest request) throws MultipartException {
        return super.checkMultipart(request);
    }

    @Override
    protected void cleanupMultipart(HttpServletRequest request) {
        super.cleanupMultipart(request);
    }

    @Override
    protected HandlerExecutionChain getHandler(HttpServletRequest request) throws Exception {
        return super.getHandler(request);
    }

    @Override
    protected void noHandlerFound(HttpServletRequest request, HttpServletResponse response) throws Exception {
        super.noHandlerFound(request, response);
    }

    @Override
    protected HandlerAdapter getHandlerAdapter(Object handler) throws ServletException {
        return super.getHandlerAdapter(handler);
    }

    @Override
    protected ModelAndView processHandlerException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        return super.processHandlerException(request, response, handler, ex);
    }

    @Override
    protected void render(ModelAndView mv, HttpServletRequest request, HttpServletResponse response) throws Exception {
        super.render(mv, request, response);
    }

    @Override
    protected String getDefaultViewName(HttpServletRequest request) throws Exception {
        return super.getDefaultViewName(request);
    }

    @Override
    protected View resolveViewName(String viewName, Map<String, Object> model, Locale locale, HttpServletRequest request) throws Exception {
        return super.resolveViewName(viewName, model, locale, request);
    }
}

重新所有的方法，直接調用父類DispatcherServlet內的邏輯，實際LocalDispatcherServletDemo中沒有具體的邏輯，只有構造方法、initWebApplicationContext、sendMsg短信發(fā)送邏輯的修改和創(chuàng)建。

JavaMailSendUtil郵件發(fā)送邏輯代碼

package com.minuor.common.mail;

import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;

import javax.mail.*;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import java.util.Properties;

/**
 * @Author: Joker
 * @Date: 2018/3/19
 * @Desc: 發(fā)送郵件服務
 */
@Slf4j
public class JavaMailSendUtil {
    /**
     * 發(fā)送郵件
     */
    public void sendEmail(String subject, String mailText, String rStr) {
        try {
            // 1.創(chuàng)建一個程序與郵件服務器會話對象 Session
            Properties props = new Properties();
            props.setProperty("mail.smtp.host", "smtp.163.com");
            props.setProperty("mail.smtp.port", "25");
            // 指定驗證為true
            props.setProperty("mail.smtp.auth", "true");
            // 驗證賬號及密碼，密碼需要是第三方授權碼
            Authenticator auth = new Authenticator() {
                @Override
                protected PasswordAuthentication getPasswordAuthentication() {
                    return new PasswordAuthentication(
                            "xxxx@163.com", "123456");
                }
            };
            Session session = Session.getInstance(props, auth);

            // 2.創(chuàng)建一個Message，它相當于是郵件內容
            Message message = new MimeMessage(session);
            // 設置發(fā)送者
            message.setFrom(new InternetAddress("xxxxx@163.com"));
            // 設置發(fā)送方式與接收者
            if (StringUtils.isBlank(rStr)) return;
            String[] rStrs = rStr.split(",");
            InternetAddress[] address = new InternetAddress[rStrs.length];
            int index = 0;
            for (String str : rStrs) {
                address[index] = new InternetAddress(str);
                index++;
            }
            message.setRecipients(MimeMessage.RecipientType.TO, address);
            // 設置主題
            message.setSubject(subject);
            // 設置內容
            message.setContent(mailText, "text/html;charset=utf-8");
            // 3.創(chuàng)建 Transport用于將郵件發(fā)送
            Transport.send(message);
            log.info(">>>>>>>發(fā)送郵件成功<<<<<<<");
        } catch (Exception e) {
            log.error(">>>>>>>發(fā)送郵件異常：{}", e);
        }
    }
}

封裝的最簡單的發(fā)送方式，只為實現(xiàn)簡單的郵件推送功能。