java-给微信推送消息 利用企业微信

目的：给关注用户推送消息

    场景：自动化测试,运维监控，接口访问等报错预警。例如线上接口报错，发送提醒消息

准备工作：

 1:注册企业号（为什么不用公众号呢？）

企业号注册

2:常用参数介绍：

     1:CORPID    企业号唯一标志符号。
        位置：点击首页企业名称，企业资料中有key：CorpID
     2:CORPSECRET：
        需要创建单独等应用。具体步骤，按照提示一步一步来即可。需关注2个参数
        Secret  和  AgentId（用于区分给哪个应用推送消息）

3:发送消息准备工作：

 关注自己的企业号。（需要先绑定手机号）

4:纪录下需要发送消息的通讯录Id

用于给指定用户推送消息

5:代码结构

   1:获取token
   2:发送消息

6源码：（在你执行下面代码的时候，AgentId改为你自己的）

import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
 import java.net.URL;
 import javax.net.ssl.HttpsURLConnection;
 import net.sf.json.JSONObject;

 import org.apache.commons.httpclient.HttpClient;
 import org.apache.commons.httpclient.NameValuePair;
 import org.apache.commons.httpclient.cookie.CookiePolicy;
 import org.apache.commons.httpclient.methods.GetMethod;
 import org.apache.commons.httpclient.methods.PostMethod;
 import org.apache.commons.httpclient.params.DefaultHttpParams;

/**
 * @author cxf
*/

public class SendWeChatMessage {
   // 系统properties文件名称
//    private static final String EMAILCONFIG = "emailAndMsgConfig";
// 发送消息类型
private final static String MSGTYPE = "text";
// 发送消息分组所有成员
 private final static String TOPARTY = "@all";
// 获取配置文件中的值
private final static String CORPID = "上面提到的CORPID";// 需要自己申请，官网有试用企业号
// 可以申请试用
private final static String CORPSECRET = "上面提到的CORPSECRET";
// 获取访问权限码URL
private final static String ACCESS_TOKEN_URL = "https://qyapi.weixin.qq.com/cgi-bin/gettoken";
// 创建会话请求URL
private final static String CREATE_SESSION_URL = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=";

// 获取接口访问权限码
public String getAccessToken() {
    HttpClient client = new HttpClient();
//        PostMethod post = new PostMethod(ACCESS_TOKEN_URL);
    GetMethod get = new GetMethod(ACCESS_TOKEN_URL);
    get.releaseConnection();
    get.setRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8");
    NameValuePair[] param = { new NameValuePair("corpid", CORPID), new NameValuePair("corpsecret", CORPSECRET) };
    // 设置策略，防止报cookie错误
    DefaultHttpParams.getDefaultParams().setParameter("http.protocol.cookie-policy", CookiePolicy.BROWSER_COMPATIBILITY);
    // 给post设置参数
    get.setQueryString(param);
    String result = null;
    try {
        client.executeMethod(get);
        result = new String(get.getResponseBodyAsString().getBytes("utf-8"));
    } catch (IOException e) {
        e.printStackTrace();
    }
    // 将数据转换成json

    if(result==null||result==""){
        System.out.println("*****************");
        System.out.println("result:null");
    }else {
        System.out.println("result is not  null:"+result.toString());
        JSONObject jasonObject = JSONObject.fromObject(result);
        result = (String) jasonObject.get("access_token");
        // System.out.println(result);

        get.releaseConnection();
    }
    return result;

}

/**
 * 企业接口向下属关注用户发送微信消息(实现方式一)
 *
 * @param touser
 *            成员ID列表（消息接收者，多个接收者用‘|’分隔，最多支持1000个）。特殊情况：指定为@all，
 *            则向关注该企业应用的全部成员发送
 * @param toparty
 *            部门ID列表，多个接收者用‘|’分隔，最多支持100个。当touser为@all时忽略本参数
 * @param totag
 *            标签ID列表，多个接收者用‘|’分隔。当touser为@all时忽略本参数
 * @param content
 *            消息内容
 * @return
 */
@SuppressWarnings("deprecation")
public String sendWeChatMessage(String touser, String toparty, String totag, String content) {
    HttpClient client = new HttpClient();
    String ACCESS_TOKEN = getAccessToken();
    StringBuffer sb = new StringBuffer();
    sb.append("{");
    sb.append("\"touser\":" + "\"" + touser + "\",");
    sb.append("\"toparty\":" + "\"" + toparty + "\",");
    sb.append("\"totag\":" + "\"" + totag + "\",");
    sb.append("\"msgtype\":" + "\"" + "text" + "\",");
    sb.append("\"agentid\":" + "\"" + "1000002" + "\",");
    sb.append("\"text\":" + "{");
    sb.append("\"content\":" + "\"" + content + "\"},");
    sb.append("\"debug\":" + "\"" + "1" + "\"");
    sb.append("}");
    // 请求链接
    String url = CREATE_SESSION_URL + ACCESS_TOKEN;
    PostMethod post = new PostMethod(url);
    post.releaseConnection();
    post.setRequestHeader("Content-Type", "application/json;charset=UTF-8");
    // 设置策略，防止报cookie错误
    DefaultHttpParams.getDefaultParams().setParameter("http.protocol.cookie-policy", CookiePolicy.BROWSER_COMPATIBILITY);
    // 给post设置参数
    post.setRequestBody(sb.toString());
    String result = "";
    try {
        client.executeMethod(post);
        result = new String(post.getResponseBodyAsString().getBytes("utf-8"));
    } catch (IOException e) {
        e.printStackTrace();
    }
    System.out.println(result);

    post.releaseConnection();

    return result;

}

/**
 * 此方法可以发送任意类型消息
 *
 * @param msgType
 *            text|image|voice|video|file|news
 * @param touser
 *            成员ID列表（消息接收者，多个接收者用‘|’分隔，最多支持1000个）。特殊情况：指定为@all，
 *            则向关注该企业应用的全部成员发送
 * @param toparty
 *            部门ID列表，多个接收者用‘|’分隔，最多支持100个。当touser为@all时忽略本参数
 * @param totag
 *            标签ID列表，多个接收者用‘|’分隔。当touser为@all时忽略本参数
 * @param content
 *            msgType=text时 ,文本消息内容
 * @param mediaId
 *            msgType=image|voice|video时 ,对应消息信息ID（--------）
 * @param title
 *            msgType=news|video时，消息标题
 * @param description
 *            msgType=news|video时，消息描述
 * @param url
 *            msgType=news时，消息链接
 * @param picurl
 *            msgType=news时，图片路径
 * @param safe
 *            表示是否是保密消息，0表示否，1表示是，默认0
 */
public void sendWeChatMsg(String msgType, String touser, String toparty, String totag, String content, String mediaId, String title,
                          String description, String url, String picurl, String safe) {

    URL uRl;
    String ACCESS_TOKEN = getAccessToken();
    // 拼接请求串
    String action = CREATE_SESSION_URL + ACCESS_TOKEN;
    // 封装发送消息请求json
    StringBuffer sb = new StringBuffer();
    sb.append("{");
    sb.append("\"touser\":" + "\"" + touser + "\",");
    sb.append("\"toparty\":" + "\"" + toparty + "\",");
    sb.append("\"totag\":" + "\"" + totag + "\",");
    if (msgType.equals("text")) {
        sb.append("\"msgtype\":" + "\"" + msgType + "\",");
        sb.append("\"text\":" + "{");
        sb.append("\"content\":" + "\"" + content + "\"");
        sb.append("}");
    } else if (msgType.equals("image")) {
        sb.append("\"msgtype\":" + "\"" + msgType + "\",");
        sb.append("\"image\":" + "{");
        sb.append("\"media_id\":" + "\"" + mediaId + "\"");
        sb.append("}");
    } else if (msgType.equals("voice")) {
        sb.append("\"msgtype\":" + "\"" + msgType + "\",");
        sb.append("\"voice\":" + "{");
        sb.append("\"media_id\":" + "\"" + mediaId + "\"");
        sb.append("}");
    } else if (msgType.equals("video")) {
        sb.append("\"msgtype\":" + "\"" + msgType + "\",");
        sb.append("\"video\":" + "{");
        sb.append("\"media_id\":" + "\"" + mediaId + "\",");
        sb.append("\"title\":" + "\"" + title + "\",");
        sb.append("\"description\":" + "\"" + description + "\"");
        sb.append("}");
    } else if (msgType.equals("file")) {
        sb.append("\"msgtype\":" + "\"" + msgType + "\",");
        sb.append("\"file\":" + "{");
        sb.append("\"media_id\":" + "\"" + mediaId + "\"");
        sb.append("}");
    } else if (msgType.equals("news")) {
        sb.append("\"msgtype\":" + "\"" + msgType + "\",");
        sb.append("\"news\":" + "{");
        sb.append("\"articles\":" + "[");
        sb.append("{");
        sb.append("\"title\":" + "\"" + title + "\",");
        sb.append("\"description\":" + "\"" + description + "\",");
        sb.append("\"url\":" + "\"" + url + "\",");
        sb.append("\"picurl\":" + "\"" + picurl + "\"");
        sb.append("}");
        sb.append("]");
        sb.append("}");
    }
    sb.append(",\"safe\":" + "\"" + safe + "\",");
    sb.append("\"agentid\":" + "\"" + "1000002" + "\",");
    sb.append("\"debug\":" + "\"" + "1" + "\"");
    sb.append("}");
    String json = sb.toString();
    try {

        uRl = new URL(action);

        HttpsURLConnection http = (HttpsURLConnection) uRl.openConnection();

        http.setRequestMethod("POST");

        http.setRequestProperty("Content-Type",

                "application/json;charset=UTF-8");

        http.setDoOutput(true);

        http.setDoInput(true);

        System.setProperty("sun.net.client.defaultConnectTimeout", "30000");//
        // 连接超时30秒

        System.setProperty("sun.net.client.defaultReadTimeout", "30000"); //
        // 读取超时30秒

        http.connect();

        OutputStream os = http.getOutputStream();

        os.write(json.getBytes("UTF-8"));// 传入参数

        InputStream is = http.getInputStream();

        int size = is.available();

        byte[] jsonBytes = new byte[size];

        is.read(jsonBytes);

        String result = new String(jsonBytes, "UTF-8");

        System.out.println("请求返回结果:" + result);

        os.flush();

        os.close();

    } catch (Exception e) {

        e.printStackTrace();

    }
}

/**
 * 企业接口向下属关注用户发送微信消息(实现方式二)
 *
 * @param touser
 *            成员ID列表（消息接收者，多个接收者用‘|’分隔，最多支持1000个）。特殊情况：指定为@all，
 *            则向关注该企业应用的全部成员发送
 * @param toparty
 *            部门ID列表，多个接收者用‘|’分隔，最多支持100个。当touser为@all时忽略本参数
 * @param totag
 *            标签ID列表，多个接收者用‘|’分隔。当touser为@all时忽略本参数
 * @param content
 *            消息内容
 * @param safe
 *            消息是否保密
 * @return
 */
public void sendWeChatMsgText(String touser, String toparty, String totag, String content, String safe) {

    URL uRl;
    String ACCESS_TOKEN = getAccessToken();
    // 拼接请求串
    String action = CREATE_SESSION_URL + ACCESS_TOKEN;
    // 封装发送消息请求json
    StringBuffer sb = new StringBuffer();
    sb.append("{");
    sb.append("\"touser\":" + "\"" + touser + "\",");
    sb.append("\"toparty\":" + "\"" + toparty + "\",");
    sb.append("\"totag\":" + "\"" + totag + "\",");

    sb.append("\"msgtype\":" + "\"" + MSGTYPE + "\",");
    sb.append("\"text\":" + "{");
    sb.append("\"content\":" + "\"" + content + "\"");
    sb.append("}");

    sb.append(",\"safe\":" + "\"" + safe + "\",");
    sb.append("\"agentid\":" + "\"" + "1000002" + "\",");
    sb.append("\"debug\":" + "\"" + "1" + "\"");
    sb.append("}");
    String json = sb.toString();
    System.out.println("==========================");
    System.out.println(json);
    System.out.println("==========================");
    try {

        uRl = new URL(action);

        HttpsURLConnection http = (HttpsURLConnection) uRl.openConnection();

        http.setRequestMethod("POST");

        http.setRequestProperty("Content-Type",

                "application/json;charset=UTF-8");

        http.setDoOutput(true);

        http.setDoInput(true);

        System.setProperty("sun.net.client.defaultConnectTimeout", "30000");//
        // 连接超时30秒

        System.setProperty("sun.net.client.defaultReadTimeout", "30000"); //
        // 读取超时30秒

        http.connect();

        OutputStream os = http.getOutputStream();

        os.write(json.getBytes("UTF-8"));// 传入参数

        InputStream is = http.getInputStream();

        int size = is.available();

        byte[] jsonBytes = new byte[size];

        is.read(jsonBytes);

        String result = new String(jsonBytes, "UTF-8");

        System.out.println("请求返回结果:" + result);

        os.flush();

        os.close();

    } catch (Exception e) {

        e.printStackTrace();

    }
}

public static void main(String[] args) {
    SendWeChatMessage weChat = new SendWeChatMessage();
    weChat.sendWeChatMsgText("ChengXueFeng", "1", "", "微信测试", "0");
    // weChat.sendWeChatMsg("text", "mxlydx", "4", "", "测试senMsg", "", "",
    // "", "", "", "0");
    // weChat.sendWeChatMessage("mxlydq", "2", "", "Hi");
}

　　

转自：https://www.jianshu.com/p/b0b81a986e35

原文地址：https://www.cnblogs.com/panchanggui/p/9962617.html

时间： 2024-10-08 20:34:11

java-给微信推送消息 利用企业微信的相关文章

微信推送消息实战

# 沙箱环境登录地址:https://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=sandbox/login # 微信网页授权地址:https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421140842 第一步:获取认证信息.测试模板.等 第二步:后端代码: 1.获取二维码网址: def bind_qcode(request): """ 生成二维码 :param requ

免注册公众号的三种微信推送消息服务的C#代码实现

有时候我们需要监控一些网络上的变化,但是每次去刷新网页却又很麻烦,而且大部分刷新的时候网页并没有更新.那么有没有一个工具,可以监控网页变化,并将变化的结果推送到手机微信上呢? 这里有很多应用场景,比如前一段时间很火的工具来监控JD.TB等口罩是否有货的状态.还有就是刷票.抢课.监听网页便也变化.爬虫等等. 我们可以在后台写一个监控程序,一旦口罩有货了,就立马推送消息到微信上. 有人会说这样的方式,微信公众号可以实现啊,那么为什么要你介绍? 不不不,注册微信公众号后,还要阅读官方的各种文档,反复调

Java实现iOS推送（利用javapns1.6）

import java.util.HashMap; import java.util.Iterator; import org.apache.log4j.Logger; import org.apache.log4j.PropertyConfigurator; import javapns.back.PushNotificationManager; import javapns.back.SSLConnectionHelper; import javapns.data.Device; impor

微信推送消息--发送模板消息

工具类,详见附件,下载地址: http://files.cnblogs.com/files/007sx/weixin_util.zip 传的参数参考微信开发者文档-发送模板消息: http://mp.weixin.qq.com/wiki/17/304c1885ea66dbedf7dc170d84999a9d.html#.E5.8F.91.E9.80.81.E6.A8.A1.E6.9D.BF.E6.B6.88.E6.81.AF 全局返回码说明: http://mp.weixin.qq.com/wi

微信推送

-微信推送 -推送的方式:-短信推送(第三方) -邮件推送 -微信推送 -微信的各种号 -公众号?? -认证的公众号(个人的认证公众号每天只能发一篇文章)粉丝可以跟公众号聊天 -未认证的公众号 -服务号?? -企业认证(营业执照),沙箱环境 -主动给用户发消息(推送),必须关注我的服务号 -企业号?? - -微信小程序 ???????????? -微信推送的流程 -1 用户登录到我的系统,用户扫码关注我的服务号(二维码:微信提供的),现在用户并没有跟我系统绑定 -2 让用户跟我系统绑定 -1 生

微信推送功能实现

推送的方式: 短信推送(第三方) 邮件推送 微信推送 公众号:认证的公众号(个人的认证公众号每天只能发一篇文章),粉丝可以跟公众号聊天, 未认证公众号 服务号:企业认证(营业执照),沙箱环境测试 主动给用户发消息(推送),用户要接收到推送消息前提是需要关注对应的服务号才行 企业号 微信小程序 微信推送的流程: 微信沙箱环境:http://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=sandbox/login 使用pycharm打开微信推送demo,然后进行相

微信推送功能实现-实用篇

推送的方式: 短信推送(第三方) 邮件推送 微信推送 公众号:认证的公众号(个人的认证公众号每天只能发一篇文章),粉丝可以跟公众号聊天, 未认证公众号 服务号:企业认证(营业执照),沙箱环境测试 主动给用户发消息(推送),用户要接收到推送消息前提是需要关注对应的服务号才行 企业号 微信小程序 回到顶部 微信推送的流程: 微信沙箱环境:http://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=sandbox/login 使用pycharm打开微信推送demo,

微信公众平台向特定用户推送消息

最近研究微信公众平台,这里整理了一下向特定用户推送消息的思路 一.首先需要将微信的openid与系统用户绑定. 在用户关注公众平台的时候,回复一个链接,要求用户绑定,可以设计如下消息进行回复,(openid最好进行加密处理,后者还需要用这个字段绑定fakeid). 欢迎关注有问必答平台,<a href='http://myweixin123.duapp.com/[email protected]'>点击此处进行用户绑定</a>! 在bind.html页面将openid与系统的use

微信推送模板消息的PHP代码整理

最近做过一个需要推送消息的系统,就研究了一下微信的模板消息的推送.由于认证过的微信号,就用测试号做的,但是过程基本一致. 本文基于微信平台的官方文档写成,http://mp.weixin.qq.com/debug/cgi-bin/readtmpl?t=tmplmsg/faq_tmpl 首先,得在微信的后台管理中设置一下,模板消息的格式,获取到一个模板消息的id {{first.DATA}} 被撕的人:{{name.DATA}} 被撕人的组别:{{zu.DATA}} 被撕时间:{{time.DAT