web.xml配置信息
<?xml version="1.0" encoding="UTF-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" version="2.5"> <display-name></display-name> <servlet> <servlet-name>InitServlet</servlet-name> <servlet-class>com.xxx.wechat.token.InitServlet</servlet-class> </servlet> <servlet-mapping> <servlet-name>InitServlet</servlet-name> <url-pattern>/initServlet.do</url-pattern> </servlet-mapping> <welcome-file-list> <welcome-file>index.jsp</welcome-file> </welcome-file-list> </web-app>InitServlet
package com.xxx.wechat.token; import java.io.IOException; import java.io.OutputStream; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; /** * 获取微信Token接口 */ public class InitServlet extends HttpServlet{ protected static Logger logger = LogManager.getLogger(InitServlet.class); private static final long serialVersionUID = 1L; public void init() throws ServletException { // 启动定时获取access_token的线程 new Thread(new TokenThread()).start(); } public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { request.setCharacterEncoding("UTF-8"); String accessToken = TokenThread.accessToken; //String accessToken = WechatTools.getAccessToken(); try { OutputStream os = response.getOutputStream(); os.write(accessToken.getBytes("UTF-8")); os.flush(); os.close(); } catch (Exception e) { logger.debug("InitServlet doGet token Exception:"+e); } } @Override public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { doGet(request, response); } }线程
package com.xxx.wechat.token; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * 每1小时(微信端两小时内有效)获取一次Token */ public class TokenThread implements Runnable{ private static Logger log = LoggerFactory.getLogger(TokenThread.class); public static String accessToken = null; public void run() { while (true) { try { accessToken = WechatTools.getAccessToken(); log.debug("获取access_token成功:", accessToken); Thread.sleep(3600*1000); log.debug("next start ....."); } catch (InterruptedException e) { log.error("InterruptedException {}", e); } catch (Exception e) { log.error("Exception {}", e); } } } }WechatTools
package com.minxue.wechat.token; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import com.minxue.util.HttpConnectionUtil; import com.minxue.util.JsonUtil; import com.minxue.util.PropertisUtil; /** * 微信推送工具类 */ public class WechatTools { protected static Logger logger = LogManager.getLogger(WechatTools.class); private final static String appid = PropertisUtil.getInstance().getWxAppid(); private final static String secret = PropertisUtil.getInstance().getWxSecret(); private final static String WECHAT_URL = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid="+appid+"&secret="+secret; private static String access_token = ""; /** * 获取access_token */ public static String getAccessToken() { try{ logger.debug("getAccessToken i(ss):" ); //获取access_token String accessTokenURL = HttpConnectionUtil.AccessUrlGet(WECHAT_URL); logger.debug("new accessTokenResult URL :"+accessTokenURL); if(accessTokenURL != null && !accessTokenURL.equals("")){ AccessToken accessToken = (AccessToken) JsonUtil.JsonToObject(accessTokenURL, AccessToken.class); if(accessToken != null){ access_token = accessToken.getAccess_token();; logger.debug("new_access_token============:"+access_token); }else{ logger.error("accessTokenResult error:"+accessToken); } } }catch(Exception e){ logger.error("getAccessToken Exception:" + e); } return access_token; } }HttpConnectionUtil工具
package com.minxue.util; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.MalformedURLException; import java.net.URL; /** * 网络连接工具类 * @version V1.0 */ public class HttpConnectionUtil { /** * 网络链接 * @param url * @param postString 参数 * @return String */ public static String AccessUrl(String url, String postString) { String result = null; HttpURLConnection conn = null; try { URL postUrl = new URL(url); conn = (HttpURLConnection) postUrl.openConnection(); conn.setRequestMethod("POST"); conn.setDoOutput(true); conn.setDoInput(true); conn.setUseCaches(false); conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8"); conn.setConnectTimeout(2000); conn.setReadTimeout(2000); OutputStream os = conn.getOutputStream(); os.write(postString.getBytes("utf-8")); // 往远程URL传递参数 os.flush(); os.close(); int code = conn.getResponseCode(); // 返回长度："+conn.getContentLength()); conn.getHeaderFields(); conn.getContentLength(); if (code == 200) {// 返回成功 BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream(), "utf-8")); String line; StringBuffer buffer = new StringBuffer(); while ((line = reader.readLine()) != null) { buffer.append(line); } result = buffer.toString(); } else { result = "服务异常，错误码:"+code; } } catch (MalformedURLException e) { result = "服务异常:"+e.getMessage(); } catch (IOException e) { result = "服务异常:"+e.getMessage(); }finally{ if(conn != null){ conn.disconnect(); conn=null; } } return result; } /** * 网络链接 * @param url * @param postString 参数 * @return String */ public static String AccessUrlGet(String url) { String result = null; HttpURLConnection conn = null; try { URL postUrl = new URL(url); conn = (HttpURLConnection) postUrl.openConnection(); conn.setRequestMethod("GET"); conn.setDoOutput(true); conn.setDoInput(true); conn.setUseCaches(false); conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8"); conn.setConnectTimeout(2000); conn.setReadTimeout(2000); int code = conn.getResponseCode(); conn.getHeaderFields(); conn.getContentLength(); if (code == 200) {// 返回成功 BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream(), "utf-8")); String line; StringBuffer buffer = new StringBuffer(); while ((line = reader.readLine()) != null) { buffer.append(line); } result = buffer.toString(); } else { result = "服务异常，错误码:"+code; } } catch (MalformedURLException e) { result = "服务异常:"+e.getMessage(); } catch (IOException e) { result = "服务异常:"+e.getMessage(); }finally{ if(conn != null){ conn.disconnect(); conn=null; } } return result; } }微信凭证AccessToken
package com.minxue.wechat.token; /** * 微信凭证 */ public class AccessToken { /** * 获取到的凭证 */ private String access_token; /** * 凭证有效时间，单位：秒 */ private int expires_in; /** * 创建一个新的实例 AccessToken. * */ public AccessToken() { super(); } /** * @return access_token */ public String getAccess_token() { return access_token; } /** * @param access_token the access_token to set */ public void setAccess_token(String access_token) { this.access_token = access_token; } /** * @return expires_in */ public int getExpires_in() { return expires_in; } /** * @param expires_in the expires_in to set */ public void setExpires_in(int expires_in) { this.expires_in = expires_in; } }因token接口请求每天有上线限制，使用该工具可以完成token的获取工作
