钉钉消息结合链路监控在项目中的应用

痛定思痛。 2022-11-14 10:27 158阅读 0赞

# 官方对接地址 #

[https://developers.dingtalk.com/document/app/custom-robot-access][https_developers.dingtalk.com_document_app_custom-robot-access]

# 第一步：拉一个钉钉群，然后添加一个机器人,获取发送权限 #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA3NzIyMzA_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA3NzIyMzA_size_16_color_FFFFFF_t_70 1][]

添加完成后，会返回发送的地址链接：

[https://oapi.dingtalk.com/robot/send?access\_token=][https_oapi.dingtalk.com_robot_send_access_token]xxxx

注意点：发送内容必须含有自定义关键词，才能发送成功

![20210328223113811.png][]

# 第二步：编写发送钉钉消息代码 #

注意点：content中必须含有  第一步设置的关键词  “告警” 两个字否则发送不成功。

@Component
    @Slf4j
    public class DingDingHelper {
    
        @Resource
        private RestTemplate restTemplate;
        @Autowired
        private EnvHelper envHelper;
    
        @Async
        public void sendAlert(String title, String context) {
            try {
                StringBuffer stringBuffer = new StringBuffer();
                stringBuffer.append("【类型】: ").append("某某项目业务告警").append("\n");
                stringBuffer.append("【标题】: ").append(title).append("\n");
                stringBuffer.append("【环境】: ").append(envHelper.getEnv()).append("\n");
                stringBuffer.append("【链路id】: ").append(TraceContext.traceId()).append("\n");
                stringBuffer.append("【内容】: ").append( context).append("\n");
                stringBuffer.append("【时间】: ").append(DateTimeUtils.toString(LocalDateTime.now())).append("\n");
    
                HashMap<String, Object> text = new HashMap<>(2);
                text.put("content", stringBuffer.toString());
                HashMap<String, Object> params = new HashMap<>(4);
                params.put("msgtype", "text");
                params.put("text", text);
    
                HttpHeaders headers = new HttpHeaders();
                headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
                
                restTemplate.postForEntity("https://oapi.dingtalk.com/robot/send?access_token=xxx",
                            new HttpEntity<>(params, headers), Void.class);
             
            } catch (RestClientException e) {
                log.error("发送钉钉异常={}", e.getMessage());
            }
        }
    
    }

将发送钉钉消息，结合项目和环境链路，可以在程序中打点告警，方便问题及时人工处理和问题的排查。

[https_developers.dingtalk.com_document_app_custom-robot-access]: https://developers.dingtalk.com/document/app/custom-robot-access
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA3NzIyMzA_size_16_color_FFFFFF_t_70]: /images/20221022/3fd846aac38542429cb667bd711355e1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA3NzIyMzA_size_16_color_FFFFFF_t_70 1]: /images/20221022/6b07041452ce460380d4e57a312fa489.png
[https_oapi.dingtalk.com_robot_send_access_token]: https://oapi.dingtalk.com/robot/send?access_token=c0f1a3dca3aa1cd0f43d0821f8a17393db6f56f44bd828440ac045a060a7dfd6
[20210328223113811.png]: /images/20221022/cf7d3194cbff442aa964457e278e6615.png