利用java开发微信实现微信主动推送消息实例

1.拉取access_token2.拉取用户信息3.主动推送消息4.接口貌似要申请权限5.依赖httpclient4.2.3 和jackson 2.2.1

public class WeixinAPIHelper {   /**    * 获取token接口    */   private String getTokenUrl = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={0}&secret={1}";   /**    * 拉微信用户信息接口    */   private String getUserInfoUrl = "https://api.weixin.qq.com/cgi-bin/user/info?access_token={0}&openid={1}";   /**    * 主动推送信息接口    */   private String sendMsgUrl = "https://api.weixin.qq.com/cgi-bin/message/send?access_token={0}";   private HttpClient webClient;   private Log log = LogFactory.getLog(getClass());   public void initWebClient(String proxyHost, int proxyPort){    this.initWebClient();    if(webClient != null && !StringUtils.isEmpty(proxyHost)){     HttpHost proxy = new HttpHost(proxyHost, proxyPort);     webClient.getParams().setParameter(ConnRoutePNames.DEFAULT_PROXY, proxy);    }   }   /**    * @desc 初始化创建 WebClient    */   public void initWebClient() {    log.info("initWebClient start....");    try {     PoolingClientConnectionManager tcm = new PoolingClientConnectionManager();     tcm.setMaxTotal(10);     SSLContext ctx = SSLContext.getInstance("TLS");     X509TrustManager tm = new X509TrustManager() {      public void checkClientTrusted(X509Certificate[] arg0, String arg1) throws CertificateException {      }      public void checkServerTrusted(X509Certificate[] arg0, String arg1) throws CertificateException {      }      public X509Certificate[] getAcceptedIssuers() {       return null;      }     };     ctx.init(null, new X509TrustManager[] { tm }, null);     SSLSocketFactory ssf = new SSLSocketFactory(ctx, SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);     Scheme sch = new Scheme("https", 443, ssf);     tcm.getSchemeRegistry().register(sch);     webClient = new DefaultHttpClient(tcm);    } catch (Exception ex) {     log.error("initWebClient exception", ex);    } finally {     log.info("initWebClient end....");    }   }   /**    * @desc 获取授权token    * @param appid    * @param secret    * @return    */   public String getAccessToken(String appid, String secret) {    String accessToken = null;    try {     log.info("getAccessToken start.{appid=" + appid + ",secret:" + secret + "}");     String url = MessageFormat.format(this.getTokenUrl, appid, secret);     String response = executeHttpGet(url);     accessToken = JsonUtils.read(response, "access_token");    } catch (Exception e) {     log.error("get access toekn exception", e);    }    return accessToken;   }   /**    * @desc 推送信息    * @param token    * @param msg    * @return    */   public String sendMessage(String token,String msg){    try{     log.info("sendMessage start.token:"+token+",msg:"+msg);     String url = MessageFormat.format(this.sendMsgUrl, token);     HttpPost post = new HttpPost(url);     ResponseHandler<?> responseHandler = new BasicResponseHandler();     StringEntity entity = new StringEntity(msg);     post.setEntity(entity);     String response = (String) this.webClient.execute(post, responseHandler);     log.info("return response=====start======");     log.info(response);     log.info("return response=====end======");     return response;      }catch (Exception e) {     log.error("get user info exception", e);     return null;    }    }   /**    * @desc 拉取用户信息    * @param token    * @param openid    * @return    */   public WeixinOpenUser getUserInfo(String token, String openid) {    try {     log.info("getUserInfo start.{token:" + token + ",openid:" + openid + "}");     String url = MessageFormat.format(this.getUserInfoUrl, token, openid);     String response = executeHttpGet(url);     JsonNode json = JsonUtils.read(response);     if (json.get("openid") != null) {      WeixinOpenUser user = new WeixinOpenUser();      user.setOpenUserId(json.get("openid").asText());      user.setState(json.get("subscribe").asText());      if ("1".equals(user.getState())) {       user.setUserName(json.get("nickname").asText());       user.setSex(json.get("sex").asText());       user.setCity(json.get("city").asText());       user.setLanguage(json.get("language").asText());      }      return user;     }    } catch (Exception e) {     log.error("get user info exception", e);    }    return null;   }   /**    * @desc 发起HTTP GET请求返回数据    * @param url    * @return    * @throws IOException    * @throws ClientProtocolException    */   private String executeHttpGet(String url) throws IOException, ClientProtocolException {    ResponseHandler<?> responseHandler = new BasicResponseHandler();    String response = (String) this.webClient.execute(new HttpGet(url), responseHandler);    log.info("return response=====start======");    log.info(response);    log.info("return response=====end======");    return response;   }  }

以上就是利用java开发微信实现微信主动推送消息实例的详细内容，更多内容请关注技术你好其它相关文章！