拦截应用 error日志并发送到钉钉群｜Java 开发实战

/**
 * UnsynchronizedAppenderBase 用于异步处理，不阻塞主线程, 拦截error日志，并发送到钉钉群
 */
@Getter
@Setter
public class SendErrorMsgAppender extends UnsynchronizedAppenderBase<ILoggingEvent> {
    // ILoggingEvent里面是日志的内容
    Layout<ILoggingEvent> layout;
    //自定义配置
    String printString;
    @Override
    public void start() {
        //这里可以做些初始化判断 比如layout不能为null ,
        if (layout == null) {
            addWarn("Layout was not defined");
        }
        //或者写入数据库、redis时的初始化连接等等
        super.start();
    }
    @Override
    public void stop() {
        //释放相关资源，如数据库连接，redis线程池等等
        if (!isStarted()) {
            return;
        }
        super.stop();
    }
    @Override
    public void append(ILoggingEvent event) {
        if (event.getLevel() == Level.ERROR) {
            try {
                var isEnableSendLog = "true".equals(SpringUtil.environment(PropertiesConstant.IS_ENABLE_SEND_LOG));
                if (isEnableSendLog) {
                    //获取服务器Ip，告知哪台服务器抛异常
                    var ip = InetAddress.getLocalHost().getHostAddress();
                    var message = ip + "  " + layout.doLayout(event);
                    sendMsgToDingDing(message);
                }
            } catch (UnknownHostException ignored) {
                addWarn("获取服务器ip失败");
            }
        }
    }
    /**
    * 发送日志消息到钉钉的逻辑
    **/
    private void sendMsgToDingDing(String msg) {
        Text text = new Text();
        text.setContent(msg);
        DdMsgBody msgBody = DdMsgBody.builder().msgtype("text").text(text).build();
        Long timestamp = System.currentTimeMillis();
        String secret = SpringUtil.environment(PropertiesConstant.OAPI_DINGTALK_SECRET);
        var charsetName = "UTF-8";
        // 把timestamp+"\n"+密钥当做签名字符串
        String stringToSign = timestamp + "\n" + secret;
        try {
            // 使用HmacSHA256算法计算签名
            Mac mac = Mac.getInstance("HmacSHA256");
            mac.init(new SecretKeySpec(secret.getBytes(charsetName), "HmacSHA256"));
            byte[] signData = mac.doFinal(stringToSign.getBytes());
            // 最后再把签名参数再进行urlEncode，得到最终的签名（需要使用UTF-8字符集）
            String sign = URLEncoder.encode(Base64.getEncoder().encodeToString(signData), charsetName);
            var paramMap = Map.of("timestamp", timestamp, "sign", sign);
            var sendUrl = RestTemplateUtils.buildGetUrlByMap(SpringUtil.environment(PropertiesConstant.OAPI_DINGTALK_URL), paramMap);
            RestTemplateUtils.executeHttpPost(sendUrl, msgBody);
        } catch (Exception e) {
        }
    }
    @Builder
    @Data
    private static class DdMsgBody {
        private String msgtype;
        private Text text;
        private Markdown markdown;
    }
    @Accessors(chain = true)
    @Data
    private class Markdown {
        private String title;
    }
    @Accessors(chain = true)
    @Data
    private class Text {
        private String content;
    }
}
复制代码

<?xml version="1.0" encoding="UTF-8"?>
<configuration>
    <appender name="sendErrorMsg" class="com.mty.jls.config.SendErrorMsgAppender">
        <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
            <level>INFO</level>
        </filter>
        <layout class="ch.qos.logback.classic.PatternLayout">
            <!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符 -->
            <pattern>%d{yyyy-MM-dd HH:mm:ss} [ %t:%r ] - [ %p ] %m%n</pattern>
        </layout>
    </appender>
    <root level="info">
        <appender-ref ref="stdout"/>
        <appender-ref ref="sendErrorMsg"/>
    </root>
</configuration>
复制代码