⭐⭐⭐ Spring Boot 项目实战	⭐⭐⭐ Spring Cloud 项目实战
《Dubbo 实现原理与源码解析 —— 精品合集》	《Netty 实现原理与源码解析 —— 精品合集》
《Spring 实现原理与源码解析 —— 精品合集》	《MyBatis 实现原理与源码解析 —— 精品合集》
《Spring MVC 实现原理与源码解析 —— 精品合集》	《数据库实体设计合集》
《Spring Boot 实现原理与源码解析 —— 精品合集》	《Java 面试题 + Java 学习指南》

摘要: 原创出处 juejin.cn/post/7269357836026904633 「null」欢迎转载，保留摘要，谢谢！

🙂🙂🙂关注微信公众号：【芋道源码】有福利：

RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表

RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址

您对于源码的疑问每条留言都将得到认真回复。甚至不知道如何读源码也可以请教噢。

新的源码解析文章实时收到通知。每周更新一篇左右。

认真的源码交流微信群。

1 网页操作步骤

1.进入支付宝开发平台—沙箱环境

使用开发者账号登录开放平台控制平台

2.点击沙箱进入沙箱环境

说明：沙箱环境支持的产品，可以在沙箱控制台沙箱应用 > 产品列表中查看。

3.进入沙箱，配置接口加签方式

在沙箱进行调试前需要确保已经配置密钥/证书用于加签，支付宝提供了系统默认密钥及自定义密钥两种方式进行配置。这里我采取的是默认方式：

开发者如需使用系统默认密钥/证书，可在开发信息中选择系统默认密钥。注意:使用API在线调试工具调试OpenAPI必须使用系统默认密钥。

4.配置应用网关

应用网关用于接收支付宝沙箱环境的异步通知（对接 From 蚂蚁消息），如创建门店的被动通知。

注意：仅 HTTP 订阅模式的 From 蚂蚁消息才需要配置应用网关，WebSocket 订阅模式的 From 蚂蚁消息无需配置应用网关。

5.生成自己的密钥

至此，网页操作完成

2 idea操作步骤

1.导入依赖

<dependency>
   <groupId>com.alipay.sdk</groupId>
   <artifactId>alipay-sdk-java</artifactId>
   <version>4.22.110.ALL</version>
</dependency>

2.在 application.yml 里面进行配置

alipay:
  appId: 
  appPrivateKey: 
  alipayPublicKey: 
  notifyUrl: （回调接口）

3.alipay的JAVA配置：AlipayConfig.java

读取yml中的配置信息，自动填充到对应的属性

@Data
@Component
@ConfigurationProperties(prefix = "alipay")
public class AliPayConfig {
    private String appId;
    private String appPrivateKey;
    private String alipayPublicKey;
    private String notifyUrl;

}

4.支付接口新建一个 AliPayController.java

在Controller中配置gateway_url（调用支付宝url的一个网关地址）、format（JSON形式）、charset（UTF-8）、sign_type（签名方式-rsa2
编写一个Get请求，（方法参数是一个AliPay的配置类里面包括自己生成的订单号、总金额、支付的名称、支付宝交易凭证号和HttpServletResponse）
创建Client（他是由通用SDK提供的Client，负责调用支付宝的API，设置参数包含网关地址、appid、密钥、公钥、format、charset、签名方式）———————–>创建Client，他是由通用SDK提供的Client，负责调用支付宝的API
创建 AlipayTradePagePayRequest，配置notifyUrl并设置Request参数（参数包含订单号、总金额、支付的名称）（格式：JSON格式）————————->创建 Request并设置Request参数
通过AlipayClient执行request调用SDK生成表单，用HttpServletResponse（浏览器响应的一个流）写表单的内容，创建一个html的网页）—————————>执行请求，拿到响应的结果，返回给浏览器

@Data
public class AliPay {
    private String traceNo;
    private double totalAmount;
    private String subject;
    private String alipayTraceNo;
}
private static final String GATEWAY_URL = "https://openapi.alipaydev.com/gateway.do";
private static final String FORMAT = "JSON";
private static final String CHARSET = "UTF-8";
    //签名方式
    private static final String SIGN_TYPE = "RSA2";
@Resource
private AliPayConfig aliPayConfig;

@Resource
private OrdersMapper ordersMapper;

@GetMapping("/pay") // &subject=xxx&traceNo=xxx&totalAmount=xxx
public void pay(AliPay aliPay, HttpServletResponse httpResponse) throws Exception {
    // 1. 创建Client，通用SDK提供的Client，负责调用支付宝的API
    AlipayClient alipayClient = new DefaultAlipayClient(GATEWAY_URL, aliPayConfig.getAppId(),
            aliPayConfig.getAppPrivateKey(), FORMAT, CHARSET, aliPayConfig.getAlipayPublicKey(), SIGN_TYPE);

    // 2. 创建 Request并设置Request参数
    AlipayTradePagePayRequest request = new AlipayTradePagePayRequest();  // 发送请求的 Request类
    request.setNotifyUrl(aliPayConfig.getNotifyUrl());
    JSONObject bizContent = new JSONObject();
    bizContent.set("out_trade_no", aliPay.getTraceNo());  // 我们自己生成的订单编号
    bizContent.set("total_amount", aliPay.getTotalAmount()); // 订单的总金额
    bizContent.set("subject", aliPay.getSubject());   // 支付的名称
    bizContent.set("product_code", "FAST_INSTANT_TRADE_PAY");  // 固定配置
    request.setBizContent(bizContent.toString());

    // 执行请求，拿到响应的结果，返回给浏览器
    String form = "";
    try {
        form = alipayClient.pageExecute(request).getBody(); // 调用SDK生成表单
    } catch (AlipayApiException e) {
        e.printStackTrace();
    }
    httpResponse.setContentType("text/html;charset=" + CHARSET);
    httpResponse.getWriter().write(form);// 直接将完整的表单html输出到页面
    httpResponse.getWriter().flush();
    httpResponse.getWriter().close();
}

5.在拦截器里面加上忽略alipay接口的配置

遇到的坑：

url中有中文字符报错，更换依赖

官网提供有easy版和正式版

easy-sdk 好像不太支持中文的subject，否则 biz_content就会乱码，那我索性就用了 alipay-sdk 正式版的

6.回调接口

使用的Post接口，首先验证交易状态是否成功，获取request里面的信息
支付宝验签（使用的是AlipaySignature（通用SDK提供的类）获取一个String字符串将其与sign签名验证），通过后，使用OrderMapper更新到数据库）

使用的Post接口，因为官方建议处理付款成功后的操作在异步调用方法中，异步调用为post请求，异步回调方法必须为公网IP，因为支付宝是基于公网访问，访问不了localhost，需要代理，设置公网IP有两种方案，1、内网穿透，2、将项目部署到服务器，我们项目使用的是内网穿透，使用的是natapp，配置一条免费的隧道，在idea中配置notifyurl接口

@PostMapping("/notify")  // 注意这里必须是POST接口
public String payNotify(HttpServletRequest request) throws Exception {
    if (request.getParameter("trade_status").equals("TRADE_SUCCESS")) {
        System.out.println("=========支付宝异步回调========");        
  Map<String, String> params = new HashMap<>();
        Map<String, String[]> requestParams = request.getParameterMap();
        for (String name : requestParams.keySet()) {
            params.put(name, request.getParameter(name));
            // System.out.println(name + " = " + request.getParameter(name));
        }

        String tradeNo = params.get("out_trade_no");
        String gmtPayment = params.get("gmt_payment");
        String alipayTradeNo = params.get("trade_no");

        String sign = params.get("sign");
        String content = AlipaySignature.getSignCheckContentV1(params);
        boolean checkSignature = AlipaySignature.rsa256CheckContent(content, sign, aliPayConfig.getAlipayPublicKey(), "UTF-8"); // 验证签名
        // 支付宝验签
        if (checkSignature) {
            // 验签通过
            System.out.println("交易名称: " + params.get("subject"));
            System.out.println("交易状态: " + params.get("trade_status"));
            System.out.println("支付宝交易凭证号: " + params.get("trade_no"));
            System.out.println("商户订单号: " + params.get("out_trade_no"));
            System.out.println("交易金额: " + params.get("total_amount"));
            System.out.println("买家在支付宝唯一id: " + params.get("buyer_id"));
            System.out.println("买家付款时间: " + params.get("gmt_payment"));
            System.out.println("买家付款金额: " + params.get("buyer_pay_amount"));

            // 更新订单未已支付
            ordersMapper.updateState(tradeNo, "已支付", gmtPayment, alipayTradeNo);
        }
    }
    return "success";
}

3 退款流程

创建Client（他是由通用SDK提供的Client，负责调用支付宝的API）（参数包含网关地址、appid、密钥、公钥、format、charset、签名方式）———————->创建Client，通用SDK提供的Client，负责调用支付宝的API
创建 AlipayTradePagePayRequest，设置Request参数（参数包含支付宝回调的订单流水号、总金额、我的订单编号）（格式：JSON格式）—————————->创建 Request，设置参数
通过AlipayClient执行request获取response，通过isSuccess判断是否成功，成功后更新数据库状态————->执行请求，更新数据库

@GetMapping("/return")
public Result returnPay(AliPay aliPay) throws AlipayApiException {
        // 7天无理由退款
        String now = DateUtil.now();
        Orders orders = ordersMapper.getByNo(aliPay.getTraceNo());
        if (orders != null) {
            // hutool工具类，判断时间间隔
            long between = DateUtil.between(DateUtil.parseDateTime(orders.getPaymentTime()), DateUtil.parseDateTime(now), DateUnit.DAY);
            if (between > 7) {
                return Result.error("-1", "该订单已超过7天，不支持退款");
            }
        }
    // 1. 创建Client，通用SDK提供的Client，负责调用支付宝的API
    AlipayClient alipayClient = new DefaultAlipayClient(GATEWAY_URL,
            aliPayConfig.getAppId(), aliPayConfig.getAppPrivateKey(), FORMAT, CHARSET,
            aliPayConfig.getAlipayPublicKey(), SIGN_TYPE);
    // 2. 创建 Request，设置参数
    AlipayTradeRefundRequest request = new AlipayTradeRefundRequest();
    JSONObject bizContent = new JSONObject();
    bizContent.set("trade_no", aliPay.getAlipayTraceNo());  // 支付宝回调的订单流水号
    bizContent.set("refund_amount", aliPay.getTotalAmount());  // 订单的总金额
    bizContent.set("out_request_no", aliPay.getTraceNo());   //  我的订单编号

    // 返回参数选项，按需传入
    //JSONArray queryOptions = new JSONArray();
    //queryOptions.add("refund_detail_item_list");
    //bizContent.put("query_options", queryOptions);

    request.setBizContent(bizContent.toString());

    // 3. 执行请求
    AlipayTradeRefundResponse response = alipayClient.execute(request);
    if (response.isSuccess()) {  // 退款成功，isSuccess 为true
        System.out.println("调用成功");

        // 4. 更新数据库状态
        ordersMapper.updatePayState(aliPay.getTraceNo(), "已退款", now);
        return Result.success();
    } else {   // 退款失败，isSuccess 为false
        System.out.println(response.getBody());
        return Result.error(response.getCode(), response.getBody());
    }

}

订单三十分钟未支付自动取消

使用消息队列

我们可以采用rabbitMQ的延时队列。RabbitMQ具有以下两个特性，可以实现延迟队列

RabbitMQ可以针对Queue和Message设置 x-message-tt，来控制消息的生存时间，如果超时，则消息变为dead letter

RabbitMQ的Queue可以配置x-dead-letter-exchange 和x-dead-letter-routing-key（可选）两个参数，用来控制队列内出现了deadletter，则按照这两个参数重新路由。结合以上两个特性，就可以模拟出延迟消息的功能

优缺点

优点： 高效,可以利用rabbitmq的分布式特性轻易的进行横向扩展,消息支持持久化增加了可靠性。
缺点： 本身的易用度要依赖于rabbitMq的运维.因为要引用rabbitMq,所以复杂度和成本变高。

用户下单之后，投递一个msg消息存放在msg服务器daunt，该消息msg消息过期时间为30分钟，一直未被订单消费者消费，消息会转移到死信交换机路由到死信队列中，被我们的死信消费者30分钟后消息。

死信消费者在根据订单号码查询支付订单状态，如果是未支付情况下，则将该订单设置未超时。

对筛选出来的订单号码进行核对校验:

订单中是否存在
携带订单号码调用支付宝查询订单支付状态是否为待支付
更新该订单号码状态

芋道源码 —— 纯源码解析博客

SpringBoot 集成支付宝支付，看这篇就够了

1 网页操作步骤

1.进入支付宝开发平台—沙箱环境

2.点击沙箱进入沙箱环境

3.进入沙箱，配置接口加签方式

4.配置应用网关

5.生成自己的密钥

2 idea操作步骤

1.导入依赖

2.在 application.yml 里面进行配置

3.alipay的JAVA配置：AlipayConfig.java

4.支付接口新建一个 AliPayController.java

5.在拦截器里面加上忽略alipay接口的配置

6.回调接口

3 退款流程

订单三十分钟未支付自动取消

1 网页操作步骤

1.进入支付宝开发平台—沙箱环境

2.点击沙箱进入沙箱环境

3.进入沙箱，配置接口加签方式

4.配置应用网关

5.生成自己的密钥

2 idea操作步骤

1.导入依赖

2.在 application.yml 里面进行配置

3.alipay的JAVA配置：AlipayConfig.java

4.支付接口 新建一个 AliPayController.java

5.在拦截器里面加上 忽略alipay接口的配置

6.回调接口

3 退款流程

订单三十分钟未支付自动取消

4.支付接口新建一个 AliPayController.java

5.在拦截器里面加上忽略alipay接口的配置