httpClient实现微信公众号消息群发详解编程语言

<dependency> 
    <groupId>org.apache.httpcomponents</groupId> 
    <artifactId>httpclient</artifactId> 
    <version>4.3.1</version> 
</dependency>

import com.alibaba.druid.support.json.JSONUtils; 
import com.alibaba.druid.support.logging.Log; 
import com.alibaba.druid.support.logging.LogFactory; 
import com.alibaba.fastjson.JSON; 
import com.alibaba.fastjson.JSONObject; 
import com.seewo.core.util.json.JsonUtils; 
import org.apache.commons.collections.map.HashedMap; 
import org.apache.commons.lang.StringUtils; 
import org.apache.http.HttpHost; 
import org.apache.http.NameValuePair; 
import org.apache.http.client.ClientProtocolException; 
import org.apache.http.client.HttpClient; 
import org.apache.http.client.ResponseHandler; 
import org.apache.http.client.methods.HttpGet; 
import org.apache.http.client.methods.HttpPost; 
import org.apache.http.conn.params.ConnRoutePNames; 
import org.apache.http.conn.scheme.Scheme; 
import org.apache.http.conn.ssl.SSLSocketFactory; 
import org.apache.http.entity.StringEntity; 
import org.apache.http.impl.client.BasicResponseHandler; 
import org.apache.http.impl.client.DefaultHttpClient; 
import org.apache.http.impl.conn.PoolingClientConnectionManager; 
import org.apache.http.message.BasicNameValuePair; 
import org.springframework.http.HttpHeaders; 
import org.springframework.http.MediaType; 
import javax.net.ssl.SSLContext; 
import javax.net.ssl.X509TrustManager; 
import javax.security.cert.CertificateException; 
import javax.security.cert.X509Certificate; 
import java.io.IOException; 
import java.text.MessageFormat; 
import java.util.ArrayList; 
import java.util.List; 
import java.util.Map; 
/** 
* Created by zhengcanrui on 16/9/20. 
*/ 
public class WechatAPIHander { 
/** 
* 获取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/mass/sendall?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() { 
@Override 
public void checkClientTrusted(java.security.cert.X509Certificate[] x509Certificates, String s) throws java.security.cert.CertificateException { 
} 
@Override 
public void checkServerTrusted(java.security.cert.X509Certificate[] x509Certificates, String s) throws java.security.cert.CertificateException { 
} 
@Override 
public java.security.cert.X509Certificate[] getAcceptedIssuers() { 
return new java.security.cert.X509Certificate[0]; 
} 
}; 
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); 
Map map = JsonUtils.jsonToMap(response); 
accessToken = (String) map.get("access_token"); 
/* Object Object = JSONUtils.parse(response); 
accessToken = jsonObject.getString("access_token");*/ 
//                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("/n/nsendMessage start.token:"+token+",msg:"+msg); 
String url = MessageFormat.format(this.sendMsgUrl, token); 
HttpPost post = new HttpPost(url); 
ResponseHandler<?> responseHandler = new BasicResponseHandler(); 
//这里必须是一个合法的json格式数据,每个字段的意义可以查看上面连接的说明,content后面的test是要发送给用户的数据,这里是群发给所有人 
msg = "{/"filter/":{/"is_to_all/":true},/"text/":{/"content/":/"test/"},/"msgtype/":/"text/"}/""; 
//设置发送消息的参数 
StringEntity entity = new StringEntity(msg); 
//解决中文乱码的问题 
entity.setContentEncoding("UTF-8"); 
entity.setContentType("application/json"); 
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 发起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; 
} 
}

  @RequestMapping(value = "/testHttpClient", method = RequestMethod.GET) 
public DataMap test() { 
WechatAPIHander wechatAPIHander = new WechatAPIHander(); 
//获取access_token
　　　　　　//第一个参数是你appid，第二个参数是你的秘钥，需要根据你的具体情况换 
String accessToken = wechatAPIHander.getAccessToken("appid","scerpt");   
//发送消息 
wechatAPIHander.sendMessage(accessToken, "测试数据"); 
return new DataMap().addAttribute("DATA",accessToken); 
}