Java微信公众平台开发（6）微信开发中的token获取-eolink官网

Java微信公众平台开发（6）微信开发中的token获取

（一）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 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 params)

throws Exception {

try {

Set set = params.keySet();

List list = new ArrayList();

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 params) {

StringBuilder query = new StringBuilder();

Set 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 params = new HashMap();

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 (Excepthttp://ion e) {

logger.error(e, e);

}

这里新建配置文件spring-quartz.xml以方便quartz任务的管理和启用，这里将我们需要用到的workForToken()加入到执行任务中：

class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">

workForToken

class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">

workForToken

0 0/1 * * * ?

class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

这里我为了测试将执行间隔时间设置成了1分钟一次，根据需要可以自行修改执行时间；最后我们需要在我们的web.xml启动项中开启quartz的使用：

contextConfigLocation

classpath:spring.xml,classpath:spring-mybatis.xml,classpath:spring-quartz.xml

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

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

Iterator与LIstIterator接口在java中的区别有哪些

248 2023-05-21

Java微信公众平台开发（6）微信开发中的token获取

多平台统一管理软件接口，如何实现多平台统一管理软件接口

vue项目接口域名动态的获取方法

Iterator与LIstIterator接口在java中的区别有哪些

推荐文章

接口调用是什么意思？几种常用接口调用方式

接口设计原则

8款在线 API 接口文档管理工具

api管理系统是什么？

什么是接口调试？接口调试的步骤有哪些？

api 接口管理系统有哪些？

接口测试有几种测试方法

API文档生成工具有哪些？

微服务和api网关区别

交换机配置步骤

最近发表

热评文章

在线接口文档管理工具推荐，支持在线测试，HTTP接口

开源的在线接口文档wiki工具Mindoc的介绍与使

如何优雅的进行接口设计？接口设计的六大原则是什么？

什么是API测试,api检测公司

软件接口设计怎么做？前后端分离软件接口设计思路

接口管理平台推荐，几大接口管理平台总有一款适合你！

Java微信公众平台开发（6） 微信开发中的token获取

推荐文章

最近发表

热评文章

Java微信公众平台开发（6）微信开发中的token获取