（一）token的介绍

引用：access_token是公众号的全局唯一票据，公众号调用各接口时都需使用access_token。开发者需要进行妥善保存。access_token的存储至少要保留512个字符空间。access_token的有效期目前为2个小时，需定时刷新，重复获取将导致上次获取的access_token失效！

（二）token的获取参考文档

获取的流程我们完全可以参考微信官方文档：http://mp.weixin.qq.com/wiki/14/9f9c82c1af308e3b14ba9b973f99a8ba.html 如图：

（三）token获取流程分析

从公众平台获取账号的AppID和AppSecret；
token获取并解析存储执行体；
采用任务调度每隔两小时执行一次token获取执行体；

（四）token的获取流程的具体实现
①获取appid和appsecret

在微信公众平台【开发】——>【基本配置】中可以查看到我们需要的两个参数：

这里我们将他们定义到我们的配置文件【wechat.properties】中，大致代码为：

#获取到的appid
appid=wx7e32765bc24XXXX 
#获取到的AppSecret
AppSecret=d58051564fe9d86093f9XXXXX

②token获取并解析存储执行体的代码编写

由于在这里我们需要通过http的get请求向微信服务器获取时效性为7200秒的token，所以我在这里写了一个http请求的工具类，以方便我们的使用，如下：

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请求工具类
 * @author dapengniao
 * @date 2016年3月10日 下午3:57:14
 */
@SuppressWarnings("deprecation")
public class HttpUtils {
 
 /**
  * @Description: http get请求共用方法
  * @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请求共用方法
  * @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("网络连接失败,请连接网络后再试");
    }
   } else {
    throw new Exception("参数不全，请稍后重试");
   }
  } catch (Exception ex) {
   ex.printStackTrace();
   throw new Exception("发送未知异常");
  }
 }
 
 /**
  * @Description: http post请求json数据
  * @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);
  // 发送请求
  @SuppressWarnings("resource")
  HttpResponse httpResponse = new DefaultHttpClient().execute(request);
  // 得到应答的字符串，这也是一个 JSON 格式保存的数据
  String retSrc = EntityUtils.toString(httpResponse.getEntity());
  request.releaseConnection();
  return retSrc;
 
 }
 
 /**
  * @Description: http请求发送xml内容
  * @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; // 返回请求结果
  } 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);
   // 取前两个字节
   byte[] header = new byte[2];
   int result = bis.read(header);
   // reset输入流到开始位置
   bis.reset();
   // 判断是否是GZIP格式
   int headerData = getShort(header);
   // Gzip 流 的前两个字节是 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;
 }
 
 /**
  * 构建get方式的url
  * 
  * @param reqUrl
  *   基础的url地址
  * @param params
  *   查询参数
  * @return 构建好的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();
 }
 
}

我们在做http请求的时候需要目标服务器的url，这里在项目中为了方便对url的管理我们在资源目录下建立了interface_url.properties用于存放目标url，这里我们将请求token的url存入：

#获取token的url
tokenUrl=https://api.weixin.qq.com/cgi-bin/token

我们需要将我们配置的配置文件在项目初始化后能得到启动，所以我在这里加入一个项目初始化的代码实现，用于项目启动初始化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: 项目启动初始化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();
 }
 
}

初始化的具体实现，将初始化过后的方法都存入到GlobalConstants中方便项目中随意调用，如下：

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: 项目启动初始化方法
 * @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;
 }
 
}

当我们把所有的准备工作都做好了之后我们可以开始真正的去获取token了，这里我们将获取到的token解析之后依然存储到GlobalConstants中方便使用，简单代码如下：

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: 微信两小时定时任务体
 * @author dapengniao
 * @date 2016年3月10日 下午1:42:29
 */
public class WeChatTask {
 /**
  * @Description: 任务执行体
  * @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);
 }
 
}

（三）采用任务调度每隔两小时执行一次token获取执行体

我们阅读过微信的文档会发现我们的token获取的接口每天是有调用次数限制的，为了防止我们业务量比较大的情况下token的直接调用的接口次数不够用，所以我们需要根据token的时效性（7200s）在自己的业务服务器上做到token的缓存并定时获取，我这里用到的任务调度的方式是采用quartz，有关quartz的使用可以参考文章 http://cuiyongzhi.com/?tags=%E5%AE%9A%E6%97%B6%E4%BB%BB%E5%8A%A1 ，下面具体代码的实现：

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: 任务执行获取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任务的管理和启用，这里将我们需要用到的workForToken()加入到执行任务中：

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
 
<beans>
 <!-- 要调用的工作类 -->
 <bean id="quartzJob" class="com.cuiyongzhi.wechat.quartz.QuartzJob"></bean>
  
 <!-- 定义调用对象和调用对象的方法 -->
 <bean id="jobtaskForToken"
  class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
  <!-- 调用的类 -->
  <property name="targetObject">
   <ref bean="quartzJob" />
  </property>
  <!-- 调用类中的方法 -->
  <property name="targetMethod">
   <value>workForToken</value>
  </property>
 
 </bean>
 <!-- 定义触发时间 -->
 <bean id="doTimeForToken" class="org.springframework.scheduling.quartz.CronTriggerBean">
  <property name="jobDetail">
   <ref bean="jobtaskForToken" />
  </property>
  <!-- cron表达式 -->
  <property name="cronExpression">
   <value>0 0/1 * * * ?</value>
  </property>
 </bean>
 
 
 <!-- 总管理类 如果将lazy-init='false'那么容器启动就会执行调度程序 -->
 <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>

这里我为了测试将执行间隔时间设置成了1分钟一次，根据需要可以自行修改执行时间；最后我们需要在我们的web.xml启动项中开启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 用于做任务调度 任务定时都可以 -->
 </context-param>

当这一切都准备完毕之后我们启动项目，会发现每间隔一分钟就会有token获取到，这里我是将其存储在项目变量中，但是如果需要考虑到项目横向扩展这里建议将token存储到缓存中；运行结果如下：

那么到这里token的获取和保存就基本讲完了，下一篇将讲述【多媒体消息的回复】，感谢你的翻阅，如果有需要源码或有疑问可以留言！

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# java  # 微信  # token  # 微信公众号获取access_token的方法实例分析  # java获取微信accessToken的方法  # 微信公众号平台接口开发 获取access_token过程解析  # 微信公众平台获取access_token的方法步骤  # 详解微信开发之access_token之坑  # php获取微信基础接口凭证Access_token  # 微信小程序登录换取token的教程  # 微信小程序url与token设置详解  # 基于thinkPHP3.2实现微信接入及查询token值的方法  # 微信公众号服务器验证Token步骤图解  # 下午  # 在这里  # 配置文件  # 两小时  # 文档  # 每隔  # 自己的  # 是一个  # 我是  # 就会  # 成了  # 好了  # 是有  # 执行时间  # 将其  # 我们可以  # 这也  # 考虑到  # 写了  # 当我们 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Laravel Seeder填充数据教程_Laravel模型工厂Factory使用  标准网站视频模板制作软件,现在有哪个网站的视频编辑素材最齐全的，背景音乐、音效等？  Laravel如何实现多级无限分类_Laravel递归模型关联与树状数据输出【方法】  在Oracle关闭情况下如何修改spfile的参数  如何用腾讯建站主机快速创建免费网站？  如何实现javascript表单验证_正则表达式有哪些实用技巧  php读取心率传感器数据怎么弄_php获取max30100的心率值【指南】  Laravel如何实现多对多模型关联？（Eloquent教程）  如何在HTML表单中获取用户输入并结合JavaScript动态控制复利计算循环  Android中AutoCompleteTextView自动提示  Laravel如何与Docker（Sail）协同开发？（环境搭建教程）  iOS中将个别页面强制横屏其他页面竖屏  Laravel如何使用Service Provider服务提供者_Laravel依赖注入与容器绑定【深度】  免费网站制作appp,免费制作app哪个平台好？  Win11搜索不到蓝牙耳机怎么办 Win11蓝牙驱动更新修复【详解】  浅析上传头像示例及其注意事项  Laravel怎么创建自己的包(Package)_Laravel扩展包开发入门到发布  网站制作大概要多少钱一个,做一个平台网站大概多少钱？  如何自定义建站之星模板颜色并下载新样式？  Laravel全局作用域是什么_Laravel Eloquent Global Scopes应用指南  如何快速启动建站代理加盟业务？  大连企业网站制作公司,大连2025企业社保缴费网上缴费流程？  创业网站制作流程,创业网站可靠吗？  Python自然语言搜索引擎项目教程_倒排索引查询优化案例  b2c电商网站制作流程,b2c水平综合的电商平台？  javascript中数组（Array)对象和字符串（String)对象的常用方法总结  Laravel辅助函数有哪些_Laravel Helpers常用助手函数大全  Laravel如何使用Seeder填充数据_Laravel模型工厂Factory批量生成测试数据【方法】  浅述节点的创建及常见功能的实现  jquery插件bootstrapValidator表单验证详解  如何注册花生壳免费域名并搭建个人网站？  如何在橙子建站上传落地页？操作指南详解  Laravel如何集成第三方登录_Laravel Socialite实现微信QQ微博登录  Laravel如何使用缓存系统提升性能_Laravel缓存驱动和应用优化方案  如何解决hover在ie6中的兼容性问题  Laravel如何生成URL和重定向？（路由助手函数）  轻松掌握MySQL函数中的last_insert_id()  如何快速搭建自助建站会员专属系统？  如何在香港服务器上快速搭建免备案网站？  Laravel策略(Policy)如何控制权限_Laravel Gates与Policies实现用户授权  小视频制作网站有哪些,有什么看国内小视频的网站，求推荐？  重庆市网站制作公司,重庆招聘网站哪个好？  Laravel中间件如何使用_Laravel自定义中间件实现权限控制  JavaScript如何实现路由_前端路由原理是什么  Laravel如何实现数据库事务？（DB Facade示例）  新三国志曹操传主线渭水交兵攻略  如何在云主机上快速搭建多站点网站？  Linux网络带宽限制_tc配置实践解析【教程】  Laravel怎么清理缓存_Laravel optimize clear命令详解  小米17系列还有一款新机？主打6.9英寸大直屏和旗舰级影像