1、实现成果

向存眷了微信公家号的微信用户群动员静。（可以是所有的用户，也可以是提供了微信openid的微信用户荟萃）

2、根基步调

前提：

　　已经有认证的公家号可能测试公家账号

发送动静步调：

1. 发送一个请求微信去获取access_token
2. 发送一个请求去请求微信发送动静

相关微信接口的信息可以查察：http://www.cnblogs.com/0201zcr/p/5866296.html 有测试账号的申请 + 获取access_token和发送微信动静的url和相关的参数需求。各个参数的意义等。

3、实践

这里通过HttpClient发送请求去微信相关的接口。

1）maven依赖

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

2）httpClient利用要领

利用HttpClient发送请求、吸收响应很简朴，一般需要如下几步即可。

1. 建设HttpClient工具。
2. 建设请求要领的实例，并指定请求URL。假如需要发送GET请求，建设HttpGet工具；假如需要发送POST请求，建设HttpPost工具。
3. 假如需要发送请求参数，可挪用HttpGet、HttpPost配合的setParams(HetpParams params)要领来添加请求参数；对付HttpPost工具而言，劳务派遣管理系统，也可挪用setEntity(HttpEntity entity)要领来配置请求参数。
4. 挪用HttpClient工具的execute(HttpUriRequest request)发送请求，该要领返回一个HttpResponse。
5. 挪用HttpResponse的getAllHeaders()、getHeaders(String name)等要领可获取处事器的响应头；挪用HttpResponse的getEntity()要领可获取HttpEntity工具，该工具包装了处事器的响应内容。措施可通过该工具获取处事器的响应内容。
6. 释放毗连。无论执行要领是否乐成，都必需释放毗连——这里利用了毗连池，可以交给毗连池去处理惩罚

3）实例

1、发送请求的类

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

}