httpClient實現微信公眾號消息群發

来源:http://www.cnblogs.com/0201zcr/archive/2016/09/21/5893600.html
-Advertisement-
Play Games

1、實現功能 向關註了微信公眾號的微信用戶群發消息。（可以是所有的用戶，也可以是提供了微信openid的微信用戶集合） 2、基本步驟 前提： 已經有認證的公眾號或者測試公眾賬號 發送消息步驟： 相關微信介面的信息可以查看：http://www.cnblogs.com/0201zcr/p/586629 ...


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

}

 2、Controller和Service層調用

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

 3、結果

　　假如你關註了微信公眾號中看到你剛剛發送的test消息。

HttpClient學習文檔：https://pan.baidu.com/s/1miO1eOg

 致謝：感謝您的閱讀


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • spring4.1.3+springmvc+mybatis3.2.1整合
    註意：這裡使用了mybatis3.2.1版本，剛開始用了3.4.1的版本，會報一個很奇怪的錯(java.lang.AbstractMethodError: org.mybatis.spring.transaction.SpringManagedTransaction.getTimeout()Ljav ...
  • PHP的mysqli_query參數MYSQLI_STORE_RESULT和MYSQLI_USE_RESULT的區別
    這篇文章主要介紹了PHP的mysqli_query參數MYSQLI_STORE_RESULT和MYSQLI_USE_RESULT的區別,本文給出了這兩個參數的5個區別,需要的朋友可以參考下 雖然nosql變得流行，但是我感覺sql還是主流今天在翻php manul的時候，發現mysqli 的查詢可以 ...
  • WNMP集成環境下配置thinkPHP
    在網上查了許多解決方法,下麵是自己測試過能行的方法,只需在nginx.conf文件添加內容就可以了. 打開nginx.conf文件 ...
  • java線程 公平鎖 ReentrantLock(boolean fair)
    獨占鎖 -- 鎖在一個時間點只能被一個線程鎖占有。根據鎖的獲取機制，它又劃分為“公平鎖”和“非公平鎖”。公平鎖，是按照通過CLH等待線程按照先來先得的規則，公平的獲取鎖；而非公平鎖，則當線程要獲取鎖時，它會無視CLH等待隊列而直接獲取鎖。獨占鎖的典型實例子是ReentrantLock，此外，Reen... ...
  • PythonCrawl自學日誌（3）
    2016年9月21日09:21:431.爬蟲的抓取周期:（1）首先生成初始請求爬第一個url,並指定一個回調函數被稱為與下載這些請求的響應。（2）第一個請求執行通過調用 start_requests()方法(預設情況下)生成 Request中指定的url start_urls和 parse方法作為請 ...
  • PHP 源碼學習之線程安全
    從作用域上來說，C語言可以定義4種不同的變數：全局變數，靜態全局變數，局部變數，靜態局部變數。 下麵僅從函數作用域的角度分析一下不同的變數，假設所有變數聲明不重名。 全局變數，在函數外聲明，例如，int gVar;。全局變數，所有函數共用，在任何地方出現這個變數名都是指這個變數 靜態全局變數（sta ...
  • E - The Values You Can Make
    E - The Values You Can Make Description Pari wants to buy an expensive chocolate from Arya. She has n coins, the value of the i-th coin is ci. The pri ...
  • boost 無鎖隊列 實現 生產者-消費者
    版權聲明 版權聲明：原創文章 禁止轉載 請通過右側公告中的“聯繫郵箱（[email protected]）”聯繫我 勿用於學術性引用。 勿用於商業出版、商業印刷、商業引用以及其他商業用途。 本文不定期修正完善。 本文鏈接：http://www.cnblogs.com/wlsandwho/p/ ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類