Java微信公眾平臺(tái)開(kāi)發(fā)（6）微信開(kāi)發(fā)中的token獲取

2019-11-26 12:31:28

字體：大中小

供稿：網(wǎng)友

（一）token的介紹

引用：access_token是公眾號(hào)的全局唯一票據(jù)，公眾號(hào)調(diào)用各接口時(shí)都需使用access_token。開(kāi)發(fā)者需要進(jìn)行妥善保存。access_token的存儲(chǔ)至少要保留512個(gè)字符空間。access_token的有效期目前為2個(gè)小時(shí)，需定時(shí)刷新，重復(fù)獲取將導(dǎo)致上次獲取的access_token失效！

（二）token的獲取參考文檔

獲取的流程我們完全可以參考微信官方文檔：http://mp.weixin.qq.com/wiki/14/9f9c82c1af308e3b14ba9b973f99a8ba.html 如圖：

（三）token獲取流程分析

從公眾平臺(tái)獲取賬號(hào)的AppID和AppSecret；
token獲取并解析存儲(chǔ)執(zhí)行體；
采用任務(wù)調(diào)度每隔兩小時(shí)執(zhí)行一次token獲取執(zhí)行體；

（四）token的獲取流程的具體實(shí)現(xiàn)
①獲取appid和appsecret

在微信公眾平臺(tái)【開(kāi)發(fā)】――>【基本配置】中可以查看到我們需要的兩個(gè)參數(shù)：

這里我們將他們定義到我們的配置文件【wechat.properties】中，大致代碼為：

#獲取到的appidappid=wx7e32765bc24XXXX #獲取到的AppSecretAppSecret=d58051564fe9d86093f9XXXXX

②token獲取并解析存儲(chǔ)執(zhí)行體的代碼編寫

由于在這里我們需要通過(guò)http的get請(qǐng)求向微信服務(wù)器獲取時(shí)效性為7200秒的token，所以我在這里寫了一個(gè)http請(qǐng)求的工具類，以方便我們的使用，如下：

package com.cuiyongzhi.wechat.util; import java.io.BufferedInputStream;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStreamWriter;import java.net.MalformedURLException;import java.net.URI;import java.net.URL;import java.net.URLConnection;import java.util.ArrayList;import java.util.List;import java.util.Map;import java.util.Set;import java.util.zip.GZIPInputStream; import org.apache.http.HttpResponse;import org.apache.http.NameValuePair;import org.apache.http.client.ClientProtocolException;import org.apache.http.client.HttpClient;import org.apache.http.client.entity.UrlEncodedFormEntity;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.DefaultHttpClient;import org.apache.http.message.BasicNameValuePair;import org.apache.http.protocol.HTTP;import org.apache.http.util.EntityUtils; /** * ClassName: HttpUtils *  * @Description: http請(qǐng)求工具類 * @author dapengniao * @date 2016年3月10日 下午3:57:14 */@SuppressWarnings("deprecation")public class HttpUtils {  /**  * @Description: http get請(qǐng)求共用方法  * @param @param reqUrl  * @param @param params  * @param @return  * @param @throws Exception  * @author dapengniao  * @date 2016年3月10日 下午3:57:39  */ @SuppressWarnings("resource") public static String sendGet(String reqUrl, Map<String, String> params)   throws Exception {  InputStream inputStream = null;  HttpGet request = new HttpGet();  try {   String url = buildUrl(reqUrl, params);   HttpClient client = new DefaultHttpClient();    request.setHeader("Accept-Encoding", "gzip");   request.setURI(new URI(url));    HttpResponse response = client.execute(request);    inputStream = response.getEntity().getContent();   String result = getJsonStringFromGZIP(inputStream);   return result;  } finally {   if (inputStream != null) {    inputStream.close();   }   request.releaseConnection();  }  }  /**  * @Description: http post請(qǐng)求共用方法  * @param @param reqUrl  * @param @param params  * @param @return  * @param @throws Exception  * @author dapengniao  * @date 2016年3月10日 下午3:57:53  */ @SuppressWarnings("resource") public static String sendPost(String reqUrl, Map<String, String> params)   throws Exception {  try {   Set<String> set = params.keySet();   List<NameValuePair> list = new ArrayList<NameValuePair>();   for (String key : set) {    list.add(new BasicNameValuePair(key, params.get(key)));   }   if (list.size() > 0) {    try {     HttpClient client = new DefaultHttpClient();     HttpPost request = new HttpPost(reqUrl);      request.setHeader("Accept-Encoding", "gzip");     request.setEntity(new UrlEncodedFormEntity(list, HTTP.UTF_8));      HttpResponse response = client.execute(request);      InputStream inputStream = response.getEntity().getContent();     try {      String result = getJsonStringFromGZIP(inputStream);       return result;     } finally {      inputStream.close();     }    } catch (Exception ex) {     ex.printStackTrace();     throw new Exception("網(wǎng)絡(luò)連接失敗,請(qǐng)連接網(wǎng)絡(luò)后再試");    }   } else {    throw new Exception("參數(shù)不全，請(qǐng)稍后重試");   }  } catch (Exception ex) {   ex.printStackTrace();   throw new Exception("發(fā)送未知異常");  } }  /**  * @Description: http post請(qǐng)求json數(shù)據(jù)  * @param @param urls  * @param @param params  * @param @return  * @param @throws ClientProtocolException  * @param @throws IOException  * @author dapengniao  * @date 2016年3月10日 下午3:58:15  */ public static String sendPostBuffer(String urls, String params)   throws ClientProtocolException, IOException {  HttpPost request = new HttpPost(urls);   StringEntity se = new StringEntity(params, HTTP.UTF_8);  request.setEntity(se);  // 發(fā)送請(qǐng)求  @SuppressWarnings("resource")  HttpResponse httpResponse = new DefaultHttpClient().execute(request);  // 得到應(yīng)答的字符串，這也是一個(gè) JSON 格式保存的數(shù)據(jù)  String retSrc = EntityUtils.toString(httpResponse.getEntity());  request.releaseConnection();  return retSrc;  }  /**  * @Description: http請(qǐng)求發(fā)送xml內(nèi)容  * @param @param urlStr  * @param @param xmlInfo  * @param @return  * @author dapengniao  * @date 2016年3月10日 下午3:58:32  */ public static String sendXmlPost(String urlStr, String xmlInfo) {  // xmlInfo xml具體字符串   try {   URL url = new URL(urlStr);   URLConnection con = url.openConnection();   con.setDoOutput(true);   con.setRequestProperty("Pragma:", "no-cache");   con.setRequestProperty("Cache-Control", "no-cache");   con.setRequestProperty("Content-Type", "text/xml");   OutputStreamWriter out = new OutputStreamWriter(     con.getOutputStream());   out.write(new String(xmlInfo.getBytes("utf-8")));   out.flush();   out.close();   BufferedReader br = new BufferedReader(new InputStreamReader(     con.getInputStream()));   String lines = "";   for (String line = br.readLine(); line != null; line = br     .readLine()) {    lines = lines + line;   }   return lines; // 返回請(qǐng)求結(jié)果  } catch (MalformedURLException e) {   e.printStackTrace();  } catch (IOException e) {   e.printStackTrace();  }  return "fail"; }  private static String getJsonStringFromGZIP(InputStream is) {  String jsonString = null;  try {   BufferedInputStream bis = new BufferedInputStream(is);   bis.mark(2);   // 取前兩個(gè)字節(jié)   byte[] header = new byte[2];   int result = bis.read(header);   // reset輸入流到開(kāi)始位置   bis.reset();   // 判斷是否是GZIP格式   int headerData = getShort(header);   // Gzip 流 的前兩個(gè)字節(jié)是 0x1f8b   if (result != -1 && headerData == 0x1f8b) {    // LogUtil.i("HttpTask", " use GZIPInputStream ");    is = new GZIPInputStream(bis);   } else {    // LogUtil.d("HttpTask", " not use GZIPInputStream");    is = bis;   }   InputStreamReader reader = new InputStreamReader(is, "utf-8");   char[] data = new char[100];   int readSize;   StringBuffer sb = new StringBuffer();   while ((readSize = reader.read(data)) > 0) {    sb.append(data, 0, readSize);   }   jsonString = sb.toString();   bis.close();   reader.close();  } catch (Exception e) {   e.printStackTrace();  }   return jsonString; }  private static int getShort(byte[] data) {  return (data[0] << 8) | data[1] & 0xFF; }  /**  * 構(gòu)建get方式的url  *   * @param reqUrl  *   基礎(chǔ)的url地址  * @param params  *   查詢參數(shù)  * @return 構(gòu)建好的url  */ public static String buildUrl(String reqUrl, Map<String, String> params) {  StringBuilder query = new StringBuilder();  Set<String> set = params.keySet();  for (String key : set) {   query.append(String.format("%s=%s&", key, params.get(key)));  }  return reqUrl + "?" + query.toString(); } }

我們?cè)谧鰄ttp請(qǐng)求的時(shí)候需要目標(biāo)服務(wù)器的url，這里在項(xiàng)目中為了方便對(duì)url的管理我們?cè)谫Y源目錄下建立了interface_url.properties用于存放目標(biāo)url，這里我們將請(qǐng)求token的url存入：

#獲取token的urltokenUrl=https://api.weixin.qq.com/cgi-bin/token

我們需要將我們配置的配置文件在項(xiàng)目初始化后能得到啟動(dòng)，所以我在這里加入一個(gè)項(xiàng)目初始化的代碼實(shí)現(xiàn)，用于項(xiàng)目啟動(dòng)初始化interface_url.properties和wechat.properties中的配置：

package com.cuiyongzhi.web.start; import javax.servlet.ServletConfig;import javax.servlet.ServletException;import javax.servlet.http.HttpServlet; /** * ClassName: InterfaceUrlIntiServlet * @Description: 項(xiàng)目啟動(dòng)初始化servlet * @author dapengniao * @date 2016年3月10日 下午4:08:43 */public class InterfaceUrlIntiServlet extends HttpServlet {  private static final long serialVersionUID = 1L;  @Override public void init(ServletConfig config) throws ServletException {  InterfaceUrlInti.init(); } }

初始化的具體實(shí)現(xiàn)，將初始化過(guò)后的方法都存入到GlobalConstants中方便項(xiàng)目中隨意調(diào)用，如下：

package com.cuiyongzhi.web.start; import java.io.IOException;import java.io.InputStream;import java.util.Properties; import com.cuiyongzhi.web.util.GlobalConstants; /** * ClassName: InterfaceUrlInti * @Description: 項(xiàng)目啟動(dòng)初始化方法 * @author dapengniao * @date 2016年3月10日 下午4:08:21 */public class InterfaceUrlInti {  public synchronized static void init(){  ClassLoader cl = Thread.currentThread().getContextClassLoader();  Properties props = new Properties();  if(GlobalConstants.interfaceUrlProperties==null){   GlobalConstants.interfaceUrlProperties = new Properties();  }  InputStream in = null;  try {   in = cl.getResourceAsStream("interface_url.properties");   props.load(in);   for(Object key : props.keySet()){    GlobalConstants.interfaceUrlProperties.put(key, props.get(key));   }       props = new Properties();   in = cl.getResourceAsStream("wechat.properties");   props.load(in);   for(Object key : props.keySet()){    GlobalConstants.interfaceUrlProperties.put(key, props.get(key));   }      } catch (IOException e) {   e.printStackTrace();  }finally{   if(in!=null){    try {     in.close();    } catch (IOException e) {     e.printStackTrace();    }   }  }  return; } }

當(dāng)我們把所有的準(zhǔn)備工作都做好了之后我們可以開(kāi)始真正的去獲取token了，這里我們將獲取到的token解析之后依然存儲(chǔ)到GlobalConstants中方便使用，簡(jiǎn)單代碼如下：

package com.cuiyongzhi.wechat.common; import java.util.HashMap;import java.util.Map; import net.sf.json.JSONObject; import com.cuiyongzhi.web.util.GlobalConstants;import com.cuiyongzhi.wechat.util.HttpUtils; /** * ClassName: WeChatTask * @Description: 微信兩小時(shí)定時(shí)任務(wù)體 * @author dapengniao * @date 2016年3月10日 下午1:42:29 */public class WeChatTask { /**  * @Description: 任務(wù)執(zhí)行體  * @param @throws Exception  * @author dapengniao  * @date 2016年3月10日 下午2:04:37  */ public void getToken_getTicket() throws Exception {  Map<String, String> params = new HashMap<String, String>();  params.put("grant_type", "client_credential");  params.put("appid", GlobalConstants.getInterfaceUrl("appid"));  params.put("secret", GlobalConstants.getInterfaceUrl("AppSecret"));  String jstoken = HttpUtils.sendGet(    GlobalConstants.getInterfaceUrl("tokenUrl"), params);  String access_token = JSONObject.fromObject(jstoken).getString(    "access_token"); // 獲取到token并賦值保存  GlobalConstants.interfaceUrlProperties.put("access_token", access_token);    System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"token為=============================="+access_token); } }

（三）采用任務(wù)調(diào)度每隔兩小時(shí)執(zhí)行一次token獲取執(zhí)行體

我們閱讀過(guò)微信的文檔會(huì)發(fā)現(xiàn)我們的token獲取的接口每天是有調(diào)用次數(shù)限制的，為了防止我們業(yè)務(wù)量比較大的情況下token的直接調(diào)用的接口次數(shù)不夠用，所以我們需要根據(jù)token的時(shí)效性（7200s）在自己的業(yè)務(wù)服務(wù)器上做到token的緩存并定時(shí)獲取，我這里用到的任務(wù)調(diào)度的方式是采用quartz，有關(guān)quartz的使用可以參考文章 http://cuiyongzhi.com/?tags=%E5%AE%9A%E6%97%B6%E4%BB%BB%E5%8A%A1 ，下面具體代碼的實(shí)現(xiàn)：

package com.cuiyongzhi.wechat.quartz; import org.apache.log4j.Logger; import com.cuiyongzhi.wechat.common.WeChatTask; public class QuartzJob{  private static Logger logger = Logger.getLogger(QuartzJob.class);  /**   * @Description: 任務(wù)執(zhí)行獲取token   * @param     * @author dapengniao   * @date 2016年3月10日 下午4:34:26   */  public void workForToken() {    try {      WeChatTask timer = new WeChatTask();      timer.getToken_getTicket();    } catch (Exception e) {      logger.error(e, e);    }  }  }

這里新建配置文件spring-quartz.xml以方便quartz任務(wù)的管理和啟用，這里將我們需要用到的workForToken()加入到執(zhí)行任務(wù)中：

<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd"> <beans> <!-- 要調(diào)用的工作類 --> <bean id="quartzJob" class="com.cuiyongzhi.wechat.quartz.QuartzJob"></bean>   <!-- 定義調(diào)用對(duì)象和調(diào)用對(duì)象的方法 --> <bean id="jobtaskForToken"  class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">  <!-- 調(diào)用的類 -->  <property name="targetObject">   <ref bean="quartzJob" />  </property>  <!-- 調(diào)用類中的方法 -->  <property name="targetMethod">   <value>workForToken</value>  </property>  </bean> <!-- 定義觸發(fā)時(shí)間 --> <bean id="doTimeForToken" class="org.springframework.scheduling.quartz.CronTriggerBean">  <property name="jobDetail">   <ref bean="jobtaskForToken" />  </property>  <!-- cron表達(dá)式 -->  <property name="cronExpression">   <value>0 0/1 * * * ?</value>  </property> </bean>   <!-- 總管理類 如果將lazy-init='false'那么容器啟動(dòng)就會(huì)執(zhí)行調(diào)度程序 --> <bean id="startQuertz" lazy-init="false" autowire="no"  class="org.springframework.scheduling.quartz.SchedulerFactoryBean">  <property name="triggers">   <list>    <ref bean="doTimeForToken" />   </list>  </property> </bean> </beans>

這里我為了測(cè)試將執(zhí)行間隔時(shí)間設(shè)置成了1分鐘一次，根據(jù)需要可以自行修改執(zhí)行時(shí)間；最后我們需要在我們的web.xml啟動(dòng)項(xiàng)中開(kāi)啟quartz的使用：

<context-param>  <param-name>contextConfigLocation</param-name>  <param-value>classpath:spring.xml,classpath:spring-mybatis.xml,classpath:spring-quartz.xml</param-value>  <!-- ,classpath:spring-quartz.xml 用于做任務(wù)調(diào)度 任務(wù)定時(shí)都可以 --> </context-param>

當(dāng)這一切都準(zhǔn)備完畢之后我們啟動(dòng)項(xiàng)目，會(huì)發(fā)現(xiàn)每間隔一分鐘就會(huì)有token獲取到，這里我是將其存儲(chǔ)在項(xiàng)目變量中，但是如果需要考慮到項(xiàng)目橫向擴(kuò)展這里建議將token存儲(chǔ)到緩存中；運(yùn)行結(jié)果如下：