java日志
报警 接入钉钉
思路 目前java应用都是大多数使用logback，可以自定logback appender来对日志进行拦截，既然是报警只拦截ERROR即可，具体怎么处理是接入钉钉，还是企业微信，或者邮件根据具体需要处理即可。
@Slf4j
public class DingUtils {
public static Map map = new HashMap<>();
public static RateLimiter rateLimiter = null;
public static AtomicInteger atomicInteger = new AtomicInteger(0);
@Data
public static class KV{
private String k;
private String v;
}
static {
try {
ClassPathResource classPathResource = new ClassPathResource("prop/dingding.properties");
InputStream in = classPathResource.getInputStream();
// File file = new File(url.getPath(), "/prop/dingding.properties");
// FileInputStream in = new FileInputStream(file);
Properties properties = new Properties();
properties.load(in);
Enumeration keys = properties.keys();
int count = 0;
while (keys.hasMoreElements()){
String k = keys.nextElement().toString();
KV kv = new KV();
String value = properties.getProperty(k);
String[] split = value.split("&");
kv.setK(split[0]);
kv.setV(split[1]);
map.put(count++,kv);
}
BigDecimal a = new BigDecimal(map.size() * 20);
BigDecimal v = a.divide(new BigDecimal(60),2,BigDecimal.ROUND_DOWN);
rateLimiter = RateLimiter.create(v.doublevalue());
System.err.println(rateLimiter);
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public static KV getKV(){
//轮询每个机器人 拼接 map = new HashMap<>();
map.put("msgtype","text");
Map body = new HashMap<>();
body.put("content",content);
map.put("text",JSON.toJSonString(body));
String result = HttpUtils.post(dingUrl, map, null);
return result;
} catch (Exception e) {
log.info("钉钉推送消息出现异常 ", e);
return null;
}
}
}
微信扫一扫
支付宝扫一扫
评论列表（0条）