import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.ConnectException;
import java.net.URL;
import java.util.Date;
import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager;
import javax.servlet.http.HttpServletRequest;
import net.jeeshop.core.mobile.FrontContainer;
import net.jeeshop.mobile.services.front.account.bean.Account;
import net.jeeshop.mobile.services.front.systoken.bean.Token;
import net.sf.json.JSONException;
import net.sf.json.JSONObject;
import org.apache.struts2.ServletActionContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.opensymphony.xwork2.ActionContext;
/**
* 通用工具类
*
* @author
*
*/
public class CommonUtil {
private static Logger log = LoggerFactory.getLogger(CommonUtil.class);
/**
* 发送https请求
*
* @param requestUrl
* 请求地址
* @param requestMethod
* 请求方式（GET、POST）
* @param outputStr
* 提交的数据
* @return 返回微信服务器响应的信息
*/
public static String httpsRequest(String requestUrl, String requestMethod, String outputStr) {
log.error("httpsRequest.requestUrl ：{}", requestUrl);
try {
// 创建SSLContext对象，并使用我们指定的信任管理器初始化
TrustManager[] tm = { new MyX509TrustManager() };
SSLContext sslContext = SSLContext.getInstance("SSL", "SunJSSE");
sslContext.init(null, tm, new java.security.SecureRandom());
// 从上述SSLContext对象中得到SSLSocketFactory对象
SSLSocketFactory ssf = sslContext.getSocketFactory();
URL url = new URL(requestUrl);
HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
conn.setSSLSocketFactory(ssf);
conn.setDoOutput(true);
conn.setDoInput(true);
conn.setUseCaches(false);
// 设置请求方式（GET/POST）
conn.setRequestMethod(requestMethod);
conn.setRequestProperty("content-type", "application/x-www-form-urlencoded");
// 当outputStr不为null时向输出流写数据
if (null != outputStr) {
OutputStream outputStream = conn.getOutputStream();
// 注意编码格式
outputStream.write(outputStr.getBytes("UTF-8"));
outputStream.close();
}
// 从输入流读取返回内容
InputStream inputStream = conn.getInputStream();
InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "UTF-8");
BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
String str = null;
StringBuffer buffer = new StringBuffer();
while ((str = bufferedReader.readLine()) != null) {
buffer.append(str);
}
// 释放资源
bufferedReader.close();
inputStreamReader.close();
inputStream.close();
inputStream = null;
conn.disconnect();
log.error("httpsRequest 方法：{}", buffer.toString());
return buffer.toString();
} catch (ConnectException ce) {
log.error("连接超时：{}", ce);
} catch (Exception e) {
log.error("https请求异常：{}", e);
}
return null;
}
/**
* 获取接口访问凭证(不应该放到session内 需引以为戒,放数据库 或其他持久层模式) 基础支持 token
*
* @param appid
* 凭证
* @param appsecret
* 密钥
* @return
*/
public static Token getToken(String openid, String appid, String appsecret, HttpServletRequest request) {
Token token = null;
if (request != null && request.getSession() != null) {
token = (Token) request.getSession().getAttribute(openid + "token");
}
String requestUrl = ConfigUtil.BASE_TOKEN_URL.replace("APPID", appid).replace("APPSECRET", appsecret);
if (null == token || ((new Date().getTime() - token.getTime()) / 1000) > 7150) {
// 发起GET请求获取凭证
JSONObject jsonObject = JSONObject.fromObject(httpsRequest(requestUrl, "GET", null));
log.error("获取getToken jsonObject====================", jsonObject.toString());
if (null != jsonObject) {
try {
token = new Token();
token.setAccessToken(jsonObject.getString("access_token"));
token.setExpiresIn(jsonObject.getInt("expires_in"));
token.setTime(new Date().getTime());
if (request != null && request.getSession() != null) {
request.getSession().setAttribute(openid + "token", token);
}
} catch (JSONException e) {
token = null;
// 获取token失败
log.error("获取基础支持token失败 errcode:{} errmsg:{}", jsonObject.getString("errcode"), jsonObject.getString("errmsg"));
}
}
}
return token;
}
/**
* 获取接口访问凭证(不应该放到session内 需引以为戒,放数据库 或其他持久层模式) 基础支持 token
*
* @param appid
* 凭证
* @param appsecret
* 密钥
* @return
*/
public static Token getToken(String openid,HttpServletRequest request) {
Token token = null;
String requestUrl = ConfigUtil.BASE_TOKEN_URL.replace("APPID", ConfigUtil.APPID).replace("APPSECRET", ConfigUtil.APP_SECRECT);
// 发起GET请求获取凭证
JSONObject jsonObject = JSONObject.fromObject(httpsRequest(requestUrl, "GET", null));
log.error("不经过session 直接获取getToken jsonObject====================", jsonObject.toString());
if (null != jsonObject) {
try {
token = new Token();
token.setAccessToken(jsonObject.getString("access_token"));
token.setExpiresIn(jsonObject.getInt("expires_in"));
token.setTime(new Date().getTime());
if (request != null && request.getSession() != null) {
request.getSession().setAttribute(openid + "token", token);
}
} catch (JSONException e) {
token = null;
// 获取token失败
log.error("不经过session 直接获取基础支持token失败 errcode:{} errmsg:{}", jsonObject.getString("errcode"), jsonObject.getString("errmsg"));
}
}
return token;
}
/**
* 通过code获取token
*
* @param appid
* 凭证
* @param appsecret
* 密钥
* @return
*/
public static Token getOAUTH2(String appid, String appsecret, String code, HttpServletRequest request) {
log.error("通过code获取token getOAUTH2 start=================================");
Token token = null;
if (request.getSession() != null) {
token = (Token) request.getSession().getAttribute(appid + "token");
}
String requestUrl = ConfigUtil.TOKEN_URL.replace("APPID", appid).replace("SECRET", appsecret).replace("CODE", code);
if (null == token || ((new Date().getTime() - token.getTime()) / 1000) > 7150) {
// 发起GET请求获取凭证
JSONObject jsonObject = JSONObject.fromObject(httpsRequest(requestUrl, "GET", null));
log.error("获取token jsonObject====================", jsonObject.toString());
if (null != jsonObject) {
try {
token = new Token();
token.setAccessToken(jsonObject.getString("access_token"));
log.error("获取token access_token:{}", jsonObject.getString("access_token"));
token.setOpenId(jsonObject.getString("openid"));
log.error("获取token openId:{}", jsonObject.getString("openid"));
token.setRefeshToken(jsonObject.getString("refresh_token"));
log.error("获取token refeshToken:{}", jsonObject.getString("refresh_token"));
token.setScope(jsonObject.getString("scope"));
log.error("获取token scope:{}", jsonObject.getString("scope"));
token.setExpiresIn(jsonObject.getInt("expires_in"));
log.error("获取token expires_in:{}", jsonObject.getString("expires_in"));
// token.setUnionid(jsonObject.getString("unionid"));
// log.error("获取token unionid:{}",
// jsonObject.getString("unionid"));
token.setTime(new Date().getTime());
request.getSession().setAttribute(appid + "token", token);
} catch (JSONException e) {
token = null;
// 获取token失败
log.error("获取token失败 errcode:{} errmsg:{}", jsonObject.getString("errcode"), jsonObject.getString("errmsg"));
}
}
}
log.error("通过code获取token getOAUTH2 end=================================");
return token;
}
/**
* 获取用户信息
*
* @param openid
* 凭证
* @param access_token
* 密钥
* @return
*/
public static Account getUserinfo(String openid, String access_token) {
log.error("通过openid,access_token获取获取用户信息 getUserinfo start=================================");
HttpServletRequest request = (HttpServletRequest) ActionContext.getContext().get(ServletActionContext.HTTP_REQUEST);
String requestUrl = ConfigUtil.TOKEN_URL.replace("ACCESS_TOKEN", access_token).replace("OPENID", openid);
// 发起GET请求获取凭证
JSONObject jsonObject = JSONObject.fromObject(httpsRequest(requestUrl, "GET", null));
log.error("获取getUserinfo jsonObject====================", jsonObject.toString());
Account account = null;
if (null != jsonObject) {
try {
account = new Account();
account.setAccessToken(jsonObject.getString("access_token"));
log.error("获取account access_token:{}", jsonObject.getString("access_token"));
account.setOpenId(jsonObject.getString("openid"));
log.error("获取account openId:{}", jsonObject.getString("openid"));
account.setNickname(jsonObject.getString("nickname"));
log.error("获取account nickname:{}", jsonObject.getString("nickname"));
account.setProvince(jsonObject.getString("province"));
log.error("获取account province:{}", jsonObject.getString("province"));
account.setCity(jsonObject.getString("city"));
log.error("获取account city:{}", jsonObject.getString("city"));
request.getSession().setAttribute(FrontContainer.USER_INFO, account);
} catch (JSONException e) {
account = null;
// 获取token失败
log.error("获取token失败 errcode:{} errmsg:{}", jsonObject.getString("errcode"), jsonObject.getString("errmsg"));
}
}
log.error("通过openid,access_token获取获取用户信息 getUserinfo end=================================");
return account;
}
// JAVA 获取完整URL 方法
public static String getRequestURL(HttpServletRequest request) {
log.error("获取请求信息 getRequestURL start=================================");
if (request == null) {
return "";
}
String url = "";
url = request.getContextPath();
url = url + request.getServletPath();
log.error("获取请求信息getRequestURL url=================================" + url);
if (!"".equals(request.getQueryString()) || request.getQueryString() != null) {
url = url + "?" + request.getQueryString();
}
/*
* java.util.Enumeration names = request.getParameterNames(); int i = 0;
* if (names != null) { while (names.hasMoreElements()) { String name =
* (String) names.nextElement(); if (i == 0) { url = url + "?"; } else {
* url = url + "&"; } i++;
*
* String value = request.getParameter(name); if (value == null) { value
* = ""; }
*
* url = url + name + "=" + value; try { //
* java.net.URLEncoder.encode(url, "ISO-8859"); } catch (Exception e) {
* e.printStackTrace(); } } }
*/
log.error("获取请求信息getRequestURL 参数 names=================================" + url);
try {
// String enUrl = java.net.URLEncoder.encode(url, "utf-8");
} catch (Exception ex) {
ex.printStackTrace();
}
log.error("获取请求信息getRequestURL end=================================");
return url;
}
/**
* 通过accessToken获取jsapi_ticket
*
* @param accessToken
* @param request
* @return
*/
public static Token getJsapi_ticket(String accessToken, HttpServletRequest request) {
Token token = null;
if (request.getSession() != null) {
token = (Token) request.getSession().getAttribute(accessToken + "ticket");
}
String requestUrl = ConfigUtil.JSAPI_TICKET.replace("ACCESS_TOKEN", accessToken);
if (null == token || ((new Date().getTime() - token.getTime()) / 1000) > 7150) {
// 发起GET请求获取凭证
JSONObject jsonObject = JSONObject.fromObject(httpsRequest(requestUrl, "GET", null));
log.error("获取token jsonObject====================", jsonObject.toString());
if (null != jsonObject) {
try {
token = new Token();
token.setAccessToken(jsonObject.getString("ticket"));
log.error("获取token ticket:{}", jsonObject.getString("ticket"));
token.setExpiresIn(jsonObject.getInt("expires_in"));
log.error("获取token expires_in:{}", jsonObject.getString("expires_in"));
token.setTime(new Date().getTime());
request.getSession().setAttribute(accessToken + "ticket", token);
} catch (JSONException e) {
token = null;
// 获取token失败
log.error("获取token失败 errcode:{} errmsg:{}", jsonObject.getString("errcode"), jsonObject.getString("errmsg"));
}
}
}
return token;
}
public static String urlEncodeUTF8(String source) {
String result = source;
try {
result = java.net.URLEncoder.encode(source, "utf-8");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
return result;
}
}
相关推荐
请求型接口是将参数封装成xml，以post方式提交到微信，微信响应结果；响应型接口则是响应微信的post请求。Wxpay_client_是请求型接口的基类。Wxpay_server_是响应型接口的基类。Wxpay_client_、Wxpay_server_都继承...
1.CommonUtil内包括 发起https请求并获取结果工具、获取access_token工具、URL编码(utf-8)工具、根据类型判断文件扩展名工具 2.MyX509TrustManager为证书信任管理器 3.SignUtil 为验证消息真实性(请求来源于微信)...
* Native支付——请求商家获取商品信息接口--NativeCall * 【其他】 * 静态链接二维码--NativeLink * JSAPI支付--JsApi * ===================================================== * 【CommonUtil】常用工具：...
前端采用jsapi发起支付时，弹出“支付签名验证失败”的微信签名解决demo参考（已经实践验证过） 构建支付参数，以便前端Js可以jsAPi的唤起微信支付 ArrayList<String> list = new ArrayList(); list.add(appId); ...
7. **权限管理**：对于Android开发，CommonUtil可能包含处理运行时权限请求的工具类，简化权限申请流程。 8. **加密解密**：如MD5、SHA等哈希算法，或者AES、RSA等加密算法的实现，确保数据的安全性。 9. **异常...
在IT行业中，算法是至关重要的组成部分，特别是在编程和软件开发领域。"Algorithm-commonUtil.zip"这个压缩包文件，从名称来看，很可能包含了用于通用算法实现的Java代码库，特别是针对Android平台。Java作为一种...
本仓库是Java开发常用工具类的总结，旨在追求给大家提供一个轻便简单的工具类库，同时能够cover住大家80%以上的工具类的需求。如果对你有用欢迎点个star，此外，如果你有兴趣和我一起维护该仓库，欢迎提PR或者issue...
工作中经常使用的Java工具类分享，做Java开发用得上。
**Java**在后台处理AJAX请求，通常涉及接收请求、执行业务逻辑、操作数据库以及返回结果。Struts2提供了一套MVC（Model-View-Controller）架构，使得开发者能够更轻松地处理HTTP请求和响应。在这个工具中，Java代码...
"commonutil"可能包含了如字符串处理、日期时间操作、网络请求、数据序列化等不同模块，每个模块负责一个特定的任务，使得代码结构清晰，易于维护。 2. **工具类（Utility Class）**：在Java中，工具类通常是一些...
总结起来，实现`call`层方法调用接口的步骤包括理解接口协议、创建并组装请求报文、获取请求报文头、组装完整请求、调用接口以及处理返回结果。这些步骤确保了外部或内部接口的正确调用和数据交换，是业务逻辑实现的...
Android开发最常用工具类 AppUtils DensityUtils HttpUtils KeyBoardUtils NetUtils ScreenUtils SDCardUtils SPUtils T AssetUtils CommonUtil Constants DataCleanManager DialogUtil FileUtils GsonTools ...
3. **android-common-master**：这可能是核心的通用工具库项目，包含了各种Android开发中常用的功能模块，比如网络请求、数据解析、文件操作、日期时间处理、权限管理等。开发者可以将其作为一个依赖库引入到自己的...
- **请求方法**：POST方式，这是向服务器发送数据的标准方法，适合于发送包含敏感信息的请求。 - **请求地址**：`https://xxxxx:xxxx/api/pama.do`，其中具体的IP地址和端口号由主账户端提供。 - **编码规范**：所有...
6.request请求处理工具类：CommonUtil 7.类型转换器：Convert 8.时间工具类：DateUtils 9.Excel导出工具类：ExportExcel 10.ID生成器工具类：IdUtils 11.反射工具类：ReflectUtils 12.xml转为java对象，java对象转...
这些工具类的方法是Android开发中非常常见且实用的，它们帮助开发者快速地获取设备信息，进行网络检测，以及进行UI相关的尺寸转换，提高了代码的复用性和效率。在实际项目中，根据需求，可以扩展此类，添加更多的...