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");
}

`

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 206,602评论 6赞 481
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 88,442评论 2赞 382
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 152,878评论 0赞 344
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 55,306评论 1赞 279
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 64,330评论 5赞 373
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 49,071评论 1赞 285
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,382评论 3赞 400
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 37,006评论 0赞 259
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 43,512评论 1赞 300
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,965评论 2赞 325
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,094评论 1赞 333
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,732评论 4赞 323
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,283评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,286评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,512评论 1赞 262
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 45,536评论 2赞 354
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,828评论 2赞 345

推荐阅读更多精彩内容

  • Android - 收藏集
    Android 自定义View的各种姿势1 Activity的显示之ViewRootImpl详解 Activity...
    passiontim阅读 171,514评论 25赞 707
  • Java初级面试题
    1. Java基础部分 基础部分的顺序：基本语法，类相关的语法，内部类的语法，继承相关的语法，异常的语法，线程的语...
    子非鱼_t_阅读 31,582评论 18赞 399
  • RTMP规范中文翻译
    实时消息协议---流的分块 版权声明： 版权（c）2009 Adobe系统有限公司。全权所有。 摘要： 本备忘录描...
    一个人zy阅读 1,887评论 0赞 9
  • Spring Cloud
    Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智...
    卡卡罗2017阅读 134,600评论 18赞 139
  • 黑暗童话之保险
    一、 我叫许阳，曾经在一家保险公司短暂工作过，当时的岗位是保险理赔调查员，负责现场核实保险案件的真实性，然后撰写调...
    西梁人阅读 435评论 6赞 2