1. 创建钉钉群机器人

通过钉钉PC客户端进入，选择钉钉群，依次进入：“群设置”/“智能群助手”/“添加机器人”，之后选择“自定义”方式，通过Webhook接入自定义服务。
image.png
说明：此处安全设置以“自定义关键词”为例，设定后，只有包含关键词的消息内容才会被正常发送。

2. 获取机器人令牌

设置群机器人成功后，依次进入：“群设置”/“智能群助手”，之后选择自定义的机器人，即可查看到Webook地址信息，其中就包含令牌参数信息（https://oapi.dingtalk.com/robot/send?access_token=31f7005ecd6ec1775d085b4cbdc18a4639d999063a9ff3ead38d245b7e7xxxxx）。
image.png

3. 应用程序集成

通过Webhook提供的${access_token}可通过多种方式，向钉钉群发送消息，包括：HttpClient、OkHttp、Dingtalk SDK等。
应用工程依赖：

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <modelVersion>4.0.0</modelVersion>
  7.     <groupId>dingtalk-webhook-demo</groupId>
  8.     <artifactId>org.polaris.dingtalk.webhook</artifactId>
  9.     <version>1.0.0</version>
  11.     <properties>
  12.         <!-- 操作json格式数据的相应的框架 -->
  13.         <fastjson.version>1.2.29</fastjson.version>
  14.         <!-- 日志框架log4j,以及升级版 logback对应的版本号 -->
  15.         <logback.version>1.1.11</logback.version>
  16.         <slf4j.version>1.7.25</slf4j.version>
  17.     </properties>
  19.     <repositories>
  20.         <repository>
  21.             <id>sonatype-nexus-staging</id>
  22.             <name>Sonatype Nexus Staging</name>
  23.             <url>https://oss.sonatype.org/service/local/staging/deploy/maven2/</url>
  24.             <releases>
  25.                 <enabled>true</enabled>
  26.             </releases>
  27.             <snapshots>
  28.                 <enabled>true</enabled>
  29.             </snapshots>
  30.         </repository>
  31.     </repositories>
  33.     <dependencies>
  34.         <dependency>
  35.             <groupId>com.alibaba</groupId>
  36.             <artifactId>fastjson</artifactId>
  37.             <version>${fastjson.version}</version>
  38.         </dependency>
  39.         <dependency>
  40.             <groupId>com.squareup.okhttp</groupId>
  41.             <artifactId>okhttp</artifactId>
  42.             <version>2.7.5</version>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>com.aliyun</groupId>
  46.             <artifactId>alibaba-dingtalk-service-sdk</artifactId>
  47.             <version>1.0.1</version>
  48.         </dependency>
  49.         <dependency>
  50.             <groupId>org.apache.httpcomponents</groupId>
  51.             <artifactId>httpclient</artifactId>
  52.             <version>4.5.3</version>
  53.             <exclusions>
  54.                 <exclusion>
  55.                     <artifactId>commons-logging</artifactId>
  56.                     <groupId>commons-logging</groupId>
  57.                 </exclusion>
  58.             </exclusions>
  59.         </dependency>
  60.         <!-- 日志jar包依赖 -->
  61.         <dependency>
  62.             <groupId>org.slf4j</groupId>
  63.             <artifactId>slf4j-api</artifactId>
  64.             <version>${slf4j.version}</version>
  65.         </dependency>
  66.         <dependency>
  67.             <groupId>ch.qos.logback</groupId>
  68.             <artifactId>logback-classic</artifactId>
  69.             <version>${logback.version}</version>
  70.             <scope>${scope}</scope>
  71.             <exclusions>
  72.                 <exclusion>
  73.                     <artifactId>slf4j-api</artifactId>
  74.                     <groupId>org.slf4j</groupId>
  75.                 </exclusion>
  76.             </exclusions>
  77.         </dependency>
  78.         <dependency>
  79.             <groupId>ch.qos.logback</groupId>
  80.             <artifactId>logback-core</artifactId>
  81.             <version>${logback.version}</version>
  82.             <scope>${scope}</scope>
  83.         </dependency>
  84.     </dependencies>
  86. </project>

1. HttpClient

  1. public class SendMsgToDingtalkHttpClient {
  3.     private static final Logger log = LoggerFactory.getLogger(SendMsgToDingtalkHttpClient.class);
  5.     public static final String WEBHOOK_TOKEN = "https://oapi.dingtalk.com/robot/send?access_token=31f7005ecd6ec1775d085b4cbdc18a4639d999063a9ff3ead38d245b7xxxxx";
  7.     public static void main(String args[]) throws IOException {
  8.         // 配置了Webhook机器人关键字“告警测试”，则消息中需要携带，否则无法发出
  9.         // 更多配置请参考：https://ding-doc.dingtalk.com/doc#/serverapi2/qf2nxq
  10.         HttpClient httpclient = HttpClients.createDefault();
  11.         HttpPost httppost = new HttpPost(WEBHOOK_TOKEN);
  12.         httppost.addHeader("Content-Type", "application/json; charset=utf-8");
  13.         // 构建一个json格式字符串textMsg，其内容是接收方需要的参数和消息内容
  14.         String textMsg = "{\"msgtype\":\"text\",\"text\":{\"content\":\"告警测试：This is a warning test.\"},\"at\":{\"atMobiles\":[\"13632608950\"],\"isAtAll\":false}}";
  15.         StringEntity se = new StringEntity(textMsg, "utf-8");
  16.         httppost.setEntity(se);
  17.         HttpResponse response = httpclient.execute(httppost);
  18.         if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
  19.             String result = EntityUtils.toString(response.getEntity(), "utf-8");
  20.             log.info(result);
  21.         } else {
  22.             log.error("error code：" + response.getStatusLine().getStatusCode());
  23.         }
  24.     }
  26. }

2. OkHttp

  1. public class SendMsgToDingtalkOkHttp {
  3.     private static final Logger log = LoggerFactory.getLogger(SendMsgToDingtalkOkHttp.class);
  5.     private static final MediaType JSON = MediaType.parse("application/json;charset=utf-8");
  6.     public static final String ALERT_MSG_ROBOT_ID = "https://oapi.dingtalk.com/robot/send?access_token=31f7005ecd6ec1775d085b4cbdc18a4639d999063a9ff3ead38d245b7e7xxxxx";
  8.     public static void main(String[] args) {
  9.         // 配置了Webhook机器人关键字“告警测试”，则消息中需要携带，否则无法发出
  10.         // 更多配置请参考：https://ding-doc.dingtalk.com/doc#/serverapi2/qf2nxq
  11.         String msg = String.format("告警测试：%s", "This is a warning test.");
  12.         if (sendMsg(ALERT_MSG_ROBOT_ID, msg)) {
  13.             log.info("发送消息到钉钉成功!");
  14.         }
  15.     }
  17.     /**
  18.      * 发送机器人消息
  19.      */
  20.     public static boolean sendMsg(String robotId, String msg) {
  21.         JSONObject text = new JSONObject();
  22.         text.put("content", msg);
  24.         JSONObject object = new JSONObject();
  25.         object.put("msgtype", "text");
  26.         object.put("text", text);
  28.         OkHttpClient okHttpClient = new OkHttpClient();
  29.         RequestBody requestBody = RequestBody.create(JSON, object.toJSONString());
  30.         Request request = new Request.Builder().url(robotId).post(requestBody).build();
  32.         try {
  33.             Response response = okHttpClient.newCall(request).execute();
  34.             return response.isSuccessful();
  35.         } catch (Exception e) {
  36.             log.error(String.format("发送Webhook[%s,%s]失败：" + e.getMessage(), robotId, msg));
  37.             return false;
  38.         }
  39.     }
  40. }

3. Dingtalk SDK

  1. public class SendMsgToDingtalkSDK {
  3.     private static final Logger log = LoggerFactory.getLogger(SendMsgToDingtalkSDK.class);
  5.     private static final MediaType JSON = MediaType.parse("application/json;charset=utf-8");
  6.     public static final String ALERT_MSG_ROBOT_ID = "https://oapi.dingtalk.com/robot/send?access_token=31f7005ecd6ec1775d085b4cbdc18a4639d999063a9ff3ead38d245b7e7xxxxx";
  8.     public static void main(String[] args) throws ApiException {
  9.         // 配置了Webhook机器人关键字“告警测试”，则消息中需要携带，否则无法发出
  10.         // 更多配置请参考：https://ding-doc.dingtalk.com/doc#/serverapi2/qf2nxq
  11.         // 图片消息需要确保图片路径可访问
  12.         String msg = "#### xxx大数据平台 @13632608950\n" +
  13.                 "> 内存使用率：84%\n\n" +
  14.                 "> ![screenshot](https://timgsa.baidu.com/timg?image&quality=80&size=b9999_10000&sec=1595400380087&di=1d5656aa2d536eec8c11a827e43610a1&imgtype=0&src=http%3A%2F%2Fimg0.imgtn.bdimg.com%2Fit%2Fu%3D684369095%2C514272752%26fm%3D214%26gp%3D0.jpg)\n" +
  15.                 "> ###### 10点20分发布 [告警测试](https://www.seniverse.com/) \n";
  16.         if (sendMsg(ALERT_MSG_ROBOT_ID, msg)) {
  17.             log.info("发送消息到钉钉成功!");
  18.         }
  19.     }
  21.     /**
  22.      * 发送机器人消息
  23.      */
  24.     public static boolean sendMsg(String robotId, String msg) throws ApiException {
  25.         DingTalkClient client = new DefaultDingTalkClient(robotId);
  26.         OapiRobotSendRequest request = new OapiRobotSendRequest();
  27.         request.setMsgtype("markdown");
  28.         OapiRobotSendRequest.Markdown markdown = new OapiRobotSendRequest.Markdown();
  29.         markdown.setTitle("告警测试");
  30.         markdown.setText(msg);
  31.         request.setMarkdown(markdown);
  32.         OapiRobotSendResponse response = client.execute(request);
  33.         return response.isSuccess();
  34.     }
  35. }