玩玩微信公众号Java版之三：access_token及存储access_token

 1     /**
 2      * 通过参数获取Token信息
 3      * @param appID
 4      * @param appSceret
 5      * @return
 6      */
 7     public Token getToken(String appID, String appSceret)
 8     {
 9         mAppID = appID;
10         mAppSceret = appSceret;
11 
12         // 1.确定是否要更新token，无需更新则直接直接返回获取的token
13         if (updateToken())
14         {
15             return mToken;
16         }
17 
18         // 2. 如需更新
19         if (!getTokenbyhttps(mAppID, mAppSceret))
20         {
21             System.out.println("获取失败！");
22             return null;
23         }
24 
25         return mToken;
26     }

 1     /**
 2      * 获取Token信息
 3      * @return
 4      */
 5     private boolean updateToken()
 6     {
 7         // 查询数据库数据，如果有则不用更新，无则需要更新
 8         Connection con = null;
 9         PreparedStatement stmt = null;
10         ResultSet rs = null;
11         // 判断当前token是否在有效时间内
12         String sql = " select * from token where appid =‘" + mAppID + "‘ and appsecret =‘" + mAppSceret
13                 + "‘ and ( current_timestamp -createtime) <expires_in order by createTime desc limit 0,1";
14         try
15         {
16             // 创建数据库链接
17             con = DBConnPool.getConnection();
18             // 创建处理器
19             stmt = con.prepareStatement(sql);
20             // 查询Token，读取1条记录
21             rs = stmt.executeQuery();
22             if (rs.next())
23             {
24                 mToken.setTokenid(rs.getString("tokenid"));
25                 mToken.setToken(rs.getString("token"));
26                 mToken.setExpires_in(rs.getInt("expires_in"));
27                 mToken.setAppid(rs.getString("appid"));
28                 mToken.setAppsecret(rs.getString("appsecret"));
29             }
30             else
31             {
32                 System.out.println("未查询到对应token");
33                 return false;
34             }
35         }
36         catch (Exception e)
37         {
38             // TODO: handle exception
39             return false;
40         }
41 
42         System.out.println(mToken.getToken());
43 
44         return true;
45     }

 1     /**
 2      * 通过https请求获取token
 3      * @param appID
 4      * @param appSceret
 5      * @return
 6      */
 7     private boolean getTokenbyhttps(String appID, String appSceret)
 8     {
 9         String current_time = new Date().getTime() + "";
10 
11         try
12         {
13             // 请求地址
14             String path = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid="
15                     + appID + "&secret=" + appSceret;
16             
17             String strResp = WeChatUtil.doHttpsGet(path, "");
18             System.out.println(strResp);
19             
20             // 解析获取的token信息
21             Map<String, Object> tMap = WeChatUtil.jsonToMap(strResp);
22 
23             System.out.println(tMap.toString());
24 
25             mToken.setTokenid(WeChatUtil.getMaxTokenID());
26             mToken.setToken((String) tMap.get("access_token"));
27             mToken.setExpires_in(Integer.parseInt((String) tMap.get("expires_in")));
28             mToken.setAppid(appID);
29             mToken.setAppsecret(appSceret);
30             mToken.setCreatetime(current_time);
31 
32             System.out.println(mToken.getToken());
33 
34         }
35         catch (HttpException e)
36         {
37             // TODO Auto-generated catch block
38             e.printStackTrace();
39         }
40         catch (IOException e)
41         {
42             // TODO Auto-generated catch block
43             e.printStackTrace();
44         }
45 
46         // 存储token至数据库
47         saveToken(mToken);
48 
49         return true;
50     }
51 
52     /**
53      * 保存Token信息
54      * @return
55      */
56     private boolean saveToken(Token token)
57     {
58         PreparedStatement pst = null;
59         Connection conn = null;
60         try
61         {
62             Token tToken = token.clone();
63 
64             System.out.println(tToken.getTokenid() + tToken.getToken());
65 
66             conn = DBConnPool.getConnection();
67             // 创建预处理器
68             pst = conn.prepareStatement("insert into token(tokenid, token, expires_in,appid, appsecret,createtime) values (?,?,?,?,?,?)");
69 
70             pst.setString(1, tToken.getTokenid());
71             pst.setString(2, tToken.getToken());
72             pst.setInt(3, tToken.getExpires_in());
73             pst.setString(4, tToken.getAppid());
74             pst.setString(5, tToken.getAppsecret());
75             long now = new Date().getTime();
76             pst.setTimestamp(6, new java.sql.Timestamp(now));
77             pst.execute();
78 
79         }
80         catch (CloneNotSupportedException e)
81         {
82             // TODO Auto-generated catch block
83             e.printStackTrace();
84             return false;
85         }
86         catch (SQLException e)
87         {
88             // TODO Auto-generated catch block
89             e.printStackTrace();
90             return false;
91         }
92         catch (Exception e)
93         {
94             // TODO: handle exception
95             System.out.println("出现额外异常");
96         }
97         return true;
98     }

 1     /**
 2      * HTTPS请求Get方法调用
 3      * @param path
 4      * @param requestData
 5      * @return
 6      * @throws HttpException
 7      * @throws IOException
 8      */
 9     public static String doHttpsGet(String path, String requestData) throws HttpException, IOException
10     {
11         // 创建https请求，未默认证书，可自行添加
12         // 设置编码
13         HttpClient httpClient = new HttpClient();
14         GetMethod getMethod = new GetMethod(path);
15         httpClient.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "UTF-8");
16 
17         httpClient.executeMethod(getMethod);
18 
19         // 读取内容
20         byte[] responseBody = getMethod.getResponseBody();
21         String strResp = new String(responseBody, "UTF-8");
22 
23         System.out.println(strResp);
24 
25         getMethod.releaseConnection();
26 
27         return strResp;
28     }
29 
30     /**
31      * HTTPS请求Post方法调用
32      * @param path
33      * @param requestData
34      * @return
35      * @throws HttpException
36      * @throws IOException
37      */
38     public static String doHttpsPost(String path, String requestData) throws HttpException, IOException
39     {
40         // 创建https请求，未默认证书，可自行添加
41         String strResp ="";
42         HttpClient httpClient = new HttpClient();
43         PostMethod postMethod = new PostMethod(path);
44         // 设置编码
45         httpClient.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "UTF-8");
46         
47         System.out.println("path:" + path);
48         System.out.println("requestData:" + requestData);
49 
50         postMethod.setRequestBody(requestData);
51 
52         long start = System.currentTimeMillis();
53         // 执行getMethod
54         int statusCode = httpClient.executeMethod(postMethod);
55         System.out.println("cost:" + (System.currentTimeMillis() - start));
56         // 失败
57         if (statusCode != HttpStatus.SC_OK)
58         {
59             System.out.println("Method failed: " + postMethod.getStatusLine());
60             // 读取内容
61             byte[] responseBody = postMethod.getResponseBody();
62             // 处理内容
63             strResp = new String(responseBody, "UTF-8");
64             System.out.println(strResp);
65         }
66         else
67         {
68             // 读取内容
69             byte[] responseBody = postMethod.getResponseBody();
70             strResp = new String(responseBody, "UTF-8");
71             System.out.println("服务器返回:" + strResp);
72         }
73 
74         postMethod.releaseConnection();
75 
76         return strResp;
77     }