order 是一个订单系统, 可用于任何基于订单的业务, 比如商品购买/发货等. 这个库是实现订单系统的lib库, 多个不同业务/分布式系统也能直接引用这个lib库且可以使用相同的底层储存组件(redis/mysql), 其业务隔离性由订单类型来区分.
-
多订单类型
-
多支付类型
-
混合支付
-
预付款下单
-
先下单后付款
-
业务数据嵌入到订单
-
订单变动流水记录
-
并发支持
-
订单可重入
-
metrics上报
- 首先准备一个库名为
order的mysql库. 这个库名可以根据sqlx组件配置的连接db库修改 - 创建订单的分表, 默认为2个分表, 分表索引从0开始, 可以通过配置
TableShardNums修改. 一开始应该设计好分表数量, 确认好后暂不支持修改分表数量, 如果你不知道设置为多少就设为1000.
app := zapp.NewApp("zapp.test.order",
order.WithOrder(),
)
defer app.Exit()sequenceDiagram
participant u as 用户
participant a as 业务层
participant b as order平台
participant f as 第三方付费平台
a ->> b: 注册业务 (RegistryOrderBusiness)
opt 用户预付费下单
rect rgb(230, 250, 255)
u ->> a: 下单
rect rgb(250, 180, 220)
a ->> b: 生成订单号 (GenOID)
a ->> b: 下单 (CreateOrder) 并启用后置补偿 (enableCompensation=true)
a ->> b: 推进订单 (Forward)
end
a -->> u: rps ok
end
end
opt 等待用户付费下单
rect rgb(230, 250, 255)
u ->> a: 下单
rect rgb(250, 180, 220)
a ->> b: 生成订单号 (GenOID)
a ->> b: 下单 (CreateOrder) 不启用后置补偿 (enableCompensation=false)
end
a -->>+ u: rps ok
u ->>- f: 用户付费
rect rgb(200, 240, 255)
opt 付费回调处理
f -->> a: 付费完成回调
rect rgb(250, 180, 220)
a ->> b: 更新付费状态 (UpdatePayStatus)
a ->> b: 发送后置补偿信号 (SendCompensationSignal)
end
a -->> f: ok
end
par 启协程推进订单
rect rgb(250, 180, 220)
a ->> b: 根据订单号推进订单 (ForwardOrderID), 此处失败不用告知第三方付费平台失败
end
a -->> a: 订单完成之后的其它处理
end
end
end
end
sequenceDiagram
participant u as 用户
participant a as 业务层
participant b as order平台
participant c as mysql
participant d as redis
participant e as mq
participant f as 第三方付费平台
a ->> b: 注册业务 (RegistryOrderBusiness)
opt 用户预付费下单
rect rgb(230, 250, 255)
u ->> a: 下单
a ->> b: 生成订单号 (GenOID)
rect rgb(250, 250, 220)
b ->> d: incr生成订单号
end
a ->> b: 下单 (CreateOrder) 并启用后置补偿 (enableCompensation=true)
rect rgb(250, 250, 220)
b ->> e: 写入补偿mq
b ->> c: 写入订单数据
end
a ->> b: 推进订单 (Forward)
rect rgb(250, 250, 220)
b ->> d: 加订单锁
b -->> c: 获取订单数据
b ->> b: 扣款
b ->> b: 发货
b ->> d: 解除订单锁
end
a -->> u: rsp ok
end
end
opt 等待用户付费下单
rect rgb(230, 250, 255)
u ->> a: 下单
a ->> b: 生成订单号 (GenOID)
rect rgb(250, 250, 220)
b ->> d: incr生成订单号
end
a ->> b: 下单 (CreateOrder) 不启用后置补偿 (enableCompensation=false)
b ->> c: 写入订单数据
a -->>+ u: rps ok
u ->>- f: 用户付费
rect rgb(200, 240, 255)
opt 付费回调处理
f -->> a: 付费完成回调
a ->> b: 更新付费状态 (UpdatePayStatus)
rect rgb(250, 250, 220)
b ->> c: 更新付费状态
end
a ->> b: 发送后置补偿信号 (SendCompensationSignal)
rect rgb(250, 250, 220)
b ->> e: 写入补偿mq
end
a -->> f: rsp ok
end
par 启协程推进订单
a ->> b: 根据订单号推进订单 (ForwardOrderID), 此处失败不用告知第三方付费平台失败
rect rgb(250, 250, 220)
b ->> d: 加订单锁
b -->> c: 获取订单数据
b ->> b: 扣款
b ->> b: 发货
b ->> d: 解除订单锁
end
a -->> a: 订单完成之后的其它处理
end
end
end
end
详细实现转到conf/config.go
# order配置
order:
SqlxName: "order" # sqlx组件名
TableShardNums: 2 # 表分片数量
RedisName: "order" # redis组件名
OrderLockDBExpire: 30 # 订单锁有效时间, 单位秒
OrderUnlockDBLimitProcessTime: 10 # 订单处理在多少时间内完成才会主动解锁, 单位秒
MQType: "pulsar" # mq类型. 支持 pulsar
MQProducerName: "order" # mq生产者组件名
AllowMqCompensation: false # 是否允许mq补偿, 如果为false, 将不会启动mq补偿消费进程, 代码中的提交mq补偿会报错, 且不会启动mq补偿消费者
CompensationDelayTime: 60 # mq补偿延迟时间, 单位秒
MQConsumeName: "order" # mq消费者组件名
CompensationMQMsgLifeTime: 3600 # mq消息如果存活超过这个时间, 在失败后不会再重试了. 单位秒
# 依赖组件
components:
sqlx: # 参考 https://github.com/zly-app/component/tree/master/sqlx
score:
# ...
redis: # 参考 https://github.com/zly-app/component/tree/master/redis
score:
# ...
pulsar-producer:
order:
# ...
# 依赖服务
services:
pulsar-consume:
order:
# ...在 apollo 中, 对于 order 配置可以直接创建一个 order 命名空间
SqlxName: "order" # sqlx组件名
TableShardNums: 2 # 表分片数量
RedisName: "order" # redis组件名
OrderLockDBExpire: 30 # 订单锁有效时间, 单位秒
OrderUnlockDBLimitProcessTime: 10 # 订单处理在多少时间内完成才会主动解锁, 单位秒
MQType: "pulsar" # mq类型. 支持 pulsar
MQProducerName: "order" # mq生产者名
AllowMqCompensation: false # 是否允许mq补偿, 如果为false, 将不会启动mq补偿消费进程, 代码中的提交mq补偿会报错, 且不会启动mq补偿消费者
CompensationDelayTime: 60 # mq补偿延迟时间, 单位秒
MQConsumeName: "order" # mq消费者名
CompensationMQMsgLifeTime: 3600 # mq消息如果存活超过这个时间, 在失败后不会再重试了. 单位秒