标签：content shell http String text 机器人 发送 static import

一、前言

服务器上有时 定时任务、重要接口 等出现异常，导致数据不正常，不能及时通知到服务负责人，及时处理问题。所以引入“钉钉”作为通知工具，当服务出现异常便可立即收到通知，及时处理！
二、使用方式
1、客户端配置机器人
1.1首先需要有阿里巴巴的“钉钉”客户端

1.2、建立群聊（如果只想通知给自己，不想通知其他人，也可以与他们创建群聊之后再将他们踢出）

 

 

1.3、点击“群设置”里面的“智能群助手”

1.4、“添加机器人”

 

 

 1.5、自定义

 

 

 1.6、给机器人取个名字，注意：后续的消息体中必须要包含设置的“自定义关键词”，消息才能发送成功。

 

 

 1.7、点击“完成”后会得到一个webhook，把这个webhook复制出来，一会儿代码中要用，

类似这样的：https://oapi.dingtalk.com/robot/send?access_token=880e6b7********************************************97d5e

 

 

 1.8、点击“完成”之后会收到这样一条消息，说明机器人配置完成了，接下来就是代码了

 

2.消息类型及数据格式

2.1 文本类型（text）

参数	必选	类型	说明
msgtype	true	string	此消息类型为固定text
content	true	string	内容消息
atMobiles	false	string	被@人手机号
isAtall	false	bool	@所有人时为ture，否则为false

{
     "msgtype": "text",
     "text": {
         "content": "我是陈十六，请多指教@156****16**"
     },
     "at": {
         "atMobiles": [
             "1825718XXXX"
         ], 
         "isAtAll": false
     }
 }

 

 

 2.2 link类型

参数	必选	类型	说明
msgtype	true	string	此消息类型为固定link
title	true	string	消息标题
text	true	string	内容消息，如果太长只会显示一部分
messageUrl	true	string	点击消息跳转的url
picUrl	false	string	图片url

 

{
    "msgtype": "link", 
    "link": {
        "text":"link是以连接的形式发送消息。", 
       "title": "连接的主题", 
        "picUrl": "", 
        "messageUrl": "复制的机器人的Webhoot"
    }
}

 

2.3、markdown类型

{
     "msgtype": "markdown",
     "markdown": {"title":"杭州天气",
"text":"#### 杭州天气  \n > 9度，@1825718XXXX 西北风1级，空气良89，相对温度73%\n\n > ![screenshot](http://i01.lw.aliimg.com/media/lALPBbCc1ZhJGIvNAkzNBLA_1200_588.png)\n  > ###### 10点20分发布 [天气](http://www.thinkpage.cn/) "
     },
    "at": {
        "atMobiles": [
            "1825718XXXX"
        ], 
        "isAtAll": false
    }
 }

 

 

 

3、通过代码使用机器人发送钉钉消息

a、通过java代码实现

package com.common.util;
 
import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.springframework.util.CollectionUtils;
 
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
/**
 * 钉钉-工具类
 */
@Slf4j
public class DingTalkUtil {
 
    /**
     * 钉钉机器人发消息地址（配置机器人的webhook）
     * 此处大家可以配置到配置文件等等方式
     */
    private static final String MSG_URL = "https://oapi.dingtalk.com/robot/send?access_token=880e6b7********************************************97d5e";
 
    /**
     * 通知具体人
     *
     * @param content    通知内容
     * @param mobileList 通知具体人的手机号码列表
     */
    public static void sendDingTalkMsg(List<String> mobileList, String content) {
        sendDingTalkMsg(false, mobileList, content);
    }
 
    /**
     * 通知所有人
     *
     * @param content 通知内容
     */
    public static void sendDingTalkMsg(String content) {
        sendDingTalkMsg(true, null, content);
    }
 
    /**
     * 发送消息
     *
     * @param content    通知内容
     * @param isAtAll    是否@所有人
     * @param mobileList 通知具体人的手机号码列表
     */
    private static void sendDingTalkMsg(boolean isAtAll, List<String> mobileList, String content) {
        try {
            if (!CollectionUtils.isEmpty(mobileList)) {
                isAtAll = false;
            }
            //消息内容
            Map<String, String> contentMap = new HashMap<>();
            contentMap.put("content", content);
 
            //通知人
            Map<String, Object> atMap = new HashMap<>();
            //1.是否通知所有人
            atMap.put("isAtAll", isAtAll);
            //2.通知具体人的手机号码列表
            atMap.put("atMobiles", mobileList);
 
            Map<String, Object> parameter = new HashMap<>();
            parameter.put("msgtype", "text");
            parameter.put("at", atMap);
            parameter.put("text", contentMap);
 
            //推送消息（http请求）
            String result = HttpUtils.post(MSG_URL, JSON.toJSONString(parameter));
            log.info("发送钉钉消息-result:{}", result);
        } catch (Exception e) {
            log.error("发送钉钉消息异常", e);
        }
    }
 
    public static void main(String[] args) {
//        sendDingTalkMsg("服务通知:测试消息");
        sendDingTalkMsg(Collections.singletonList("189********"), "服务通知:测试消息");
    }
}

另附代码中使用到的HttpUtils

package com.common.util;
 
import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.HttpStatus;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicHeader;
import org.apache.http.util.EntityUtils;
 
import java.io.Closeable;
import java.nio.charset.Charset;
import java.util.Map;
 
/**
 * http请求-工具类
 *
 * @author xiehongwei
 * @date 2020/11/03
 */
@Slf4j
public class HttpUtils {
 
    private static final String UTF_8 = "utf-8";
 
    private static RequestConfig requestConfig;
 
    static {
        requestConfig = RequestConfig.custom()
                .setConnectTimeout(1000)//连接超时时间
                .setSocketTimeout(3000)//读超时时间
                .build();
    }
 
    /**
     * post请求(无参/参数在url上)
     */
    public static String post(String url) throws Exception {
        return post(url, "");
    }
 
    /**
     * post请求
     */
    public static String post(String url, String body) throws Exception {
        CloseableHttpClient httpClient = null;
        CloseableHttpResponse httpResponse = null;
        try {
            httpClient = HttpClients.createDefault();
 
            HttpPost httpPost = new HttpPost(url);
 
            if (StringUtils.isNotBlank(body)) {
                StringEntity se = new StringEntity(body, Charset.forName(UTF_8));
                se.setContentType("text/json");
                se.setContentEncoding(new BasicHeader("Content-Type", "application/json"));
 
                httpPost.setEntity(se);
            }
 
            httpPost.setConfig(requestConfig);
            httpPost.setHeader("Content-Type", "application/json;charset=utf-8");
 
            httpResponse = httpClient.execute(httpPost);
            if (httpResponse.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
                return EntityUtils.toString(httpResponse.getEntity(), UTF_8);
            } else {
                log.error("post请求其它服务失败,statusCode:{}", httpResponse.getStatusLine().getStatusCode());
            }
        } catch (Exception e) {
            log.error("post请求其它服务异常", e);
            throw e;
        } finally {
            close(httpClient);
            close(httpResponse);
        }
        return null;
    }
 
    /**
     * post请求
     */
    public static String post(String url, Map<String, String> parameter) throws Exception {
        return post(url, JSON.toJSONString(parameter));
    }
 
    /**
     * 关闭流
     */
    private static <T extends Closeable> void close(T io) {
        if (io == null) {
            return;
        }
        try {
            io.close();
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }
}

 

shell脚本实现

#!/bin/bash
 
webhook='https://oapi.dingtalk.com/robot/send?access_token=34XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX'
cluster='QQOrder_ERP'
host=`hostname -I | awk '{print $1}'`
vip=$1
 
function SendMsgToDingding() {
  curl $webhook -H 'Content-Type: application/json' -d "
  {
    'msgtype': 'text',
    'text': {
      'content': '集群名称：$cluster\n告警信息：虚拟IP<$vip>已漂移至节点<$host>，请注意\n'
    },
    'at': {
      'isAtAll': true
    }
  }"
}
SendMsgToDingding

 

标签：content,shell,http,String,text,机器人,发送,static,import
来源： https://www.cnblogs.com/zouhong/p/16476137.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。