java企业微信消息发送工具类
2024-06-01 11:40:12
java企业微信消息发送工具类
用途
基于java实现调用企业微信发送消息，文件，图片。
实现效果
文件列表
| 文件名 | 用途 |
|---|---|
| WechatUtil.java | 企业微信工具类 |
| WechatTest.java | 消息发送测试类 |
| pom.xml | 依赖库 |
WechatUtil.java
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.URL;
import java.util.HashMap;
import java.util.Map;import javax.net.ssl.HttpsURLConnection;import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
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.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import com.alibaba.fastjson.JSONObject;/*** 企业微信工具类** @author hury**/
public class WechatUtil {public static final String CHAR_SET = "utf-8";public static final String TOKEN_API = "https://qyapi.weixin.qq.com/cgi-bin/gettoken";public static final String MSG_SEND_API = "https://qyapi.weixin.qq.com/cgi-bin/message/send";public static final String MEDIA_UPLOAD_API = "https://qyapi.weixin.qq.com/cgi-bin/media/upload";private CloseableHttpClient httpClient;private HttpPost httpPost;private HttpGet httpGet;private static Logger log = LoggerFactory.getLogger(WechatUtil.class);/*** 获取access_token** @param corpid 企业ID* @param corpsecret 应用的凭证密钥* @throws IOException*/public String getToken(String corpid, String corpsecret) throws IOException {httpClient = HttpClients.createDefault();httpGet = new HttpGet(TOKEN_API + "?corpid=" + corpid + "&corpsecret=" + corpsecret);CloseableHttpResponse res = httpClient.execute(httpGet);String resString = "";try {HttpEntity entity = res.getEntity();resString = EntityUtils.toString(entity, "utf-8");EntityUtils.consume(entity);JSONObject jo = JSONObject.parseObject(resString);return jo.getString("access_token");} catch (Exception e) {log.error(e.getMessage());} finally {res.close();}log.debug("resp:{}", resString);return resString;}/*** 发送消息* * @param data post数据* @param token 鉴权token* @return* @throws IOException*/public String sendMsg(String data, String token) throws IOException {httpClient = HttpClients.createDefault();httpPost = new HttpPost(MSG_SEND_API + "?access_token=" + token);httpPost.setEntity(new StringEntity(data, CHAR_SET));CloseableHttpResponse res = httpClient.execute(httpPost);String resString;try {HttpEntity entity = res.getEntity();resString = EntityUtils.toString(entity, CHAR_SET);EntityUtils.consume(entity);} finally {res.close();}log.debug("call [{}], param:{}, res:{}", MSG_SEND_API, data, resString);return resString;}/*** 创建文本消息* * 示例：* * <pre>* {"touser" : "UserID1|UserID2|UserID3","toparty" : "PartyID1|PartyID2","totag" : "TagID1 | TagID2","msgtype" : "text","agentid" : 1,"text" : {"content" : "你的快递已到，请携带工卡前往邮件中心领取。\n出发前可查看<a href=\"http://work.weixin.qq.com\">邮件中心视频实况</a>，聪明避开排队。"},"safe":0,"enable_id_trans": 0,"enable_duplicate_check": 0,"duplicate_check_interval": 1800}* </pre>* * @param touser 指定接收消息的成员，成员ID列表（多个接收者用‘|’分隔，最多支持1000个）。* 特殊情况：指定为"@all"，则向该企业应用的全部成员发送* @param agentid 企业应用的id* @param content 消息内容，最长不超过2048个字节，超过将截断（支持id转译）* * @return*/public String createTextData(String touser, int agentid, String content) {Map<String, Object> data = new HashMap<String, Object>();Map<String, Object> text = new HashMap<String, Object>();data.put("touser", touser);data.put("msgtype", "text");data.put("agentid", agentid);text.put("content", content);data.put("text", text);return JSONObject.toJSONString(data);}/*** 创建文件消息* * 示例：* * <pre>* {"touser" : "UserID1|UserID2|UserID3","toparty" : "PartyID1|PartyID2","totag" : "TagID1 | TagID2","msgtype" : "file","agentid" : 1,"file" : {"media_id" : "1Yv-zXfHjSjU-7LH-GwtYqDGS-zz6w22KmWAT5COgP7o"},"safe":0,"enable_duplicate_check": 0,"duplicate_check_interval": 1800}* </pre>* * @param touser 指定接收消息的成员，成员ID列表（多个接收者用‘|’分隔，最多支持1000个）。* 特殊情况：指定为"@all"，则向该企业应用的全部成员发送* @param agentid 企业应用的id* @param media_id 文件id，可以调用上传临时素材接口获取* * @return*/public String createFileData(String touser, int agentid, String media_id) {Map<String, Object> data = new HashMap<String, Object>();Map<String, Object> file = new HashMap<String, Object>();data.put("touser", touser);data.put("msgtype", "file");data.put("agentid", agentid);file.put("media_id", media_id);data.put("file", file);return JSONObject.toJSONString(data);}/*** 创建图片消息* * 示例：* * <pre>* {"touser" : "UserID1|UserID2|UserID3","toparty" : "PartyID1|PartyID2","totag" : "TagID1 | TagID2","msgtype" : "image","agentid" : 1,"image" : {"media_id" : "MEDIA_ID"},"safe":0,"enable_duplicate_check": 0,"duplicate_check_interval": 1800}* </pre>* * @param touser 指定接收消息的成员，成员ID列表（多个接收者用‘|’分隔，最多支持1000个）。* 特殊情况：指定为"@all"，则向该企业应用的全部成员发送* @param agentid 企业应用的id* @param media_id 图片媒体文件id，可以调用上传临时素材接口获取* * @return*/public String createImageData(String touser, int agentid, String media_id) {Map<String, Object> data = new HashMap<String, Object>();Map<String, Object> image = new HashMap<String, Object>();data.put("touser", touser);data.put("msgtype", "image");data.put("agentid", agentid);image.put("media_id", media_id);data.put("image", image);return JSONObject.toJSONString(data);}/*** 上传临时素材* * <pre>*上传的媒体文件限制*所有文件size必须大于5个字节*图片（image）：10MB，支持JPG,PNG格式*语音（voice） ：2MB，播放长度不超过60s，仅支持AMR格式*视频（video） ：10MB，支持MP4格式*普通文件（file）：20MB* </pre>* * @param fileType 媒体文件类型，分别有图片（image）、语音（voice）、视频（video），普通文件（file）* @param filePath 文件路径* @param token 调用接口凭证* @return media_id 媒体文件上传后获取的唯一标识，3天内有效* @throws Exception*/public String upload(String fileType, String filePath, String token) throws Exception {// 返回结果String result = null;File file = new File(filePath);if (!file.exists() || !file.isFile()) {throw new IOException("文件不存在");}String uploadUrl = MEDIA_UPLOAD_API + "?access_token=" + token + "&type=" + fileType;URL url = new URL(uploadUrl);HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();conn.setRequestMethod("POST");// 以POST方式提交表单conn.setDoInput(true);conn.setDoOutput(true);conn.setUseCaches(false);// POST方式不能使用缓存// 设置请求头信息conn.setRequestProperty("Connection", "Keep-Alive");conn.setRequestProperty("Charset", "UTF-8");// 设置边界String BOUNDARY = "----------" + System.currentTimeMillis();conn.setRequestProperty("Content-Type", "multipart/form-data; boundary=" + BOUNDARY);// 请求正文信息// 第一部分StringBuilder sb = new StringBuilder();sb.append("--");// 必须多两条道sb.append(BOUNDARY);sb.append("\r\n");sb.append("Content-Disposition: form-data;name=\"media\"; filename=\"" + file.getName() + "\"\r\n");sb.append("Content-Type:application/octet-stream\r\n\r\n");// 获得输出流OutputStream out = new DataOutputStream(conn.getOutputStream());// 输出表头out.write(sb.toString().getBytes("UTF-8"));// 文件正文部分// 把文件以流的方式 推送道URL中DataInputStream din = new DataInputStream(new FileInputStream(file));int bytes = 0;byte[] buffer = new byte[1024];while ((bytes = din.read(buffer)) != -1) {out.write(buffer, 0, bytes);}din.close();// 结尾部分byte[] foot = ("\r\n--" + BOUNDARY + "--\r\n").getBytes("UTF-8");// 定义数据最后分割线out.write(foot);out.flush();out.close();if (HttpsURLConnection.HTTP_OK == conn.getResponseCode()) {StringBuffer strbuffer = null;BufferedReader reader = null;try {strbuffer = new StringBuffer();reader = new BufferedReader(new InputStreamReader(conn.getInputStream()));String lineString = null;while ((lineString = reader.readLine()) != null) {strbuffer.append(lineString);}if (result == null) {result = strbuffer.toString();}} catch (IOException e) {e.printStackTrace();} finally {if (reader != null) {reader.close();}}}JSONObject jsonObject = JSONObject.parseObject(result);return jsonObject.getString("media_id");}
}
WechatTest.java
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;/*** 微信消息调用测试类* * @author hury**/
public class WechatTest {private static Logger log = LoggerFactory.getLogger(WechatTest.class);// 企业IDprivate static String corpid = "*****";// 应用的凭证密钥private static String corpsecret = "*****-*****";// 消息接收人private static String touser = "Zhang3";// 企业应用的idprivate static int agentid = 1000003;public static void main(String[] args) {WechatTest wx = new WechatTest();wx.sendText("测试发送企业微信消息@java");wx.sendFile("d:\\security.log");wx.sendImage("d:\\瓢虫.png");}/*** 发送文本* * @param content 文本内容*/public void sendText(String content) {WechatUtil wx = new WechatUtil();try {String token = wx.getToken(corpid, corpsecret);String data = wx.createTextData(touser, agentid, content);String res = wx.sendMsg(data, token);log.info("token >>>" + token);log.info("data >>>" + data);log.info("res >>>" + res);} catch (Exception e) {e.getStackTrace();}}/*** 发送文件* * @param filePath 文件路径*/public void sendFile(String filePath) {WechatUtil wx = new WechatUtil();try {String token = wx.getToken(corpid, corpsecret);String media_id = wx.upload("file", filePath, token);String data = wx.createFileData(touser, agentid, media_id);String res = wx.sendMsg(data, token);log.info("token >>>" + token);log.info("data >>>" + data);log.info("res >>>" + res);} catch (Exception e) {e.getStackTrace();}}/*** 发送图片* * @param filePath 图片路径*/public void sendImage(String filePath) {WechatUtil wx = new WechatUtil();try {String token = wx.getToken(corpid, corpsecret);String media_id = wx.upload("image", filePath, token);String data = wx.createImageData(touser, agentid, media_id);String res = wx.sendMsg(data, token);log.info("token >>>" + token);log.info("data >>>" + data);log.info("res >>>" + res);} catch (Exception e) {e.getStackTrace();}}
}pom.xml
<dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpclient</artifactId><version>4.5.2</version></dependency><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpcore</artifactId><version>4.4.5</version></dependency><!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-api --><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId><version>1.7.25</version></dependency><!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-log4j12 --><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId><version>1.7.25</version><!-- <scope>test</scope> --></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.4</version></dependency>
java企业微信消息发送工具类相关推荐
- 微信企业号和企业微信消息发送区别
原本开发的企业微信的功能,但是有客户使用微信企业号,其他的99%的API都一样,就是主动发送消息有些不通: 微信企业号的消息格式为: text消息 image消息 voice消息 video消息 fi ...
- java访问微信接口发送消息
最近在开发activiti流程的时候有个需求:流程到达每个审批节点后,需要向该节点的审批人发送一个消息,提示有审批需要处理. 参考了一下微信的开发者文档和网络上的一些技术博客,现在记录一下.以便后续继 ...
- java调用企业微信接口发送文件功能
java调用企业微信接口发送文件功能 代码 结合几位大佬的代码后实现此功能:感谢大佬让我完成此功能的实现,如有侵权,立刻删除. 借鉴文章地址: java调用企业微信接口发送消息https://blog ...
- 【Java开发】Java实现企业微信消息推送，通过应用发送
企业微信机器人发送消息 一.可能需要的依赖 二.必须的信息 三.效果展示 四.具体代码 一.可能需要的依赖 之前导依赖的时候没有特别标记,现在分不清哪个是哪个了,应该就在这些里面 <depend ...
- 微信支付、微信企业付款到零钱工具类
微信支付.微信企业付款到零钱工具类 主要依赖:apache httpclient 4.5 jdk1.8 工具类主要功能: xml参数拼接 签名算法实现 post加密请求 import lombok.e ...
- Java企业微信开发-企业微信所有类型消息推送封装
企业微信开发第一步获取AccessToken,企业微信的AccessToken和公众号的不一样,企业微信所有接口调用只需要一个AccessToken,而公众号授权和jssdk是分开的 一.获取企业微信 ...
- Java微信公众号开发之微信素材管理工具类
1.前言 微信公众号在使用接口的时候是通过传入media_id来进行调用的,所以在使用的接口的时候我们往往需要先上传素材,然后拿到微信返回给我们的media_id去调用相关接口,素材管理分为临时素材和 ...
- 企业微信机器人脚本python_python实现企业微信定时发送文本消息的示例代码
企业微信定时发送文本消息 使用工具:企业微信机器人+python可执行文件+计算机管理中的任务计划程序 第一步:创建群机器人 选择群聊,单击鼠标右键,添加群机器人. 建立群机器人后,右键查看机器人,如 ...
- 企业微信开发02-企业微信消息发送
目前公司需要在培训管理系统中向企业微信发送通知.通知类型为文本. 现在的项目是maven管理的多模块形式,所以考虑新增一个模块,在模块中对外提供公共方法,调用企业微信weixin-java-cp中提供 ...
最新文章
- D.Digits 思维dp 取log乘积变成加法
- U-BOOT下使用bootm引导内核方法
- css3动画简介以及动画库animate.css的使用
- 基于Pytorch再次解析AlexNet现代卷积神经网络
- 怎么给电脑设密码_怎么给电脑中重要的文件夹设置密码？
- Oracle数据库知识小结
- Python处理图像五个有趣场景，很实用！
- 基于httpd建立私有CA实现https加密连接
- Android ADT插件更新后程序运行时抛出java.lang.VerifyError异常解决办法
- Vue 3 源码公布
- McAfee ePO4.5 admin账号密码忘记的解决办法
- 判断文件是否存在 VC++
- 警惕那些产生负价值的开发者
- 无常之美·《炉香》-扎西拉姆·多多
- 图着色问题（超详细！！！）
- python 正数变成负数_初一数学上册第一章有理数1.1正数和负数基础知识概括及同步练习题含解析...
- 记一次ARM-鲲鹏服务器读写parquet报错解决过程
- 海龟交易法则（中译文）
- Oracle Partner Levels and Diamond Partners List
- 《录屏工具：真正的两款良心免费开源录屏软件》