注册中的同步和异步
会员注册流程.png
登陆
移动端登录接口.png
联合第三方登陆
第三方联合登录流程.png
混合开发技术
混合开发技术.png
加密
安全加密.png
支付架构流程
支付架构流程.png
同步回调
@Slf4j
@RestController
public class PayCallBackServiceImpl extends BaseApiService implements PayCallBackService {
@Autowired
private PaymentInfoDao paymentInfoDao;
// 同步回调
public ResponseBase synCallBack(@RequestParam Map<String, String> params) {
// 获取支付宝GET过来反馈信息
try {
log.info("####同步回调开始####params:",params);
boolean signVerified = AlipaySignature.rsaCheckV1(params, AlipayConfig.alipay_public_key,
AlipayConfig.charset, AlipayConfig.sign_type); // 调用SDK验证签名
// ——请在这里编写您的程序（以下代码仅作参考）——
if (!signVerified) {
return setResultError("验签失败!");
}
// 商户订单号
String out_trade_no = params.get("out_trade_no");
// 支付宝交易号
String trade_no = params.get("trade_no");
// 付款金额
String total_amount = params.get("total_amount");
JSONObject data = new JSONObject();
data.put("out_trade_no", out_trade_no);
data.put("trade_no", trade_no);
data.put("total_amount", total_amount);
return setResultSuccess(data);
} catch (Exception e) {
log.info("######PayCallBackServiceImpl##ERROR:#####", e);
return setResultError("系统错误!");
}finally{
log.info("####同步回调结束####params:",params);
}
}
PayController同步回调隐藏get参数，get传表单，表单里有post
// 同步回调
@RequestMapping("/callBack/synCallBack")
public void synCallBack(HttpServletRequest request, HttpServletResponse response) throws IOException {
response.setContentType("text/html;charset=utf-8");
Map<String, String[]> requestParams = request.getParameterMap();
Map<String, String> params = new HashMap<String, String>();
for (Iterator<String> iter = requestParams.keySet().iterator(); iter.hasNext();) {
String name = (String) iter.next();
String[] values = (String[]) requestParams.get(name);
String valueStr = "";
for (int i = 0; i < values.length; i++) {
valueStr = (i == values.length - 1) ? valueStr + values[i] : valueStr + values[i] + ",";
}
// 乱码解决，这段代码在出现乱码时使用
valueStr = new String(valueStr.getBytes("ISO-8859-1"), "utf-8");
params.put(name, valueStr);
}
PrintWriter writer = response.getWriter();
ResponseBase synCallBack = payCallBackFegin.synCallBack(params);
if (!synCallBack.getRtnCode().equals(Constants.HTTP_RES_CODE_200)) {
return;
}
LinkedHashMap data = (LinkedHashMap) synCallBack.getData();
String htmlFrom = "<form name='punchout_form'"
+ " method='post' action='http://127.0.0.1/callBack/synSuccessPage' >"
+ "<input type='hidden' name='outTradeNo' value='" + data.get("out_trade_no") + "'>"
+ "<input type='hidden' name='tradeNo' value='" + data.get("trade_no") + "'>"
+ "<input type='hidden' name='totalAmount' value='" + data.get("total_amount") + "'>"
+ "<input type='submit' value='立即支付' style='display:none'>"
+ "</form><script>document.forms[0].submit();" + "</script>";
writer.println(htmlFrom);
writer.close();
}
// 同步回调,解决隐藏参数
@RequestMapping(value = "/callBack/synSuccessPage", method = RequestMethod.POST)
public String synSuccessPage(HttpServletRequest request, String outTradeNo, String tradeNo, String totalAmount) {
request.setAttribute("outTradeNo", outTradeNo);
request.setAttribute("tradeNo", tradeNo);
request.setAttribute("totalAmount", totalAmount);
return PAY_SUCCESS;
}
支付异步通知(其实和同步很像，多了幂等性判断,和修改订单)
@Override
public String asynCallBack(@RequestParam Map<String, String> params) {
// 1.日志记录
log.info("#####支付宝异步通知synCallBack#####开始,params:{}", params);
// 2.验签操作
try {
boolean signVerified = AlipaySignature.rsaCheckV1(params, AlipayConfig.alipay_public_key,
AlipayConfig.charset, AlipayConfig.sign_type); // 调用SDK验证签名
log.info("#####支付宝异步通知signVerified:{}######", signVerified);
// ——请在这里编写您的程序（以下代码仅作参考）——
if (!signVerified) {
return Constants.PAY_FAIL;
}
// 商户订单号
String outTradeNo = params.get("out_trade_no");
// 调用订单数据库修改订单表数据库
// 3 处理幂等
PaymentInfo orderIdPayInfo = paymentInfoDao.getByOrderIdPayInfo(outTradeNo);
if (orderIdPayInfo == null) {
return Constants.PAY_FAIL;
}
// 判断是否已经支付过，如果已经支付过,返回success,防止重试产生重复
Integer state = orderIdPayInfo.getState();
if (state == 1) {
return Constants.PAY_SUCCESS;
}
// 支付宝交易号
String tradeNo = params.get("trade_no");
orderIdPayInfo.setState(1);
orderIdPayInfo.setPlatformorderId(tradeNo);
orderIdPayInfo.setPayMessage(params.toString());
Integer updatePayInfo = paymentInfoDao.updatePayInfo(orderIdPayInfo);
if (updatePayInfo <= 0) {
return Constants.PAY_FAIL;
}
// 调用订单接口通知修改订单状态
ResponseBase ordeResponseBase = orderFegin.updateOrderId(1l, tradeNo, outTradeNo);
if (!ordeResponseBase.getRtnCode().equals(Constants.HTTP_RES_CODE_200)) {
return Constants.PAY_FAIL;
}
return Constants.PAY_SUCCESS;
} catch (Exception e) {
log.error("####支付宝异步通知出现异常,ERROR:", e);
return Constants.PAY_FAIL;
} finally {
log.info("#####支付宝异步通知synCallBack#####结束,params:{}", params);
}
分布式事务
分布式产生原因
分布式事物产生原因.png
2PC
两段提交协议.png
图片1.png
消息中间解决
消息中间解决分布式事物.png
CAP
- 数据一致性(consistency)：如果系统对一个写操作返回成功，那么之后的读请求都必须读到这个新数据；如果返回失败，那么所有读操作都不能读到这个数据，对调用者而言数据具有强一致性(strong consistency) (又叫原子性 atomic、线性一致性 linearizable consistency)[5]
- 服务可用性(availability)：所有读写请求在一定时间内得到响应，可终止、不会一直等待
- 分区容错性(partition-tolerance)：在网络分区的情况下，被分隔的节点仍能正常对外服务
TCC
TCC（Try-Confirm-Cancel），则是将业务逻辑分成try、confirm/cancel两个阶段执行其事务处理方式为：
1、 在全局事务决定提交时，调用与try业务逻辑相对应的confirm业务逻辑；
2、 在全局事务决定回滚时，调用与try业务逻辑相对应的cancel业务逻辑。 可见，TCC在事务处理方式上，是很简单的：要么调用confirm业务逻辑，要么调用cancel逻辑
