支付系统核心逻辑 — — 状态机（JavaGolang版本）

支付系统核心逻辑 — — 状态机

代码地址：https://github.com/ziyifast/ziyifast-code_instruction/tree/main/state_machine_demo

1 概念：FSM（有限状态机），模式之间转换

状态机，也叫有限状态机（FSM，Finite State Machine），是一种行为模式，是由一组定义良好的状态、状态之间的转换规则和一个初始状态组成。

  • 根据当前的状态和输入的事件，从一个状态转移到另一个状态。

2 实战：支付核心逻辑

2.1 支付交易三重奏：收单、结算、拒付款

下图中我们可以看到，一共4种状态，每个状态之间的转换都通过指定事件触发。
在这里插入图片描述

2.2 状态机设计原则

无论是设计支付类的系统，还是电商类的系统，在设计状态机时，都建议遵循以下原则

  1. 明确性：状态和转换必须清晰定义，避免含糊不清的状态。
  2. 完备性：为所有可能的事件-状态组合定义转换逻辑。
  3. 可预测性：系统应根据当前状态和给定事件可预测地响应。
  4. 最小化：状态数应保持最小，避免不必要的复杂性。
①明确性：状态与转换必须定义清晰
②完备性：需要考虑所有事件-状态的转换组合
③可预测性：需根据当前状态+给定事件可预测响应
④最小化：状态数要少，避免过于复杂
常见误区
  1. 过度设计：引入不必要的状态
  2. 不完备的处理：没有考虑到状态与事件所有可能的转换关系，导致系统行为不确定
  3. 硬编码逻辑：过多硬编码转换逻辑，导致系统不具备可扩展性和灵活性

比如下面的设计：

一眼看过去，好像除了复杂一点，整体还是合理的，比如初始化，受理成功就到ACCEPT，然后到PAYING，如果直接成功就到PAIED，退款成功就到REFUND。

在这里插入图片描述

不合理的地方：

  1. 流程复杂。第一眼看过去会发现不那么清晰，流程比较繁琐，比较复杂，有很多状态都可以简化或者舍去。比如ACCEPT没有存在的必要。
  2. 职责不明确。支付单只管支付，到PAIED就算支付成功，最终状态不再改变。不应该后面还有REFUND状态。REFUND应该由退款单来负责处理，否则如果客户部分退款，我们就不好处理了。

改进方案：

  • 删除不必要的状态。如：ACCEPT
  • 将一个大型状态机抽取为多份小的状态机。比如把一些退款REFUND、请款等单据单独抽取出来。这个样子，虽然状态机数量多了，但是每个状态机都更加清晰明了。
  1. 主单：
    在这里插入图片描述
  1. 普通支付单
    在这里插入图片描述
  1. 预授权单
    在这里插入图片描述
  1. 请款单
    在这里插入图片描述
  1. 退款单
    在这里插入图片描述
最佳实践及代码规范

代码层面：

  1. 分离状态和处理逻辑：使用状态模式，将每个状态的行为都封装在各自的类中
  2. 使用事件驱动模型：通过事件来触发状态转换，而不是直接调用状态方法
  3. 确保可追踪性：状态转换应被记录和追踪，以便故障排查和审计

上面几点也就要求我们不应该使用if else或者switch case来写，会让代码看起来复杂。我们应该将每个状态封装为单独的类。

2.3 Java版本实现

  1. 定义状态基类
/*** 状态基类*/
public interface BaseStatus {
}
  1. 定义事件基类
/*** 事件基类*/
public interface BaseEvent {
}
  1. 定义状态-事件对，指定的状态只能接受指定的事件
/*** 状态事件对，指定的状态只能接受指定的事件*/
public class StatusEventPair<S extends BaseStatus, E extends BaseEvent> {/*** 指定的状态*/private final S status;/*** 可接受的事件*/private final E event;public StatusEventPair(S status, E event) {this.status = status;this.event = event;}@Overridepublic boolean equals(Object obj) {if (obj instanceof StatusEventPair) {StatusEventPair<S, E> other = (StatusEventPair<S, E>)obj;return this.status.equals(other.status) && this.event.equals(other.event);}return false;}@Overridepublic int hashCode() {// 这里使用的是google的guava包。com.google.common.base.Objectsreturn Objects.hashCode(status, event);}
}
  1. 定义状态机
/*** 状态机*/
public class StateMachine<S extends BaseStatus, E extends BaseEvent> {private final Map<StatusEventPair<S, E>, S> statusEventMap = new HashMap<>();/*** 只接受指定的当前状态下，指定的事件触发，可以到达的指定目标状态*/public void accept(S sourceStatus, E event, S targetStatus) {statusEventMap.put(new StatusEventPair<>(sourceStatus, event), targetStatus);}/*** 通过源状态和事件，获取目标状态*/public S getTargetStatus(S sourceStatus, E event) {return statusEventMap.get(new StatusEventPair<>(sourceStatus, event));}
}
  1. 定义支付状态机。注：支付、退款等不同的业务状态机是独立的。
/*** 支付状态机*/
public enum PaymentStatus implements BaseStatus {INIT("INIT", "初始化"),PAYING("PAYING", "支付中"),PAID("PAID", "支付成功"),FAILED("FAILED", "支付失败"),;// 支付状态机内容private static final StateMachine<PaymentStatus, PaymentEvent> STATE_MACHINE = new StateMachine<>();static {// 初始状态STATE_MACHINE.accept(null, PaymentEvent.PAY_CREATE, INIT);// 支付中STATE_MACHINE.accept(INIT, PaymentEvent.PAY_PROCESS, PAYING);// 支付成功STATE_MACHINE.accept(PAYING, PaymentEvent.PAY_SUCCESS, PAID);// 支付失败STATE_MACHINE.accept(PAYING, PaymentEvent.PAY_FAIL, FAILED);}// 状态private final String status;// 描述private final String description;PaymentStatus(String status, String description) {this.status = status;this.description = description;}/*** 通过源状态和事件类型获取目标状态*/public static PaymentStatus getTargetStatus(PaymentStatus sourceStatus, PaymentEvent event) {return STATE_MACHINE.getTargetStatus(sourceStatus, event);}
}
  1. 定义支付事件。注：支付、退款等不同业务的事件是不一样的。
/*** 支付事件*/
public enum PaymentEvent implements BaseEvent {// 支付创建PAY_CREATE("PAY_CREATE", "支付创建"),// 支付中PAY_PROCESS("PAY_PROCESS", "支付中"),// 支付成功PAY_SUCCESS("PAY_SUCCESS", "支付成功"),// 支付失败PAY_FAIL("PAY_FAIL", "支付失败");/*** 事件*/private String event;/*** 事件描述*/private String description;PaymentEvent(String event, String description) {this.event = event;this.description = description;}
}
  1. 在支付单模型中声明状态和根据事件推进状态的方法：
/*** 支付单模型*/
public class PaymentModel {/*** 其它所有字段省略*/// 上次状态private PaymentStatus lastStatus;// 当前状态private PaymentStatus currentStatus;/*** 根据事件推进状态*/public void transferStatusByEvent(PaymentEvent event) {// 根据当前状态和事件，去获取目标状态PaymentStatus targetStatus = PaymentStatus.getTargetStatus(currentStatus, event);// 如果目标状态不为空，说明是可以推进的if (targetStatus != null) {lastStatus = currentStatus;currentStatus = targetStatus;} else {// 目标状态为空，说明是非法推进，进入异常处理，这里只是抛出去，由调用者去具体处理throw new StateMachineException(currentStatus, event, "状态转换失败");}}
}

代码注释已经写得很清楚，其中StateMachineException是自定义，不想定义的话，直接使用RuntimeException也是可以的。

在支付业务代码中的使用：只需要paymentModel.transferStatusByEvent(PaymentEvent.valueOf(message.getEvent()))

/*** 支付领域域服务*/
public class PaymentDomainServiceImpl implements PaymentDomainService {/*** 支付结果通知*/public void notify(PaymentNotifyMessage message) {PaymentModel paymentModel = loadPaymentModel(message.getPaymentId());try {// 状态推进paymentModel.transferStatusByEvent(PaymentEvent.valueOf(message.getEvent()));savePaymentModel(paymentModel);// 其它业务处理... ...} catch (StateMachineException e) {// 异常处理... ...} catch (Exception e) {// 异常处理... ...}}
}

上面的代码只需要加完善异常处理，优化一下注释，就可以直接用起来。

上面写法的好处：

  1. 定义了明确的状态、事件。
  2. 状态机的推进，只能通过“当前状态、事件、目标状态”来推进，不能通过if else 或case switch来直接写。比如：STATE_MACHINE.accept(INIT, PaymentEvent.PAY_PROCESS, PAYING);
  3. 避免终态变更。比如线上碰到if else写状态机，渠道异步通知比同步返回还快，异步通知回来把订单更新为“PAIED”，然后同步返回的代码把单据重新推进到PAYING。

2.4 Golang版本实现

项目结构：
在这里插入图片描述

①定义基础状态机：base_state_machine.go
package modeltype BaseStatus interface {
}type BaseEvent interface {
}type StatusEventPair struct {status BaseStatusevent  BaseEvent
}func (pair StatusEventPair) equals(other StatusEventPair) bool {return pair.status == other.status && pair.event == other.event
}type StateMachine struct {statusEventMap map[StatusEventPair]BaseStatus
}func (sm *StateMachine) accept(sourceStatus BaseStatus, event BaseEvent, targetStatus BaseStatus) {pair := StatusEventPair{status: sourceStatus, event: event}sm.statusEventMap[pair] = targetStatus
}func (sm *StateMachine) getTargetStatus(sourceStatus BaseStatus, event BaseEvent) BaseStatus {pair := StatusEventPair{status: sourceStatus, event: event}baseStatus := sm.statusEventMap[pair]return baseStatus
}
②定义支付状态机：payment_state_machine.go
package modeltype PaymentStatus stringconst (INIT   PaymentStatus = "INIT"PAYING PaymentStatus = "PAYING"PAID   PaymentStatus = "PAID"FAILED PaymentStatus = "FAILED"
)type PaymentEvent stringconst (PAY_CREATE  PaymentEvent = "PAY_CREATE"PAY_PROCESS PaymentEvent = "PAY_PROCESS"PAY_SUCCESS PaymentEvent = "PAY_SUCCESS"PAY_FAIL    PaymentEvent = "PAY_FAIL"
)var PaymentStateMachine = StateMachine{statusEventMap: map[StatusEventPair]BaseStatus{}}func init() {//支付状态机初始化，包含所有可能的情况PaymentStateMachine.accept(nil, PAY_CREATE, INIT)PaymentStateMachine.accept(INIT, PAY_PROCESS, PAYING)PaymentStateMachine.accept(PAYING, PAY_SUCCESS, PAID)PaymentStateMachine.accept(PAYING, PAY_FAIL, FAILED)
}func GetTargetStatus(sourceStatus PaymentStatus, event PaymentEvent) PaymentStatus {status := PaymentStateMachine.getTargetStatus(sourceStatus, event)if status != nil {return status.(PaymentStatus)}panic("获取目标状态失败")
}type PaymentModel struct {lastStatus    PaymentStatusCurrentStatus PaymentStatus
}func (pm *PaymentModel) TransferStatusByEvent(event PaymentEvent) {targetStatus := GetTargetStatus(pm.CurrentStatus, event)if targetStatus != "" {pm.lastStatus = pm.CurrentStatuspm.CurrentStatus = targetStatus} else {// 处理异常panic("状态转换失败")}
}
③使用及测试

main.go：

package mainimport ("github.com/kataras/iris/v12""github.com/kataras/iris/v12/context""github.com/ziyifast/log""myTest/demo_home/state_machine_demo/model""time"
)var (testOrder = new(model.PaymentModel)
)func main() {application := iris.New()application.Get("/order/create", createOrder)application.Get("/order/pay", payOrder)application.Get("/order/status", getOrderStatus)application.Listen(":8899", nil)
}func createOrder(context *context.Context) {testOrder.CurrentStatus = model.INITcontext.WriteString("create order succ...")
}func payOrder(context *context.Context) {testOrder.TransferStatusByEvent(model.PAY_PROCESS)log.Infof("call third api....")//调用第三方支付接口和其他业务处理逻辑time.Sleep(time.Second * 15)log.Infof("done...")testOrder.TransferStatusByEvent(model.PAY_SUCCESS)
}func getOrderStatus(context *context.Context) {context.WriteString(string(testOrder.CurrentStatus))
}

声明：为了快速验证以及让代码更加简洁，没有按照标准的规范来编写controller、service、dao等。

测试：

  1. 启动程序，调用create接口，创建订单
http://localhost:8899/order/create

在这里插入图片描述

  1. 调用支付接口支付订单
http://localhost:8899/order/pay

我们手动模拟调用第三方支付接口，sleep了几十秒（实际调用肯定比这个快多了），所以不会立即返回结果，我们需要新开一个窗口，直接查询订单状态

在这里插入图片描述

  1. 立即调用查询接口获取订单状态，查看是否为支付中
http://localhost:8899/order/status

在这里插入图片描述

  1. 等待支付成功后，调用接口查看订单状态，是否为已支付

等待后台日志打印done之后重新调用查询接口：

在这里插入图片描述

http://localhost:8899/order/status

在这里插入图片描述

3 并发更新问题：多线程修改同一状态机（db版本号）

“状态机领域模型同时被两个线程操作怎么避免状态幂等问题？”
这是一个好问题。在分布式场景下，这种情况太过于常见。同一机器有可能多个线程处理同一笔业务，不同机器也可能处理同一笔业务。

业内通常的做法是设计良好的状态机 + 数据库锁 + 数据版本号解决。

在这里插入图片描述
简要说明：

  1. 状态机一定要设计好，只有特定的原始状态 + 特定的事件才可以推进到指定的状态。比如 INIT + 支付成功才能推进到sucess。
  2. 更新数据库之前，先使用select for update进行锁行记录，同时在更新时判断版本号是否是之前取出来的版本号，更新成功就结束，更新失败就组成消息发到消息队列，后面再消费。
  3. 通过补偿机制兜底，比如查询补单。

通过上述三个步骤，正常情况下，最终的数据状态一定是正确的。除非是某个系统有异常，比如外部渠道开始返回支付成功，然后又返回支付失败，说明依赖的外部系统已经异常，这样只能进人工差错处理流程。

参考文章：https://juejin.cn/post/7321569896453521419

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/814191.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

基于OptiTrack跟踪系统和Turtlebot机器人的视觉SLAM定位评估

基于OptiTrack跟踪系统和Turtlebot机器人的视觉SLAM定位评估

本文旨在介绍使用OptiTrack光学跟踪系统和Turtlebot机器人进行视觉SLAM定位实验的详细流程&#xff0c;包括实验平台搭建过程、数据处理过程以及SLAM估计评估方法。由于涉及知识较多&#xff0c;部分内容只给出了相关参考博文链接。 1 实验平台搭建 实验平台包括OptiTrack光学…
阅读更多...
Golang | Leetcode Golang题解之第26题删除有序数组中的重复项

Golang | Leetcode Golang题解之第26题删除有序数组中的重复项

题目&#xff1a; 题解&#xff1a; func removeDuplicates(nums []int) int {n : len(nums)if n 0 {return 0}slow : 1for fast : 1; fast < n; fast {if nums[fast] ! nums[fast-1] {nums[slow] nums[fast]slow}}return slow }
阅读更多...
window10轻松使用k8s

window10轻松使用k8s

Docker Desktop安装篇 1、win10安装 1、下载安装包 https://www.docker.com/products/docker-desktop/ 官网下载安装包 2、配置win10支持虚拟化 不勾选Hyper-V&#xff0c;容易出错 3、安装WSL配置window支持linux Windows Subsystem for Linux (WSL) 安装 Linux 子系统&am…
阅读更多...
嵌入式sqlite3交叉编译移植

嵌入式sqlite3交叉编译移植

操作系统：Ubuntu20.04 下载sqlite3代码，下载版本3.30.00 wget https://www.sqlite.org/2019/sqlite-amalgamation-3300000.zip 或者https://download.csdn.net/download/benico/89127678 为什么下载amalgamation版本，不下载autoconf版本？ 根据我的编译实验，同版本sql…
阅读更多...
python爬取京东商品信息与可视化

python爬取京东商品信息与可视化

项目介绍&#xff1a;使用python爬取京东电商拿到价格、店铺、链接、销量并做可视化 ........................................................................................................................................................... 项目介绍效果展示全部…
阅读更多...
数据库系统概论（超详解！！！）第四节 数据库安全性

数据库系统概论（超详解！！！）第四节 数据库安全性

问题的提出&#xff1a; 数据库的一大特点是数据可以共享 数据共享必然带来数据库的安全性问题 数据库系统中的数据共享不能是无条件的共享。 1.数据库的安全概述 数据库的安全性是指保护数据库以防止不合法使用所造成的数据泄露、更改或破坏 。 系统安全保护措施是否有效…
阅读更多...
C语言：约瑟夫环问题详解

C语言：约瑟夫环问题详解

前言 哈喽&#xff0c;宝子们&#xff01;本期为大家带来一道C语言循环链表的经典算法题&#xff08;约瑟夫环&#xff09;。 目录 1.什么是约瑟夫环2.解决方案思路3.创建链表头结点4.创建循环链表5.删除链表6.完整代码实现 1.什么是约瑟夫环 据说著名历史学家Josephus有过以下…
阅读更多...
C/C++基础----判断和循环

C/C++基础----判断和循环

判断 if-elseif-else判断 语句&#xff1a; 条件使用之前的逻辑运算符或者关系运算符 if(条件1){条件1成立时内容 }else if(条件2){条件2成立时内容 }else{所有条件不成立时内容 }#include <iostream>using namespace std;int main() {int age 10;if (age > 18) {c…
阅读更多...
【C Hash Map from Redis】

【C Hash Map from Redis】

将Redis源码中的哈希表底层逻辑提取&#xff0c;并进行最小demo级测试将对应文件抽出&#xff0c;通过宏替换等方式保证源码编译通过main.c编写测试demo &#xff0c;注册哈希函数和值比较函数&#xff08;必选项&#xff09; /* Hash Tables Implementation.** This file imp…
阅读更多...
Java 原生代码获取服务器的网卡 Mac 地址、CPU序列号、主板序列号

Java 原生代码获取服务器的网卡 Mac 地址、CPU序列号、主板序列号

1、概述 Java 可以获取服务器的网卡 Mac 地址、CPU 序列号、主板序列号等信息&#xff0c;用来做一些软件授权验证、设备管理等场景。 2、代码实现 package com.study.util;import java.net.InetAddress; import java.net.NetworkInterface; import java.util.Scanner;/*** …
阅读更多...
elasticsearch7安全配置--最低安全等级，用户名密码

elasticsearch7安全配置--最低安全等级，用户名密码

上一篇博客在centos7上安装了elasticsearch7 接下来对elasticsearch进行安全方面的配置 minimal security 最低安全等级&#xff0c;用户名密码 首先开启xpack vim config/elasticsearch.yml xpack.security.enabled: true由于我是单机配置的&#xff0c;还加了如下配置 d…
阅读更多...
SAP HCM GET pernr无法获取到数据二

SAP HCM GET pernr无法获取到数据二

今天遇到一个比较奇怪的问题&#xff0c;PA30能查到员工主数据&#xff0c;任何信息类型也没有错误&#xff0c;但是核算工资的时候发现无法找到此人。 但是核算工资无法核算 断点到逻辑数据get pernr&#xff0c;也不会进入断点 查看0000数据有间隔 具体错误的代码位置如下&am…
阅读更多...
从 iPhone 上的短信中恢复已删除的图片的可靠方法

从 iPhone 上的短信中恢复已删除的图片的可靠方法

您可能在浏览消息聊天时不小心删除了一些文本和照片。事实上&#xff0c;如果这些消息对你来说意义重大&#xff0c;那对你来说可能会很麻烦。当发生意外情况时&#xff0c;您可能不想恢复整个聊天&#xff0c;而是恢复其中的附件。 好了&#xff0c;这篇文章主要是讲如何灵活…
阅读更多...
Towards Street-Level Client-Independent IP Geolocation（2011年）（第二部分）

Towards Street-Level Client-Independent IP Geolocation（2011年）（第二部分）

被引次数：306 Wang Y, Burgener D, Flores M, et al. Towards {Street-Level}{Client-Independent}{IP} Geolocation[C]//8th USENIX Symposium on Networked Systems Design and Implementation (NSDI 11). 2011. 接着Towards Street-Level Client-Independent IP Geolocati…
阅读更多...
【数据恢复软件】：Magnet AXIOM V8.0

【数据恢复软件】：Magnet AXIOM V8.0

Magnet AXIOM V8.0重大更新 1、全新的UI设计 2、更快的相应速度 3、补全工件分析 4、支持亚马逊AWS云数据&#xff08; 获取同一帐户或安全帐户上下文中的快照。 支持Windows实例、加密卷和超过1 TB的卷、具有多个卷的实例等等&#xff01; &#xff09; 5、Bug修复 6、AI支持…
阅读更多...
AI虽强，搜索引擎仍不可或缺

AI虽强，搜索引擎仍不可或缺

AI 领域正以前所未有的速度发展&#xff0c;大模型的发布变得愈发频繁&#xff0c;模型的规模也在持续扩大。如今&#xff0c;大模型的起点已经攀升至数十亿参数&#xff08;数十 B&#xff0c;B 是 Billion 的简写&#xff0c;10 亿&#xff09;&#xff0c;其功能之广泛&…
阅读更多...
从零实现诗词GPT大模型：数据集介绍和预处理

从零实现诗词GPT大模型：数据集介绍和预处理

本章将介绍该系列文章中使用的数据集&#xff0c;并且编写预处理代码&#xff0c;处理成咱们需要的格式。 一、数据集介绍 咱们使用的数据集名称是chinese-poetry&#xff0c;是一个在github上开源的中文诗词数据集&#xff0c;根据仓库中readme.md中的介绍&#xff0c;该数据…
阅读更多...
使用阿里云试用Elasticsearch学习：使用内置模型 lang_ident_model_1 创建管道并使用

使用阿里云试用Elasticsearch学习：使用内置模型 lang_ident_model_1 创建管道并使用

文档&#xff1a;https://www.elastic.co/guide/en/machine-learning/current/ml-nlp-deploy-model.html 部署刚刚下载好的内置模型 部署内存不够用 还得花钱&#xff0c;拉几把倒吧。就用自带的吧。 测试模型 POST _ml/trained_models/lang_ident_model_1/_infer {"doc…
阅读更多...
错题记录-华为海思

错题记录-华为海思

华为 海思数字芯片 参考 &#xff1a;FPGA开发/数字IC笔试系列(5) 华为海思IC笔试解析 FPGA开发/数字IC笔试系列(6) 华为海思IC笔试解析 SystemVerilog Function与Task的区别 $readmemh与$readmemb这两个系统任务是用来从指定文件中读取数据到寄存器数组或者RAM、ROM中。除了…
阅读更多...
IP地址修改步骤详解

IP地址修改步骤详解

IP地址是网络设备在网络中的标识&#xff0c;它决定了设备在网络中的位置与可访问性。然而&#xff0c;在某些情况下&#xff0c;我们可能需要修改IP地址&#xff0c;以满足特定的网络需求或解决网络问题。虎观代理将详细介绍IP地址的修改步骤&#xff0c;帮助读者更好地理解和…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023