使用Java程序发送企业微信

Java程序发送微信消息，全部代码，已测试通过

urlData.java   “微信授权请求”数据对象文件：

package Alert.weChat;

public class urlData {
    String corpid;
    String corpsecret;
    String Get_Token_Url;
    String SendMessage_Url;
    
    public String getCorpid() {
        return corpid;
    }
    public void setCorpid(String corpid) {
        this.corpid = corpid;
    }
    public String getCorpsecret() {
        return corpsecret;
    }
    public void setCorpsecret(String corpsecret) {
        this.corpsecret = corpsecret;
    }
    public void setGet_Token_Url(String corpid,String corpsecret) {
        this.Get_Token_Url ="https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid="+corpid+"&corpsecret="+corpsecret;
    }
    public String getGet_Token_Url() {
        return Get_Token_Url;
    }
    public String getSendMessage_Url(){
        SendMessage_Url = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=";
        return SendMessage_Url;
    }
    
}

weChatData.java  “微信消息发送”的post数据对象文件：

package Alert.weChat;


public class weChatData {
    //发送微信消息的URL
//    String sendMsgUrl="https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=";
    String touser;
    String msgtype;
    int agentid;
    Object text;//实际接收Map类型数据

    public Object getText() {
        return text;
    }
    public void setText(Object text) {
        this.text = text;
    }
    public String getMsgtype() {
        return msgtype;
    }
    public void setMsgtype(String msgtype) {
        this.msgtype = msgtype;
    }
    public int getAgentid() {
        return agentid;
    }
    public void setAgentid(int agentid) {
        this.agentid = agentid;
    }
    public String getTouser() {
        return touser;
    }
    public void setTouser(String touser) {
        this.touser = touser;
    }

}

send_weChatMsg.java  “发送微信实体”代码

package Alert.weChat;

import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

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.LoggerFactory;

import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;


public class send_weChatMsg {
     private CloseableHttpClient httpClient;
     private HttpPost httpPost;//用于提交登陆数据
     private HttpGet httpGet;//用于获得登录后的页面
     public static final String CONTENT_TYPE = "Content-Type";
     SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//
    

    private static Gson gson = new Gson();


    /**
     * 微信授权请求，GET类型，获取授权响应，用于其他方法截取token
     * @param Get_Token_Url
     * @return String 授权响应内容
     * @throws IOException
     */
    protected String toAuth(String Get_Token_Url) throws IOException {
        
        httpClient = HttpClients.createDefault();
        httpGet = new HttpGet(Get_Token_Url);
        CloseableHttpResponse response = httpClient.execute(httpGet);
        String resp;
        try {
            HttpEntity entity = response.getEntity();
            resp = EntityUtils.toString(entity, "utf-8");
            EntityUtils.consume(entity);
        } finally {
            response.close();
        }
        LoggerFactory.getLogger(getClass()).info(" resp:{}", resp);
        return resp;
    }

    /**
     * 获取toAuth(String Get_Token_Url)返回结果中键值对中access_token键的值
     * @param corpid应用组织编号   corpsecret应用秘钥
     */    
    protected  String getToken(String corpid,String corpsecret) throws IOException {        
        send_weChatMsg sw = new send_weChatMsg();
        urlData uData = new urlData();
        uData.setGet_Token_Url(corpid,corpsecret);
        String resp = sw.toAuth(uData.getGet_Token_Url());
        
        Map<String, Object> map = gson.fromJson(resp,
                new TypeToken<Map<String, Object>>() {
                }.getType());
        return map.get("access_token").toString();
    }

    
    /** 
    * @Title:创建微信发送请求post数据  
    * @param  touser发送消息接收者    ，msgtype消息类型（文本/图片等），
    * @param application_id应用编号。
    * @param 本方法适用于text型微信消息，contentKey和contentValue只能组一对
    * @return String     
    */
    protected String createpostdata(String touser, String msgtype,
            int application_id, String contentKey ,String contentValue) {
        weChatData wcd = new weChatData();
        wcd.setTouser(touser);
        wcd.setAgentid(application_id);
        wcd.setMsgtype(msgtype);
        Map<Object, Object> content = new HashMap<Object, Object>();
        content.put(contentKey,contentValue+"
--------
"+df.format(new Date()));
        wcd.setText(content);
        return gson.toJson(wcd);
    }

    /** 
    * @Title  创建微信发送请求post实体
    * @param  charset消息编码    ，contentType消息体内容类型，
    * @param  url微信消息发送请求地址，data为post数据，token鉴权token
    * @return String     
    */
    public String post(String charset, String contentType, String url,
            String data,String token) throws IOException {
        CloseableHttpClient httpclient = HttpClients.createDefault();
        httpPost = new HttpPost(url+token);
        httpPost.setHeader(CONTENT_TYPE, contentType);
        httpPost.setEntity(new StringEntity(data, charset));
        CloseableHttpResponse response = httpclient.execute(httpPost);
        String resp;
        try {
            HttpEntity entity = response.getEntity();
            resp = EntityUtils.toString(entity, charset);
            EntityUtils.consume(entity);
        } finally {
            response.close();
        }
        LoggerFactory.getLogger(getClass()).info(
                "call [{}], param:{}, resp:{}", url, data, resp);
        return resp;
    }
    
}

test.java  测试程序

package Alert.weChat;

import java.io.IOException;

public class test {
    public static void main(String[] args) {
        send_weChatMsg sw = new send_weChatMsg();
        try {
            String token = sw.getToken("wxbXXXXX","YYYYYYYYYY");
            String postdata = sw.createpostdata("Luosu", "text", 1, "content","This alert Email come from IapppayBJQA");
            String resp = sw.post("utf-8", send_weChatMsg.CONTENT_TYPE,(new urlData()).getSendMessage_Url(), postdata, token);
            System.out.println("获取到的token======>" + token);
            System.out.println("请求数据======>" + postdata);
            System.out.println("发送微信的响应数据======>" + resp);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

test.java代码输出：

log4j:WARN No appenders could be found for logger (org.apache.http.client.protocol.RequestAddCookies).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
获取到的token======>_kv4OeDXcsXIUG6lWwQCbz12thqlAN8HGhzx4B_HBRnYCQpt5CxwnnyMThS2ep3V
请求数据======>{"touser":"AAA","msgtype":"text","agentid":1,"text":{"content":"This alert Email come from IapppayBJQA
--------
2017-03-17 09:06:45"}}
发送微信的响应数据======>{"errcode":0,"errmsg":"ok"}