- 浏览: 278657 次
- 性别:
- 来自: 深圳
文章分类
最新评论
-
u011563440:
u011563440 写道用反射A.class.toGener ...
Java接口中的内部接口和接口中的内部类 -
u011563440:
用反射A.class.toGenericString()--- ...
Java接口中的内部接口和接口中的内部类 -
narutolby:
因为接口本身不能实例化,所以在new 一个 接口的内部类时默认 ...
Java接口中的内部接口和接口中的内部类 -
hekuilove:
请问楼主,第四部如何做?在eclipse哪个位置?
eclipse中使用maven插件的问题:Updating index central|http://repo1.maven.org/maven2 -
小小生:
请问下,如果修改了数据库里面的订单任务的时间,那么不是要重启? ...
利用Spring动态对Quartz定时任务管理
昨天看了支付宝的登录接口代码,觉得有些东西还是对以后的开发有帮助的。下面就记录自己的感想。
首先是AlipayCore.java这个类,该类是请求、通知返回两个文件所调用的公用函数核心处理文件,不需要修改。方法主要是对签名和请求参数进行拼接:
- /**
- * 生成签名结果
- * @param sArray 要签名的数组
- * @return 签名结果字符串
- */
- public static String buildMysign(Map<String, String> sArray) {
- String prestr = createLinkString(sArray); //把数组所有元素,按照“参数=参数值”的模式用“&”字符拼接成字符串
- prestr = prestr + AlipayConfig.key; //把拼接后的字符串再与安全校验码直接连接起来
- String mysign = AlipayMd5Encrypt.md5(prestr);
- return mysign;
- }
- /**
- * 除去数组中的空值和签名参数
- * @param sArray 签名参数组
- * @return 去掉空值与签名参数后的新签名参数组
- */
- public static Map<String, String> paraFilter(Map<String, String> sArray) {
- Map<String, String> result = new HashMap<String, String>();
- if (sArray == null || sArray.size() <= 0) {
- return result;
- }
- for (String key : sArray.keySet()) {
- String value = sArray.get(key);
- if (value == null || value.equals("") || key.equalsIgnoreCase("sign")
- || key.equalsIgnoreCase("sign_type")) {
- continue;
- }
- result.put(key, value);
- }
- return result;
- }
- /**
- * 把数组所有元素排序,并按照“参数=参数值”的模式用“&”字符拼接成字符串
- * @param params 需要排序并参与字符拼接的参数组
- * @return 拼接后字符串
- */
- public static String createLinkString(Map<String, String> params) {
- List<String> keys = new ArrayList<String>(params.keySet());
- Collections.sort(keys);
- String prestr = "";
- for (int i = 0; i < keys.size(); i++) {
- String key = keys.get(i);
- String value = params.get(key);
- if (i == keys.size() - 1) {//拼接时,不包括最后一个&字符
- prestr = prestr + key + "=" + value;
- } else {
- prestr = prestr + key + "=" + value + "&";
- }
- }
- return prestr;
- }
/** * 生成签名结果 * @param sArray 要签名的数组 * @return 签名结果字符串 */ public static String buildMysign(Map<String, String> sArray) { String prestr = createLinkString(sArray); //把数组所有元素,按照“参数=参数值”的模式用“&”字符拼接成字符串 prestr = prestr + AlipayConfig.key; //把拼接后的字符串再与安全校验码直接连接起来 String mysign = AlipayMd5Encrypt.md5(prestr); return mysign; } /** * 除去数组中的空值和签名参数 * @param sArray 签名参数组 * @return 去掉空值与签名参数后的新签名参数组 */ public static Map<String, String> paraFilter(Map<String, String> sArray) { Map<String, String> result = new HashMap<String, String>(); if (sArray == null || sArray.size() <= 0) { return result; } for (String key : sArray.keySet()) { String value = sArray.get(key); if (value == null || value.equals("") || key.equalsIgnoreCase("sign") || key.equalsIgnoreCase("sign_type")) { continue; } result.put(key, value); } return result; } /** * 把数组所有元素排序,并按照“参数=参数值”的模式用“&”字符拼接成字符串 * @param params 需要排序并参与字符拼接的参数组 * @return 拼接后字符串 */ public static String createLinkString(Map<String, String> params) { List<String> keys = new ArrayList<String>(params.keySet()); Collections.sort(keys); String prestr = ""; for (int i = 0; i < keys.size(); i++) { String key = keys.get(i); String value = params.get(key); if (i == keys.size() - 1) {//拼接时,不包括最后一个&字符 prestr = prestr + key + "=" + value; } else { prestr = prestr + key + "=" + value + "&"; } } return prestr; }
AlipayConfig.java这个类是一个基础配置类,主要用来设置账户有关信息和返回路径:
- //↓↓↓↓↓↓↓↓↓↓请在这里配置您的基本信息↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓
- // 合作身份者ID,以2088开头由16位纯数字组成的字符串
- public static String partner = "";
- // 交易安全检验码,由数字和字母组成的32位字符串
- public static String key = "";
- // 当前页面跳转后的页面 要用 http://格式的完整路径,不允许加?id=123这类自定义参数
- // 域名不能写成http://localhost/alipay.auth.authorize_jsp_utf8/return_url.jsp ,否则会导致return_url执行无效
- public static String return_url = "http://127.0.0.1:8080/alipay.auth.authorize_jsp_utf8/return_url.jsp";
- //↑↑↑↑↑↑↑↑↑↑请在这里配置您的基本信息↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑
- // 调试用,创建TXT日志路径
- public static String log_path = "D:\\alipay_log_" + System.currentTimeMillis()+".txt";
- // 字符编码格式 目前支持 gbk 或 utf-8
- public static String input_charset = "UTF-8";
- // 签名方式 不需修改
- public static String sign_type = "MD5";
- //访问模式,根据自己的服务器是否支持ssl访问,若支持请选择https;若不支持请选择http
- public static String transport = "http";
//↓↓↓↓↓↓↓↓↓↓请在这里配置您的基本信息↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓ // 合作身份者ID,以2088开头由16位纯数字组成的字符串 public static String partner = ""; // 交易安全检验码,由数字和字母组成的32位字符串 public static String key = ""; // 当前页面跳转后的页面 要用 http://格式的完整路径,不允许加?id=123这类自定义参数 // 域名不能写成http://localhost/alipay.auth.authorize_jsp_utf8/return_url.jsp ,否则会导致return_url执行无效 public static String return_url = "http://127.0.0.1:8080/alipay.auth.authorize_jsp_utf8/return_url.jsp"; //↑↑↑↑↑↑↑↑↑↑请在这里配置您的基本信息↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑ // 调试用,创建TXT日志路径 public static String log_path = "D:\\alipay_log_" + System.currentTimeMillis()+".txt"; // 字符编码格式 目前支持 gbk 或 utf-8 public static String input_charset = "UTF-8"; // 签名方式 不需修改 public static String sign_type = "MD5"; //访问模式,根据自己的服务器是否支持ssl访问,若支持请选择https;若不支持请选择http public static String transport = "http";AlipayMd5Encrypt.java这个类是对签名进行加密的工具类,不需要修改即可用:
- /**
- * 对字符串进行MD5签名
- *
- * @param text
- * 明文
- *
- * @return 密文
- */
- public static String md5(String text) {
- return DigestUtils.md5Hex(getContentBytes(text, AlipayConfig.input_charset));
- }
- /**
- * @param content
- * @param charset
- * @return
- * @throws SignatureException
- * @throws UnsupportedEncodingException
- */
- private static byte[] getContentBytes(String content, String charset) {
- if (charset == null || "".equals(charset)) {
- return content.getBytes();
- }
- try {
- return content.getBytes(charset);
- } catch (UnsupportedEncodingException e) {
- throw new RuntimeException("MD5签名过程中出现错误,指定的编码集不对,您目前指定的编码集是:" + charset);
- }
- }
/** * 对字符串进行MD5签名 * * @param text * 明文 * * @return 密文 */ public static String md5(String text) { return DigestUtils.md5Hex(getContentBytes(text, AlipayConfig.input_charset)); } /** * @param content * @param charset * @return * @throws SignatureException * @throws UnsupportedEncodingException */ private static byte[] getContentBytes(String content, String charset) { if (charset == null || "".equals(charset)) { return content.getBytes(); } try { return content.getBytes(charset); } catch (UnsupportedEncodingException e) { throw new RuntimeException("MD5签名过程中出现错误,指定的编码集不对,您目前指定的编码集是:" + charset); } }接下来是AlipayNotify.java这个类,这个类主要是处理支付宝各接口通知返回:
- /**
- * HTTPS形式消息验证地址
- */
- private static final String HTTPS_VERIFY_URL = "https://www.alipay.com/cooperate/gateway.do?service=notify_verify&";
- /**
- * HTTP形式消息验证地址
- */
- private static final String HTTP_VERIFY_URL = "http://notify.alipay.com/trade/notify_query.do?";
- /**
- * 验证消息是否是支付宝发出的合法消息
- * @param params 通知返回来的参数数组
- * @return 验证结果
- */
- public static boolean verify(Map<String, String> params) {
- String mysign = getMysign(params);
- String responseTxt = "true";
- if(params.get("notify_id") != null) {responseTxt = verifyResponse(params.get("notify_id"));}
- String sign = "";
- if(params.get("sign") != null) {sign = params.get("sign");}
- //写日志记录(若要调试,请取消下面两行注释)
- //String sWord = "responseTxt=" + responseTxt + "\n notify_url_log:sign=" + sign + "&mysign="
- // + mysign + "\n notify回来的参数:" + AlipayCore.createLinkString(params);
- //AlipayCore.logResult(sWord);
- //验证
- //responsetTxt的结果不是true,与服务器设置问题、合作身份者ID、notify_id一分钟失效有关
- //mysign与sign不等,与安全校验码、请求时的参数格式(如:带自定义参数等)、编码格式有关
- if (mysign.equals(sign) && responseTxt.equals("true")) {
- return true;
- } else {
- return false;
- }
- }
- /**
- * 根据反馈回来的信息,生成签名结果
- * @param Params 通知返回来的参数数组
- * @return 生成的签名结果
- */
- private static String getMysign(Map<String, String> Params) {
- Map<String, String> sParaNew = AlipayCore.paraFilter(Params);//过滤空值、sign与sign_type参数
- String mysign = AlipayCore.buildMysign(sParaNew);//获得签名结果
- return mysign;
- }
- /**
- * 获取远程服务器ATN结果,验证返回URL
- * @param notify_id 通知校验ID
- * @return 服务器ATN结果
- * 验证结果集:
- * invalid命令参数不对 出现这个错误,请检测返回处理中partner和key是否为空
- * true 返回正确信息
- * false 请检查防火墙或者是服务器阻止端口问题以及验证时间是否超过一分钟
- */
- private static String verifyResponse(String notify_id) {
- //获取远程服务器ATN结果,验证是否是支付宝服务器发来的请求
- String transport = AlipayConfig.transport;
- String partner = AlipayConfig.partner;
- String veryfy_url = "";
- if (transport.equalsIgnoreCase("https")) {
- veryfy_url = HTTPS_VERIFY_URL;
- } else {
- veryfy_url = HTTP_VERIFY_URL;
- }
- veryfy_url = veryfy_url + "partner=" + partner + "¬ify_id=" + notify_id;
- return checkUrl(veryfy_url);
- }
- /**
- * 获取远程服务器ATN结果
- * @param urlvalue 指定URL路径地址
- * @return 服务器ATN结果
- * 验证结果集:
- * invalid命令参数不对 出现这个错误,请检测返回处理中partner和key是否为空
- * true 返回正确信息
- * false 请检查防火墙或者是服务器阻止端口问题以及验证时间是否超过一分钟
- */
- private static String checkUrl(String urlvalue) {
- String inputLine = "";
- try {
- URL url = new URL(urlvalue);
- HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();
- BufferedReader in = new BufferedReader(new InputStreamReader(urlConnection
- .getInputStream()));
- inputLine = in.readLine().toString();
- } catch (Exception e) {
- e.printStackTrace();
- inputLine = "";
- }
- return inputLine;
- }
/** * HTTPS形式消息验证地址 */ private static final String HTTPS_VERIFY_URL = "https://www.alipay.com/cooperate/gateway.do?service=notify_verify&"; /** * HTTP形式消息验证地址 */ private static final String HTTP_VERIFY_URL = "http://notify.alipay.com/trade/notify_query.do?"; /** * 验证消息是否是支付宝发出的合法消息 * @param params 通知返回来的参数数组 * @return 验证结果 */ public static boolean verify(Map<String, String> params) { String mysign = getMysign(params); String responseTxt = "true"; if(params.get("notify_id") != null) {responseTxt = verifyResponse(params.get("notify_id"));} String sign = ""; if(params.get("sign") != null) {sign = params.get("sign");} //写日志记录(若要调试,请取消下面两行注释) //String sWord = "responseTxt=" + responseTxt + "\n notify_url_log:sign=" + sign + "&mysign=" // + mysign + "\n notify回来的参数:" + AlipayCore.createLinkString(params); //AlipayCore.logResult(sWord); //验证 //responsetTxt的结果不是true,与服务器设置问题、合作身份者ID、notify_id一分钟失效有关 //mysign与sign不等,与安全校验码、请求时的参数格式(如:带自定义参数等)、编码格式有关 if (mysign.equals(sign) && responseTxt.equals("true")) { return true; } else { return false; } } /** * 根据反馈回来的信息,生成签名结果 * @param Params 通知返回来的参数数组 * @return 生成的签名结果 */ private static String getMysign(Map<String, String> Params) { Map<String, String> sParaNew = AlipayCore.paraFilter(Params);//过滤空值、sign与sign_type参数 String mysign = AlipayCore.buildMysign(sParaNew);//获得签名结果 return mysign; } /** * 获取远程服务器ATN结果,验证返回URL * @param notify_id 通知校验ID * @return 服务器ATN结果 * 验证结果集: * invalid命令参数不对 出现这个错误,请检测返回处理中partner和key是否为空 * true 返回正确信息 * false 请检查防火墙或者是服务器阻止端口问题以及验证时间是否超过一分钟 */ private static String verifyResponse(String notify_id) { //获取远程服务器ATN结果,验证是否是支付宝服务器发来的请求 String transport = AlipayConfig.transport; String partner = AlipayConfig.partner; String veryfy_url = ""; if (transport.equalsIgnoreCase("https")) { veryfy_url = HTTPS_VERIFY_URL; } else { veryfy_url = HTTP_VERIFY_URL; } veryfy_url = veryfy_url + "partner=" + partner + "¬ify_id=" + notify_id; return checkUrl(veryfy_url); } /** * 获取远程服务器ATN结果 * @param urlvalue 指定URL路径地址 * @return 服务器ATN结果 * 验证结果集: * invalid命令参数不对 出现这个错误,请检测返回处理中partner和key是否为空 * true 返回正确信息 * false 请检查防火墙或者是服务器阻止端口问题以及验证时间是否超过一分钟 */ private static String checkUrl(String urlvalue) { String inputLine = ""; try { URL url = new URL(urlvalue); HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection(); BufferedReader in = new BufferedReader(new InputStreamReader(urlConnection .getInputStream())); inputLine = in.readLine().toString(); } catch (Exception e) { e.printStackTrace(); inputLine = ""; } return inputLine; }下面我们就需要进行alipay的访问请求了,在请求过程中我们要有请求参数数组,提交的表单,有了这些条件之后我们就可以进行模拟HTTP请求获得返回的数据了。生成请求参数数组的代码如下:
- /**
- * 生成要请求给支付宝的参数数组
- * @param sParaTemp 请求前的参数数组
- * @return 要请求的参数数组
- */
- private static Map<String, String> buildRequestPara(Map<String, String> sParaTemp) {
- //除去数组中的空值和签名参数
- Map<String, String> sPara = AlipayCore.paraFilter(sParaTemp);
- //生成签名结果
- String mysign = AlipayCore.buildMysign(sPara);
- //签名结果与签名方式加入请求提交参数组中
- sPara.put("sign", mysign);
- sPara.put("sign_type", AlipayConfig.sign_type);
- return sPara;
- }
/** * 生成要请求给支付宝的参数数组 * @param sParaTemp 请求前的参数数组 * @return 要请求的参数数组 */ private static Map<String, String> buildRequestPara(Map<String, String> sParaTemp) { //除去数组中的空值和签名参数 Map<String, String> sPara = AlipayCore.paraFilter(sParaTemp); //生成签名结果 String mysign = AlipayCore.buildMysign(sPara); //签名结果与签名方式加入请求提交参数组中 sPara.put("sign", mysign); sPara.put("sign_type", AlipayConfig.sign_type); return sPara; }构造提交表单代码:
- /**
- * 构造提交表单HTML数据
- * @param sParaTemp 请求参数数组
- * @param gateway 网关地址
- * @param strMethod 提交方式。两个值可选:post、get
- * @param strButtonName 确认按钮显示文字
- * @return 提交表单HTML文本
- */
- public static String buildForm(Map<String, String> sParaTemp, String gateway, String strMethod,
- String strButtonName) {
- //待请求参数数组
- Map<String, String> sPara = buildRequestPara(sParaTemp);
- List<String> keys = new ArrayList<String>(sPara.keySet());
- StringBuffer sbHtml = new StringBuffer();
- sbHtml.append("<form id=\"alipaysubmit\" name=\"alipaysubmit\" action=\"" + gateway
- + "_input_charset=" + AlipayConfig.input_charset + "\" method=\"" + strMethod
- + "\">");
- for (int i = 0; i < keys.size(); i++) {
- String name = (String) keys.get(i);
- String value = (String) sPara.get(name);
- sbHtml.append("<input type=\"hidden\" name=\"" + name + "\" value=\"" + value + "\"/>");
- }
- //submit按钮控件请不要含有name属性
- sbHtml.append("<input type=\"submit\" value=\"" + strButtonName + "\" style=\"display:none;\"></form>");
- sbHtml.append("<script>document.forms['alipaysubmit'].submit();</script>");
- return sbHtml.toString();
- }
/** * 构造提交表单HTML数据 * @param sParaTemp 请求参数数组 * @param gateway 网关地址 * @param strMethod 提交方式。两个值可选:post、get * @param strButtonName 确认按钮显示文字 * @return 提交表单HTML文本 */ public static String buildForm(Map<String, String> sParaTemp, String gateway, String strMethod, String strButtonName) { //待请求参数数组 Map<String, String> sPara = buildRequestPara(sParaTemp); List<String> keys = new ArrayList<String>(sPara.keySet()); StringBuffer sbHtml = new StringBuffer(); sbHtml.append("<form id=\"alipaysubmit\" name=\"alipaysubmit\" action=\"" + gateway + "_input_charset=" + AlipayConfig.input_charset + "\" method=\"" + strMethod + "\">"); for (int i = 0; i < keys.size(); i++) { String name = (String) keys.get(i); String value = (String) sPara.get(name); sbHtml.append("<input type=\"hidden\" name=\"" + name + "\" value=\"" + value + "\"/>"); } //submit按钮控件请不要含有name属性 sbHtml.append("<input type=\"submit\" value=\"" + strButtonName + "\" style=\"display:none;\"></form>"); sbHtml.append("<script>document.forms['alipaysubmit'].submit();</script>"); return sbHtml.toString(); }构造模拟远程HTTP的POST请求,获取支付宝的返回XML处理结果:
- public static String sendPostInfo(Map<String, String> sParaTemp, String gateway)
- throws Exception {
- //待请求参数数组
- Map<String, String> sPara = buildRequestPara(sParaTemp);
- HttpProtocolHandler httpProtocolHandler = HttpProtocolHandler.getInstance();
- HttpRequest request = new HttpRequest(HttpResultType.BYTES);
- //设置编码集
- request.setCharset(AlipayConfig.input_charset);
- request.setParameters(generatNameValuePair(sPara));
- request.setUrl(gateway+"_input_charset="+AlipayConfig.input_charset);
- HttpResponse response = httpProtocolHandler.execute(request);
- if (response == null) {
- return null;
- }
- String strResult = response.getStringResult();
- return strResult;
- }
public static String sendPostInfo(Map<String, String> sParaTemp, String gateway) throws Exception { //待请求参数数组 Map<String, String> sPara = buildRequestPara(sParaTemp); HttpProtocolHandler httpProtocolHandler = HttpProtocolHandler.getInstance(); HttpRequest request = new HttpRequest(HttpResultType.BYTES); //设置编码集 request.setCharset(AlipayConfig.input_charset); request.setParameters(generatNameValuePair(sPara)); request.setUrl(gateway+"_input_charset="+AlipayConfig.input_charset); HttpResponse response = httpProtocolHandler.execute(request); if (response == null) { return null; } String strResult = response.getStringResult(); return strResult; }generatNameValuePair方法:
- /**
- * MAP类型数组转换成NameValuePair类型
- * @param properties MAP类型数组
- * @return NameValuePair类型数组
- */
- private static NameValuePair[] generatNameValuePair(Map<String, String> properties) {
- NameValuePair[] nameValuePair = new NameValuePair[properties.size()];
- int i = 0;
- for (Map.Entry<String, String> entry : properties.entrySet()) {
- nameValuePair[i++] = new NameValuePair(entry.getKey(), entry.getValue());
- }
- return nameValuePair;
- }
/** * MAP类型数组转换成NameValuePair类型 * @param properties MAP类型数组 * @return NameValuePair类型数组 */ private static NameValuePair[] generatNameValuePair(Map<String, String> properties) { NameValuePair[] nameValuePair = new NameValuePair[properties.size()]; int i = 0; for (Map.Entry<String, String> entry : properties.entrySet()) { nameValuePair[i++] = new NameValuePair(entry.getKey(), entry.getValue()); } return nameValuePair; }接下来要看看HttpProtocolHandler.java这个类了,这个类是模拟HTTP请求的核心类,最主要的是execute这个执行http请求的方法:
- public HttpResponse execute(HttpRequest request) {
- HttpClient httpclient = new HttpClient(connectionManager);
- // 设置连接超时
- int connectionTimeout = defaultConnectionTimeout;
- if (request.getConnectionTimeout() > 0) {
- connectionTimeout = request.getConnectionTimeout();
- }
- httpclient.getHttpConnectionManager().getParams().setConnectionTimeout(connectionTimeout);
- // 设置回应超时
- int soTimeout = defaultSoTimeout;
- if (request.getTimeout() > 0) {
- soTimeout = request.getTimeout();
- }
- httpclient.getHttpConnectionManager().getParams().setSoTimeout(soTimeout);
- // 设置等待ConnectionManager释放connection的时间
- httpclient.getParams().setConnectionManagerTimeout(defaultHttpConnectionManagerTimeout);
- String charset = request.getCharset();
- charset = charset == null ? DEFAULT_CHARSET : charset;
- HttpMethod method = null;
- if (request.getMethod().equals(HttpRequest.METHOD_GET)) {
- method = new GetMethod(request.getUrl());
- method.getParams().setCredentialCharset(charset);
- // parseNotifyConfig会保证使用GET方法时,request一定使用QueryString
- method.setQueryString(request.getQueryString());
- } else {
- method = new PostMethod(request.getUrl());
- ((PostMethod) method).addParameters(request.getParameters());
- method.addRequestHeader("Content-Type",
- "application/x-www-form-urlencoded; text/html; charset=" + charset);
- }
- // 设置Http Header中的User-Agent属性
- method.addRequestHeader("User-Agent", "Mozilla/4.0");
- HttpResponse response = new HttpResponse();
- try {
- httpclient.executeMethod(method);
- if (request.getResultType().equals(HttpResultType.STRING)) {
- response.setStringResult(method.getResponseBodyAsString());
- } else if (request.getResultType().equals(HttpResultType.BYTES)) {
- response.setByteResult(method.getResponseBody());
- }
- response.setResponseHeaders(method.getResponseHeaders());
- } catch (UnknownHostException ex) {
- return null;
- } catch (IOException ex) {
- return null;
- } catch (Exception ex) {
- return null;
- } finally {
- method.releaseConnection();
- }
- return response;
- }
public HttpResponse execute(HttpRequest request) { HttpClient httpclient = new HttpClient(connectionManager); // 设置连接超时 int connectionTimeout = defaultConnectionTimeout; if (request.getConnectionTimeout() > 0) { connectionTimeout = request.getConnectionTimeout(); } httpclient.getHttpConnectionManager().getParams().setConnectionTimeout(connectionTimeout); // 设置回应超时 int soTimeout = defaultSoTimeout; if (request.getTimeout() > 0) { soTimeout = request.getTimeout(); } httpclient.getHttpConnectionManager().getParams().setSoTimeout(soTimeout); // 设置等待ConnectionManager释放connection的时间 httpclient.getParams().setConnectionManagerTimeout(defaultHttpConnectionManagerTimeout); String charset = request.getCharset(); charset = charset == null ? DEFAULT_CHARSET : charset; HttpMethod method = null; if (request.getMethod().equals(HttpRequest.METHOD_GET)) { method = new GetMethod(request.getUrl()); method.getParams().setCredentialCharset(charset); // parseNotifyConfig会保证使用GET方法时,request一定使用QueryString method.setQueryString(request.getQueryString()); } else { method = new PostMethod(request.getUrl()); ((PostMethod) method).addParameters(request.getParameters()); method.addRequestHeader("Content-Type", "application/x-www-form-urlencoded; text/html; charset=" + charset); } // 设置Http Header中的User-Agent属性 method.addRequestHeader("User-Agent", "Mozilla/4.0"); HttpResponse response = new HttpResponse(); try { httpclient.executeMethod(method); if (request.getResultType().equals(HttpResultType.STRING)) { response.setStringResult(method.getResponseBodyAsString()); } else if (request.getResultType().equals(HttpResultType.BYTES)) { response.setByteResult(method.getResponseBody()); } response.setResponseHeaders(method.getResponseHeaders()); } catch (UnknownHostException ex) { return null; } catch (IOException ex) { return null; } catch (Exception ex) { return null; } finally { method.releaseConnection(); } return response; }当然我们需要在new HttpProtocolHandler这个类的时候创建一个线程安全的HTTP连接池,为什么要线程安全,下文会有提示。我们把这个步骤放到私有的构造方法当中:
- private HttpProtocolHandler() {
- connectionManager = new MultiThreadedHttpConnectionManager();
- connectionManager.getParams().setDefaultMaxConnectionsPerHost(defaultMaxConnPerHost);
- connectionManager.getParams().setMaxTotalConnections(defaultMaxTotalConn);
- IdleConnectionTimeoutThread ict = new IdleConnectionTimeoutThread();
- ict.addConnectionManager(connectionManager);
- ict.setConnectionTimeout(defaultIdleConnTimeout);
- ict.start();
- }
private HttpProtocolHandler() { connectionManager = new MultiThreadedHttpConnectionManager(); connectionManager.getParams().setDefaultMaxConnectionsPerHost(defaultMaxConnPerHost); connectionManager.getParams().setMaxTotalConnections(defaultMaxTotalConn); IdleConnectionTimeoutThread ict = new IdleConnectionTimeoutThread(); ict.addConnectionManager(connectionManager); ict.setConnectionTimeout(defaultIdleConnTimeout); ict.start(); }然后使用如下方法来使其他类能使用getInstance()方法就获得HttpProtocolHandler这个类的实例对象,并且是线程安全的:
- private static HttpProtocolHandler httpProtocolHandler = new HttpProtocolHandler();
- /**
- * 工厂方法
- *
- * @return
- */
- public static HttpProtocolHandler getInstance() {
- return httpProtocolHandler;
- }
private static HttpProtocolHandler httpProtocolHandler = new HttpProtocolHandler(); /** * 工厂方法 * * @return */ public static HttpProtocolHandler getInstance() { return httpProtocolHandler; }此类当中还有一些属性,用来设置http连接的超时时间,连接数等参数:
- private static String DEFAULT_CHARSET = "GBK";
- /** 连接超时时间,由bean factory设置,缺省为8秒钟 */
- private int defaultConnectionTimeout = 8000;
- /** 回应超时时间, 由bean factory设置,缺省为30秒钟 */
- private int defaultSoTimeout = 30000;
- /** 闲置连接超时时间, 由bean factory设置,缺省为60秒钟 */
- private int defaultIdleConnTimeout = 60000;
- private int defaultMaxConnPerHost = 30;
- private int defaultMaxTotalConn = 80;
- /** 默认等待HttpConnectionManager返回连接超时(只有在达到最大连接数时起作用):1秒*/
- private static final long defaultHttpConnectionManagerTimeout = 3 * 1000;
- /**
- * HTTP连接管理器,该连接管理器必须是线程安全的.(如何设置线程安全上文已经写了)
- */
- private HttpConnectionManager connectionManager;
private static String DEFAULT_CHARSET = "GBK"; /** 连接超时时间,由bean factory设置,缺省为8秒钟 */ private int defaultConnectionTimeout = 8000; /** 回应超时时间, 由bean factory设置,缺省为30秒钟 */ private int defaultSoTimeout = 30000; /** 闲置连接超时时间, 由bean factory设置,缺省为60秒钟 */ private int defaultIdleConnTimeout = 60000; private int defaultMaxConnPerHost = 30; private int defaultMaxTotalConn = 80; /** 默认等待HttpConnectionManager返回连接超时(只有在达到最大连接数时起作用):1秒*/ private static final long defaultHttpConnectionManagerTimeout = 3 * 1000; /** * HTTP连接管理器,该连接管理器必须是线程安全的.(如何设置线程安全上文已经写了) */ private HttpConnectionManager connectionManager;此类当中还有HttpClient和HttpResponse这两个类,这两个类主要是对HTTP请求的封装和返回http的相应消息。这两个类就不在这里讲了,就是两个pojo类,HttpClient里面封装了请求需要的属性比如字符集,请求method,超时时间等,HttpResponse里面是响应头和返回结构的封装。
最后一个是支付宝各接口构造类AlipayService.java,
- /**
- * 支付宝提供给商户的服务接入网关URL(新)
- */
- private static final String ALIPAY_GATEWAY_NEW = "https://mapi.alipay.com/gateway.do?";
- /**
- * 构造快捷登录接口
- * @param sParaTemp 请求参数集合
- * @return 表单提交HTML信息
- */
- public static String alipay_auth_authorize(Map<String, String> sParaTemp) {
- //增加基本配置
- sParaTemp.put("service", "alipay.auth.authorize");
- sParaTemp.put("target_service", "user.auth.quick.login");
- sParaTemp.put("partner", AlipayConfig.partner);
- sParaTemp.put("return_url", AlipayConfig.return_url);
- sParaTemp.put("_input_charset", AlipayConfig.input_charset);
- String strButtonName = "确认";
- return AlipaySubmit.buildForm(sParaTemp, ALIPAY_GATEWAY_NEW, "get", strButtonName);
- }
- /**
- * 用于防钓鱼,调用接口query_timestamp来获取时间戳的处理函数
- * 注意:远程解析XML出错,与服务器是否支持SSL等配置有关
- * @return 时间戳字符串
- * @throws IOException
- * @throws DocumentException
- * @throws MalformedURLException
- */
- public static String query_timestamp() throws MalformedURLException,
- DocumentException, IOException {
- //构造访问query_timestamp接口的URL串
- String strUrl = ALIPAY_GATEWAY_NEW + "service=query_timestamp&partner=" + AlipayConfig.partner;
- StringBuffer result = new StringBuffer();
- SAXReader reader = new SAXReader();
- Document doc = reader.read(new URL(strUrl).openStream());
- List<Node> nodeList = doc.selectNodes("//alipay/*");
- for (Node node : nodeList) {
- // 截取部分不需要解析的信息
- if (node.getName().equals("is_success") && node.getText().equals("T")) {
- // 判断是否有成功标示
- List<Node> nodeList1 = doc.selectNodes("//response/timestamp/*");
- for (Node node1 : nodeList1) {
- result.append(node1.getText());
- }
- }
- }
- return result.toString();
- }
/** * 支付宝提供给商户的服务接入网关URL(新) */ private static final String ALIPAY_GATEWAY_NEW = "https://mapi.alipay.com/gateway.do?"; /** * 构造快捷登录接口 * @param sParaTemp 请求参数集合 * @return 表单提交HTML信息 */ public static String alipay_auth_authorize(Map<String, String> sParaTemp) { //增加基本配置 sParaTemp.put("service", "alipay.auth.authorize"); sParaTemp.put("target_service", "user.auth.quick.login"); sParaTemp.put("partner", AlipayConfig.partner); sParaTemp.put("return_url", AlipayConfig.return_url); sParaTemp.put("_input_charset", AlipayConfig.input_charset); String strButtonName = "确认"; return AlipaySubmit.buildForm(sParaTemp, ALIPAY_GATEWAY_NEW, "get", strButtonName); } /** * 用于防钓鱼,调用接口query_timestamp来获取时间戳的处理函数 * 注意:远程解析XML出错,与服务器是否支持SSL等配置有关 * @return 时间戳字符串 * @throws IOException * @throws DocumentException * @throws MalformedURLException */ public static String query_timestamp() throws MalformedURLException, DocumentException, IOException { //构造访问query_timestamp接口的URL串 String strUrl = ALIPAY_GATEWAY_NEW + "service=query_timestamp&partner=" + AlipayConfig.partner; StringBuffer result = new StringBuffer(); SAXReader reader = new SAXReader(); Document doc = reader.read(new URL(strUrl).openStream()); List<Node> nodeList = doc.selectNodes("//alipay/*"); for (Node node : nodeList) { // 截取部分不需要解析的信息 if (node.getName().equals("is_success") && node.getText().equals("T")) { // 判断是否有成功标示 List<Node> nodeList1 = doc.selectNodes("//response/timestamp/*"); for (Node node1 : nodeList1) { result.append(node1.getText()); } } } return result.toString(); }到这里支付宝的登录接口基本上已经结束了,讲的不是很详细,具体流程和代码在这里下载:http://download.csdn.net/detail/uohzoaix/4009777。
发表评论
-
各类软件开发文档的英文缩写
2013-04-11 16:20 3107各类软件开发文档的英文缩写 文 ... -
Maven仓库搜索网址
2013-01-16 23:44 860Sonatype Nexus: http://reposi ... -
大型网站架构演变和知识体系 (转)
2012-06-06 10:10 1250转:http://sishuok.com/forum/blog ... -
运输管理系统(Transportation Management System,TMS)
2012-06-04 16:14 2754运输管理系统概述 运输是物流运作的重要环节,在各个环节中 ... -
2012年最受欢迎的PHP框架
2012-06-04 10:24 985http://www.cnbeta.com/articles/ ... -
pid, uid, gid相关
2011-12-31 21:50 1588pid: process id,进程IDppid: paren ... -
code.google.com,https://code.google.com/hosting/settings不能访问
2011-12-25 21:10 1534访问code.google.com出错,google下解决方案 ... -
UML类关系:依赖,关联,聚合和组合
2011-12-13 16:00 1545继承 generalization 指的是一 ... -
头文件.h和源文件.cpp的关系
2011-10-07 11:14 5366(对标题的解释:标题中 ... -
正则表达式--来自维基百科
2011-07-01 09:45 1470基本概念 一个正则表 ... -
修改Liferay-prota6.0.5的数据库为MySql
2010-10-27 23:01 2607指定Liferay-prota6.0.5的数据库为MyS ... -
也谈如何架构一个"马马虎虎"的网站?
2010-05-20 16:42 1208所谓“Just so so”,翻译 ... -
软件开发的好网址
2010-05-20 14:08 1283Sun公司的J2EE中文API: http://do ...
相关推荐
java 支付宝单笔交易查询接口返回xml解析
后台可对接多个专用json 接口解析,可以 m3u8 资源站对接配置当所有的解析失效时将会启用资源站解析(你也可以留空其他解析只填写资源站解析) 有支持替换资源系统,也可对接第三方资源站,对接支付宝当面付,支持...
解析两个域名(包括2级域名)到你的主机站点上,比如解析了www.xxx.com和m.xxx.com分别作为pc端和手机端域名 将根目录下的demo.sql数据库导入到您的mysql数据库内,打开/application/common/Conf/config.php文件,按照...
后台可对接多个专用 json 接口解析,可以 m3u8 资源站对接配置当所有的解析失效时将会启用资源站解析(你也可以留空其他解析只填写资源站解析) 有支持替换资源系统,也可对接第三方资源站,对接支付宝当面付,支持...
背景原因 目前由双牛掌柜为主导框架开发的一系列产品中,网络请求框架请求到的数据是默认解析成Model类的。即项目中不会手动去解析网络请求到的json数据。...当请求接口时支付宝返回的json如下(隐私数据已隐藏): {
后台可对接多个专用 json 接口解析,可以 m3u8 资源站对接配置当所有的解析失效时将会启用资源站解析(你也可以留空其他解析只填写资源站解析) 有支持替换资源系统,也可对接第三方资源站,对接支付宝当面付,支持...
后台可对接多个专用json 接口解析,可以 m3u8 资源站对接配置当所有的解析失效时将会启用资源站解析(你也可以留空其他解析只填写资源站解析) 有支持替换资源系统,也可对接第三方资源站,对接支付宝当面付,支持...
申请支付宝接口的简单流程,包括图文解析。不包括后期开发流程
很多朋友在做ios开发项目时,遇到支付宝支付成功返回字符串的处理操作不知道该怎么办,今天小编给大家分享实例代码,需要的朋友参考下
8开发,是一款非常高端的PPT模板,图片素材下载站模板非常适合大型图库下载站,配有手机端模板,支持自定义设置会员组,支持支付宝微信扫码开通VIP,支持每日下载次数限定,支持QQ,微信登录接口。支持火车头数据...
源码介绍: ... 搭建必备:服务器/主机 域名 ...5.支付接口:支持支付宝官方pc扫码、手机网站支付、支付宝当面付;支持QQ官方扫码支付、手机支付;支持微信pc扫码、jsapi公众号支付、微信h5;官方码支付等等
而小程序开发文档上边提供的获取手机号码的接口(getPhoneNumber())返回的是密文,需要服务器端进行解密,但是官方提供的开发文档一如既往的乱,如果没有对小程序开发文档有一个整体的了解,搞懂解密流程还是有点难...
本客户端基于java swing 开发,实现了个人支付宝账户到账准实时监控,主要思路是定时扫描支付宝账户商家账户详细页面,抓取接口响应数据并解析,展示在系统列表页面
近期在了解个人支付接口,希望能解决我在微信上支付的问题。找了很多平台对比再三,感觉 payjq 比较专业。同时支持支付宝和微信,由于本人支付宝还没开通(需要有一定流量才给开通),本文重点讲一下微信收银台模式...
这篇文章主要介绍了小程序api实现promise封装过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 微信小程序和支付宝小程序的api封装方法是一样的,都是...
支付宝钱包移动支付Java SDK[2015-11-4]本SDK实现**"功能流程"**图中的第2和第5步,并提供链接页面中**"数据交互"图中的第1和解析第9步。适用于构建图中所示的基于Java的“商户服务端”**。
VIP影视网站源码全套 支持三端 带后台管理 可接第三...多方视频资源可选,超清极速解析,三端均无任何广告,完美观看体验!可接广告可接入第三方支付收费(支付宝,微信,QQ钱包),带卡密系统,有邀请奖励,推广无忧……
WHMCS是一套国外流行的域名主机管理软件,跟国内众所周知的IDCSystem一样,主要在用户管理、财务管理、域名接口、服务器管理面板接口等方面...这是WHMCS5.1的破解版,带汉化包,支付宝接口,虽然有点贵,但还是值了。
1.支持RSA加解密及验签 2.支持条码一维和二维条码 3.支持XML构建及解析 4.支持JSON检构及解析 5.支持FTP操作 6.支持SQL解析 7.... 8.... 9....20.支持微信、支付宝接口 21.支持MD5,RSA,BASE64 22.其它扩展