一、背景

（记录一下自己所做的一些小功能）由于需求的需要，一个项目中可能不止一个服务需要维护，多个服务可能搭建在不同的服务器上。如果其中的某个服务挂掉了，就会影响到部分功能，需要通知开发人员进行故障排除，这时候就需要一个服务的监控告警。

开始打算以发送邮件的形式进行告警通知，但是考虑到不是人人都能时刻注意到邮件。所以选择使用较为方便的钉钉告警机器人。

二、开始准备

到这里，前期的准备工作就做好了。记住第七步的加签会用到。

三、业务代码

?1）添加依赖

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.28</version>
        </dependency>
        <dependency>
            <groupId>com.squareup.okhttp3</groupId>
            <artifactId>okhttp</artifactId>
            <version>3.6.0</version>
        </dependency>

?2）编写发送消息工具类

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import okhttp3.*;
import org.apache.commons.codec.binary.Base64;
import org.springframework.stereotype.Component;

import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import java.io.IOException;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeUnit;

public class DingDingUti {
    private static OkHttpClient mClient;
    private static String url;

    //初始化客户端
    static {
        OkHttpClient.Builder builder = new OkHttpClient.Builder();
        builder.connectTimeout(10L, TimeUnit.SECONDS);
        builder.readTimeout(10L, TimeUnit.SECONDS);
        Dispatcher dispatcher = new Dispatcher();
        dispatcher.setMaxRequestsPerHost(200);
        dispatcher.setMaxRequests(200);
        builder.dispatcher(dispatcher);
        mClient = builder.build();
        try {
            url = getSign();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 通用 POST 请求方法  依赖 OKhttp3
     * @param message 所要发送的消息
     * @return 发送状态回执
     */
    public static String postWithJson(String message) {
        String str="{ \"at\": { \"isAtAll\": true }, \"text\": { \"content\": \" %s \"}, \"msgtype\":\"text\" }"; //这里@为全体成员，可具体@某个人只需加上手机号即可
        String format = String.format(str, message);
        JSONObject jsonObject = JSON.parseObject(format);
        RequestBody body = RequestBody.create(
                MediaType.parse("application/json; charset=utf-8"), jsonObject.toJSONString());
        Request request = new Request.Builder().url(url).post(body).build();
        try {
            Response response = mClient.newCall(request).execute();
            if (response.body() != null) {
                return response.body().string();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 获取签名
     * @return 返回签名
     */
    private static String getSign() throws Exception {
        String baseUrl = "https://oapi.dingtalk.com/robot/send?access_token=";
        String token = "5730c69d3427fdsafdsdfds05cdcb09523354c01fbb3da02562e4c945d"; //钉钉官方所获取的token
        String secret = "SEC3a1306217fdsfsddf653da96f38fdafdsfd193c7a40212d1f1c406"; //前期准备中的加签
        long timestamp = System.currentTimeMillis();
        String stringToSign = timestamp + "\n" + secret;
        Mac mac = Mac.getInstance("HmacSHA256");
        mac.init(new SecretKeySpec(secret.getBytes(StandardCharsets.UTF_8), "HmacSHA256"));
        byte[] signData = mac.doFinal(stringToSign.getBytes(StandardCharsets.UTF_8));
        return baseUrl + token + "&timestamp=" + timestamp + "&sign=" +
                URLEncoder.encode(new String(Base64.encodeBase64(signData)), "UTF-8");
    }

}

?上叙工具类，只需要修改相应的机器人加签及token，传入想要发送的内容即可。（这里采用的是定时任务的方案，通过定时任务去访问某一个接口，若返回200则说明服务正常）