<!-- http請(qǐng)求工具 -->
<dependency>
    <groupId>com.dtflys.forest</groupId>
    <artifactId>forest-spring-boot-starter</artifactId>
    <version>1.5.14</version>
</dependency>

## 輕量級(jí)HTTP客戶端框架forest
forest:
  # 配置底層API為 okhttp3
  backend: okhttp3
  # 連接池最大連接數(shù)，默認(rèn)值為500
  max-connections: 1000
  # 每個(gè)路由的最大連接數(shù)，默認(rèn)值為500
  max-route-connections: 500
  # 請(qǐng)求超時(shí)時(shí)間，單位為毫秒, 默認(rèn)值為3000
  timeout: 3000
   # 連接超時(shí)時(shí)間，單位為毫秒, 默認(rèn)值為2000
  connect-timeout: 3000
   # 請(qǐng)求失敗后重試次數(shù)，默認(rèn)為0次不重試
  retry-count: 1
   # 單向驗(yàn)證的HTTPS的默認(rèn)SSL協(xié)議，默認(rèn)為SSLv3
  ssl-protocol: SSLv3
   # 打開(kāi)或關(guān)閉日志，默認(rèn)為true
  logEnabled: true
   # 打開(kāi)/關(guān)閉Forest請(qǐng)求日志（默認(rèn)為 true）
  log-request: true
   # 打開(kāi)/關(guān)閉Forest響應(yīng)狀態(tài)日志（默認(rèn)為 true）
  log-response-status: true
   # 打開(kāi)/關(guān)閉Forest響應(yīng)內(nèi)容日志（默認(rèn)為 false）
  log-response-content: true

import com.dtflys.forest.annotation.JSONBody;
import com.dtflys.forest.annotation.Post;
import com.dtflys.forest.annotation.Var;

import java.util.Map;

public interface WechatClient {

    @Post(
            url = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key={key}",
            headers = {
                    "Accept-Charset: utf-8",
                    "Content-Type: application/json"
            },
            dataType = "json")
    void sendWechatMsg(@Var("key") String key, @JSONBody Map<String, Object> body);
}

@Resource
private WechatClient wechatClient;

/**
 * 發(fā)送文本消息
 */
public void sendTextMsg() {
    Map<String, Object> map = new HashMap<>();
    map.put("msgtype", "text");
    Map<String, String> content = new HashMap<>();
    content.put("content", "hello world!");
    map.put("text", content);
    wechatClient.sendWechatMsg("xxxxxxxxxxxxxxxxxx", map);
}

content.put("content", "hello world!<@zhangsan>");

/**
 * 發(fā)送md消息
 */
public void sendMarkdownMsg() {
    Map<String, Object> map = new HashMap<>();
    map.put("msgtype", "markdown");
    Map<String, String> content = new HashMap<>();
    content.put("content", "實(shí)時(shí)新增用戶反饋<font color=\\\"warning\\\">132例</font>，請(qǐng)相關(guān)同事注意。\\n\n" +
            "         >類型:<font color=\\\"comment\\\">用戶反饋</font>\n" +
            "         >普通用戶反饋:<font color=\\\"comment\\\">117例</font>\n" +
            "         >VIP用戶反饋:<font color=\\\"comment\\\">15例</font>");
    map.put("markdown", content);
    wechatClient.sendWechatMsg("xxxxxxxxxxxxxxxxxx", map);
}

/**
 * 發(fā)送圖片消息
 */
public void sendImageMsg() {
    String url = "C:\\Users\\admin\\Desktop\\test.png";
    Map<String, Object> map = new HashMap<>();
    map.put("msgtype", "image");
    Map<String, String> content = new HashMap<>();
    content.put("md5", getMd5(url));
    content.put("base64", getBase64(url));
    map.put("image", content);
    wechatClient.sendWechatMsg("xxxxxxxxxxxxxxxxxx", map);
}

/**
 * 圖片轉(zhuǎn)為base64編碼
 */
public static String getBase64(String imgFile) {
    InputStream in = null;
    byte[] data = null;
    //  讀取圖片字節(jié)數(shù)組
    try {
        in = new FileInputStream(imgFile);
        data = new byte[in.available()];
        in.read(data);
        in.close();
    } catch (IOException e) {
        e.printStackTrace();
    }
    // 對(duì)字節(jié)數(shù)組Base64編碼
    BASE64Encoder encoder = new BASE64Encoder();
    // 返回Base64編碼過(guò)的字節(jié)數(shù)組字符串
    return encoder.encode(data);
}

/**
 * 獲取文件的MD5值
 *
 * @param path
 * @return
 */
public static String getMd5(String path) {
    try {
        MessageDigest md5 = MessageDigest.getInstance("MD5");
        FileInputStream fis = new FileInputStream(path);
        byte[] buffer = new byte[1024];
        int len;
        while ((len = fis.read(buffer)) != -1) {
            md5.update(buffer, 0, len);
        }
        fis.close();
        byte[] byteArray = md5.digest();
        StringBuilder sb = new StringBuilder();
        for (byte b : byteArray) {
            sb.append(String.format("%02x", b));
        }
        return sb.toString();
    } catch (IOException | NoSuchAlgorithmException e) {
        e.printStackTrace();
    }
    return null;
}

content.put("base64", getBase64(url).replaceAll("\r|\n", ""));

/**
 * 發(fā)送圖文消息
 */
public void sendNewsMsg() {
    Map<String, Object> map = new HashMap<>();
    map.put("msgtype", "news");
    Map<String, Object> content = new HashMap<>();
    List<Map<String, Object>> list = new ArrayList<>();
    Map<String, Object> obj = new HashMap<>();
    obj.put("title", "中秋節(jié)禮品領(lǐng)取");
    obj.put("description", "今年中秋節(jié)公司有豪禮相送");
    obj.put("url", "www.qq.com");
    obj.put("picurl", "http://res.mail.qq.com/node/ww/wwopenmng/images/independent/doc/test_pic_msg1.png");
    list.add(obj);
    content.put("articles", list);
    map.put("news", content);
    wechatClient.sendWechatMsg("xxxxxxxxxxxxxxxxxx", map);
}