JAVA微信扫码支付模式二功能实现以及回调
一、准备工作
首先吐槽一下微信关于支付这块，本身支持的支付模式就好几种，但是官方文档特别零散，连像样的Java相关的demo也没几个。本人之前没有搞过微信支付，一开始真是被它搞晕，折腾两天终于调通了，特此写下来，以享后人吧！
关于准备工作，就“微信扫码支付模式二”官方文档地址在这https://pay.weixin.qq.com/wiki/doc/api/native.php?chapter=6_1可以先看看，实际上需要准备的东西有以下几个：
其中APP_ID和APP_SECRET可以在公众平台找着，MCH_ID和API_KEY则在商户平台找到，特别是API_KEY要在商户平台设置好，对于“微信扫码支付模式二”（支付与回调）实际只会用到APP_ID、MCH_ID和API_KEY，其他的都不用。
关于开发环境，我就不罗嗦了，不管你是springMVC、struts2又或者直接serverlet，都差不多，只要你能保证对应的方法能调用起来就行。关于引用第三方的jar包，我这里只用到了一个xml操作的jdom，记住是1.*的版本，不是官网上最新的2.*，两者不兼容。具体是jdom-1.1.3.jar，依赖包jaxen-1.1.6.jar，就这两个包，我没用到有些例子中使用的httpclient，感觉没必要，而且依赖包特别繁杂，当然你是maven当我没说。
二、开发实战
1、首先是接入微信接口，获取微信支付二维码。
publicStringweixin_pay()throwsException{
//账号信息
Stringappid=PayConfigUtil.APP_ID;//appid
//Stringappsecret=PayConfigUtil.APP_SECRET;//appsecret
Stringmch_id=PayConfigUtil.MCH_ID;//商业号
Stringkey=PayConfigUtil.API_KEY;//key
StringcurrTime=PayCommonUtil.getCurrTime();
StringstrTime=currTime.substring(8,currTime.length());
StringstrRandom=PayCommonUtil.buildRandom(4)+"";
Stringnonce_str=strTime+strRandom;
Stringorder_price=1;//价格注意：价格的单位是分
Stringbody="goodssssss";//商品名称
Stringout_trade_no="11338";//订单号
//获取发起电脑ip
Stringspbill_create_ip=PayConfigUtil.CREATE_IP;
//回调接口
Stringnotify_url=PayConfigUtil.NOTIFY_URL;
Stringtrade_type="NATIVE";
SortedMappackageParams=newTreeMap();
packageParams.put("appid",appid);
packageParams.put("mch_id",mch_id);
packageParams.put("nonce_str",nonce_str);
packageParams.put("body",body);
packageParams.put("out_trade_no",out_trade_no);
packageParams.put("total_fee",order_price);
packageParams.put("spbill_create_ip",spbill_create_ip);
packageParams.put("notify_url",notify_url);
packageParams.put("trade_type",trade_type);
Stringsign=PayCommonUtil.createSign("UTF-8",packageParams,key);
packageParams.put("sign",sign);
StringrequestXML=PayCommonUtil.getRequestXml(packageParams);
System.out.println(requestXML);
StringresXml=HttpUtil.postData(PayConfigUtil.UFDODER_URL,requestXML);
Mapmap=XMLUtil.doXMLParse(resXml);
//Stringreturn_code=(String)map.get("return_code");
//Stringprepay_id=(String)map.get("prepay_id");
StringurlCode=(String)map.get("code_url");
returnurlCode;
}
如果不出意外的话，这里就从微信服务器获取了一个支付url，形如weixin://wxpay/bizpayurl?pr=pIxXXXX，之后我们就需要把这个url生成一个二维码，然后就可以使用自己手机微信端扫码支付了。关于二维码生成有很多种方法，各位各取所需吧，我这里提供一个google的二维码生成接口：
publicstaticStringQRfromGoogle(Stringchl)throwsException{
intwidhtHeight=300;
StringEC_level="L";
intmargin=0;
chl=UrlEncode(chl);
StringQRfromGoogle="http://chart.apis.google.com/chart?chs="+widhtHeight+"x"+widhtHeight
+"&cht=qr&chld="+EC_level+"|"+margin+"&chl="+chl;
returnQRfromGoogle;
}
//特殊字符处理
publicstaticStringUrlEncode(Stringsrc)throwsUnsupportedEncodingException{
returnURLEncoder.encode(src,"UTF-8").replace("+","%20");
}
上面代码中涉及到几个工具类：PayConfigUtil、PayCommonUtil、HttpUtil和XMLUtil，其中PayConfigUtil放的就是上面提到一些配置及路径，PayCommonUtil涉及到了获取当前事件、产生随机字符串、获取参数签名和拼接xml几个方法，代码如下：
publicclassPayCommonUtil{
/**
*是否签名正确,规则是:按参数名称a-z排序,遇到空值的参数不参加签名。
*@returnboolean
*/
publicstaticbooleanisTenpaySign(StringcharacterEncoding,SortedMappackageParams,StringAPI_KEY){
StringBuffersb=newStringBuffer();
Setes=packageParams.entrySet();
Iteratorit=es.iterator();
while(it.hasNext()){
Map.Entryentry=(Map.Entry)it.next();
Stringk=(String)entry.getKey();
Stringv=(String)entry.getValue();
if(!"sign".equals(k)&&null!=v&&!"".equals(v)){
sb.append(k+"="+v+"&");
}
}
sb.append("key="+API_KEY);
//算出摘要
Stringmysign=MD5Util.MD5Encode(sb.toString(),characterEncoding).toLowerCase();
StringtenpaySign=((String)packageParams.get("sign")).toLowerCase();
//System.out.println(tenpaySign+""+mysign);
returntenpaySign.equals(mysign);
}
/**
*@author
*@date2016-4-22
*@Description：sign签名
*@paramcharacterEncoding
*编码格式
*@paramparameters
*请求参数
*@return
*/
publicstaticStringcreateSign(StringcharacterEncoding,SortedMappackageParams,StringAPI_KEY){
StringBuffersb=newStringBuffer();
Setes=packageParams.entrySet();
Iteratorit=es.iterator();
while(it.hasNext()){
Map.Entryentry=(Map.Entry)it.next();
Stringk=(String)entry.getKey();
Stringv=(String)entry.getValue();
if(null!=v&&!"".equals(v)&&!"sign".equals(k)&&!"key".equals(k)){
sb.append(k+"="+v+"&");
}
}
sb.append("key="+API_KEY);
Stringsign=MD5Util.MD5Encode(sb.toString(),characterEncoding).toUpperCase();
returnsign;
}
/**
*@author
*@date2016-4-22
*@Description：将请求参数转换为xml格式的string
*@paramparameters
*请求参数
*@return
*/
publicstaticStringgetRequestXml(SortedMapparameters){
StringBuffersb=newStringBuffer();
sb.append("");
Setes=parameters.entrySet();
Iteratorit=es.iterator();
while(it.hasNext()){
Map.Entryentry=(Map.Entry)it.next();
Stringk=(String)entry.getKey();
Stringv=(String)entry.getValue();
if("attach".equalsIgnoreCase(k)||"body".equalsIgnoreCase(k)||"sign".equalsIgnoreCase(k)){
sb.append("<"+k+">"+"");
}else{
sb.append("<"+k+">"+v+"");
}
}
sb.append("");
returnsb.toString();
}
/**
*取出一个指定长度大小的随机正整数.
*
*@paramlength
*int设定所取出随机数的长度。length小于11
*@returnint返回生成的随机数。
*/
publicstaticintbuildRandom(intlength){
intnum=1;
doublerandom=Math.random();
if(random<0.1){
random=random+0.1;
}
for(inti=0;i num=num*10;
}
return(int)((random*num));
}
/**
*获取当前时间yyyyMMddHHmmss
*
*@returnString
*/
publicstaticStringgetCurrTime(){
Datenow=newDate();
SimpleDateFormatoutFormat=newSimpleDateFormat("yyyyMMddHHmmss");
Strings=outFormat.format(now);
returns;
}
}
HttpUtil和XMLUtil如下：
publicclassHttpUtil{
privatestaticfinalLoglogger=Logs.get();
privatefinalstaticintCONNECT_TIMEOUT=5000;//inmilliseconds
privatefinalstaticStringDEFAULT_ENCODING="UTF-8";
publicstaticStringpostData(StringurlStr,Stringdata){
returnpostData(urlStr,data,null);
}
publicstaticStringpostData(StringurlStr,Stringdata,StringcontentType){
BufferedReaderreader=null;
try{
URLurl=newURL(urlStr);
URLConnectionconn=url.openConnection();
conn.setDoOutput(true);
conn.setConnectTimeout(CONNECT_TIMEOUT);
conn.setReadTimeout(CONNECT_TIMEOUT);
if(contentType!=null)
conn.setRequestProperty("content-type",contentType);
OutputStreamWriterwriter=newOutputStreamWriter(conn.getOutputStream(),DEFAULT_ENCODING);
if(data==null)
data="";
writer.write(data);
writer.flush();
writer.close();
reader=newBufferedReader(newInputStreamReader(conn.getInputStream(),DEFAULT_ENCODING));
StringBuildersb=newStringBuilder();
Stringline=null;
while((line=reader.readLine())!=null){
sb.append(line);
sb.append("\r\n");
}
returnsb.toString();
}catch(IOExceptione){
logger.error("Errorconnectingto"+urlStr+":"+e.getMessage());
}finally{
try{
if(reader!=null)
reader.close();
}catch(IOExceptione){
}
}
returnnull;
}
}
publicclassXMLUtil{
/**
*解析xml,返回第一级元素键值对。如果第一级元素有子节点，则此节点的值是子节点的xml数据。
*@paramstrxml
*@return
*@throwsJDOMException
*@throwsIOException
*/
publicstaticMapdoXMLParse(Stringstrxml)throwsJDOMException,IOException{
strxml=strxml.replaceFirst("encoding=\".*\"","encoding=\"UTF-8\"");
if(null==strxml||"".equals(strxml)){
returnnull;
}
Mapm=newHashMap();
InputStreamin=newByteArrayInputStream(strxml.getBytes("UTF-8"));
SAXBuilderbuilder=newSAXBuilder();
Documentdoc=builder.build(in);
Elementroot=doc.getRootElement();
Listlist=root.getChildren();
Iteratorit=list.iterator();
while(it.hasNext()){
Elemente=(Element)it.next();
Stringk=e.getName();
Stringv="";
Listchildren=e.getChildren();
if(children.isEmpty()){
v=e.getTextNormalize();
}else{
v=XMLUtil.getChildrenText(children);
}
m.put(k,v);
}
//关闭流
in.close();
returnm;
}
/**
*获取子结点的xml
*@paramchildren
*@returnString
*/
publicstaticStringgetChildrenText(Listchildren){
StringBuffersb=newStringBuffer();
if(!children.isEmpty()){
Iteratorit=children.iterator();
while(it.hasNext()){
Elemente=(Element)it.next();
Stringname=e.getName();
Stringvalue=e.getTextNormalize();
Listlist=e.getChildren();
sb.append("<"+name+">");
if(!list.isEmpty()){
sb.append(XMLUtil.getChildrenText(list));
}
sb.append(value);
sb.append("");
}
}
returnsb.toString();
}
}
当然还有一个MD5计算工具类
publicclassMD5Util{
privatestaticStringbyteArrayToHexString(byteb[]){
StringBufferresultSb=newStringBuffer();
for(inti=0;i resultSb.append(byteToHexString(b[i]));
returnresultSb.toString();
}
privatestaticStringbyteToHexString(byteb){
intn=b;
if(n<0)
n+=256;
intd1=n/16;
intd2=n%16;
returnhexDigits[d1]+hexDigits[d2];
}
publicstaticStringMD5Encode(Stringorigin,Stringcharsetname){
StringresultString=null;
try{
resultString=newString(origin);
MessageDigestmd=MessageDigest.getInstance("MD5");
if(charsetname==null||"".equals(charsetname))
resultString=byteArrayToHexString(md.digest(resultString
.getBytes()));
else
resultString=byteArrayToHexString(md.digest(resultString
.getBytes(charsetname)));
}catch(Exceptionexception){
}
returnresultString;
}
privatestaticfinalStringhexDigits[]={"0","1","2","3","4","5",
"6","7","8","9","a","b","c","d","e","f"};
}
2、支付回调
支付完成后，微信会把相关支付结果和用户信息发送到我们上面指定的那个回调地址，我们需要接收处理，并返回应答。对后台通知交互时，如果微信收到商户的应答不是成功或超时，微信认为通知失败，微信会通过一定的策略定期重新发起通知，尽可能提高通知的成功率，但微信不保证通知最终能成功。 （通知频率为15/15/30/180/1800/1800/1800/1800/3600，单位：秒）
关于支付回调接口，我们首先要对于支付结果通知的内容进行签名验证，然后根据支付结果进行相应的处理流程即可。
publicvoidweixin_notify(HttpServletRequestrequest,HttpServletResponseresponse)throwsException{
//读取参数
InputStreaminputStream;
StringBuffersb=newStringBuffer();
inputStream=request.getInputStream();
Strings;
BufferedReaderin=newBufferedReader(newInputStreamReader(inputStream,"UTF-8"));
while((s=in.readLine())!=null){
sb.append(s);
}
in.close();
inputStream.close();
//解析xml成map
Mapm=newHashMap();
m=XMLUtil.doXMLParse(sb.toString());
//过滤空设置TreeMap
SortedMappackageParams=newTreeMap();
Iteratorit=m.keySet().iterator();
while(it.hasNext()){
Stringparameter=(String)it.next();
StringparameterValue=m.get(parameter);
Stringv="";
if(null!=parameterValue){
v=parameterValue.trim();
}
packageParams.put(parameter,v);
}
//账号信息
Stringkey=PayConfigUtil.API_KEY;//key
logger.info(packageParams);
//判断签名是否正确
if(PayCommonUtil.isTenpaySign("UTF-8",packageParams,key)){
//------------------------------
//处理业务开始
//------------------------------
StringresXml="";
if("SUCCESS".equals((String)packageParams.get("result_code"))){
//这里是支付成功
//////////执行自己的业务逻辑////////////////
Stringmch_id=(String)packageParams.get("mch_id");
Stringopenid=(String)packageParams.get("openid");
Stringis_subscribe=(String)packageParams.get("is_subscribe");
Stringout_trade_no=(String)packageParams.get("out_trade_no");
Stringtotal_fee=(String)packageParams.get("total_fee");
logger.info("mch_id:"+mch_id);
logger.info("openid:"+openid);
logger.info("is_subscribe:"+is_subscribe);
logger.info("out_trade_no:"+out_trade_no);
logger.info("total_fee:"+total_fee);
//////////执行自己的业务逻辑////////////////
logger.info("支付成功");
//通知微信.异步确认成功.必写.不然会一直通知后台.八次之后就认为交易失败了.
resXml=""+""
+""+"";
}else{
logger.info("支付失败,错误信息："+packageParams.get("err_code"));
resXml=""+""
+""+"";
}
//------------------------------
//处理业务完毕
//------------------------------
BufferedOutputStreamout=newBufferedOutputStream(
response.getOutputStream());
out.write(resXml.getBytes());
out.flush();
out.close();
}else{
logger.info("通知签名验证失败");
}
}
签名验证算法和签名生成的算法类似，在上面PayCommonUtil工具类中提供。
相关文章
图文推荐
- 文章
- 推荐
- 热门新闻