返回
最新动态
RocketMQ+SpringBoot+Dubbo+Zookeeper的下单支付场景实战
2024-12-26 07:43

模拟电商网站购物场景中的【下单】和【支付】业务

RocketMQ+SpringBoot+Dubbo+Zookeeper的下单支付场景实战

  1. 用户请求订单系统下单
  2. 订单系统通过RPC调用订单服务下单
  3. 订单服务调用优惠券服务，扣减优惠券
  4. 订单服务调用调用库存服务，校验并扣减库存
  5. 订单服务调用用户服务，扣减用户余额
  6. 订单服务完成确认订单

2）支付

  1. 用户请求支付系统
  2. 支付系统调用第三方支付平台API进行发起支付流程
  3. 用户通过第三方支付平台支付成功后，第三方支付平台回调通知支付系统
  4. 支付系统调用订单服务修改订单状态
  5. 支付系统调用积分服务添加积分
  6. 支付系统调用日志服务记录日志

问题1

用户提交订单后，扣减库存成功、扣减优惠券成功、使用余额成功，但是在确认订单操作失败，需要对库存、库存、余额进行回退。

如何保证数据的完整性？

问题2

用户通过第三方支付平台（支付宝、微信）支付成功后，第三方支付平台要通过回调API异步通知商家支付系统用户支付结果，支付系统根据支付结果修改订单状态、记录支付日志和给用户增加积分。

  • SpringBoot
  • Dubbo
  • Zookeeper
  • RocketMQ
  • Mysql

1）优惠券表

FieldTypeCommentcoupon_idbigint(50) NOT NULL优惠券IDcoupon_pricedecimal(10,2) NULL优惠券金额user_idbigint(50) NULL用户IDorder_idbigint(32) NULL订单IDis_usedint(1) NULL是否使用 0未使用 1已使用used_timetimestamp NULL使用时间

2）商品表

FieldTypeCommentgoods_idbigint(50) NOT NULL主键goods_namevarchar(255) NULL商品名称goods_numberint(11) NULL商品库存goods_pricedecimal(10,2) NULL商品价格goods_descvarchar(255) NULL商品描述add_timetimestamp NULL添加时间

3）订单表

FieldTypeCommentorder_idbigint(50) NOT NULL订单IDuser_idbigint(50) NULL用户IDorder_statusint(1) NULL订单状态 0未确认 1已确认 2已取消 3无效 4退款pay_statusint(1) NULL支付状态 0未支付 1支付中 2已支付shipping_statusint(1) NULL发货状态 0未发货 1已发货 2已退货addressvarchar(255) NULL收货地址consigneevarchar(255) NULL收货人goods_idbigint(50) NULL商品IDgoods_numberint(11) NULL商品数量goods_pricedecimal(10,2) NULL商品价格goods_amountdecimal(10,0) NULL商品总价shipping_feedecimal(10,2) NULL运费order_amountdecimal(10,2) NULL订单价格coupon_idbigint(50) NULL优惠券IDcoupon_paiddecimal(10,2) NULL优惠券money_paiddecimal(10,2) NULL已付金额pay_amountdecimal(10,2) NULL支付金额add_timetimestamp NULL创建时间/confirm/i_timetimestamp NULL订单确认时间pay_timetimestamp NULL支付时间

4）订单商品日志表

FieldTypeCommentgoods_idint(11) NOT NULL商品IDorder_idvarchar(32) NOT NULL订单IDgoods_numberint(11) NULL库存数量log_timedatetime NULL记录时间

5）用户表

FieldTypeCommentuser_idbigint(50) NOT NULL用户IDuser_namevarchar(255) NULL用户姓名user_passwordvarchar(255) NULL用户密码user_mobilevarchar(255) NULL手机号user_scoreint(11) NULL积分user_reg_timetimestamp NULL注册时间user_moneydecimal(10,0) NULL用户余额

6）用户余额日志表

FieldTypeCommentuser_idbigint(50) NOT NULL用户IDorder_idbigint(50) NOT NULL订单IDmoney_log_typeint(1) NOT NULL日志类型 1订单付款 2 订单退款use_moneydecimal(10,2) NULL操作金额create_timetimestamp NULL日志时间

7）订单支付表

FieldTypeCommentpay_idbigint(50) NOT NULL支付编号order_idbigint(50) NULL订单编号pay_amountdecimal(10,2) NULL支付金额is_paidint(1) NULL是否已支付 1否 2是

8）MQ消息生产表

FieldTypeCommentidvarchar(100) NOT NULL主键group_namevarchar(100) NULL生产者组名msg_topicvarchar(100) NULL消息主题msg_tagvarchar(100) NULLTagmsg_keyvarchar(100) NULLKeymsg_bodyvarchar(500) NULL消息内容msg_statusint(1) NULL0:未处理;1:已经处理create_timetimestamp NOT NULL记录时间

9）MQ消息消费表

FieldTypeCommentmsg_idvarchar(50) NULL消息IDgroup_namevarchar(100) NOT NULL消费者组名msg_tagvarchar(100) NOT NULLTagmsg_keyvarchar(100) NOT NULLKeymsg_bodyvarchar(500) NULL消息体consumer_statusint(1) NULL0:正在处理;1:处理成功;2:处理失败consumer_timesint(1) NULL消费次数consumer_timestamptimestamp NULL消费时间remarkvarchar(500) NULL备注

3.2.1 工程浏览

  • 父工程：shop-parent
  • 订单系统：shop-order-web
  • 支付系统：shop-pay-web
  • 优惠券服务：shop-coupon-service
  • 订单服务：shop-order-service
  • 支付服务：shop-pay-service
  • 商品服务：shop-goods-service
  • 用户服务：shop-user-service
  • 实体类：shop-pojo
  • 持久层：shop-dao
  • 接口层：shop-api
  • 工具工程：shop-common

共12个系统

  • ID生成器

    IDWorker：Twitter雪花算法

  • 异常处理类

    CustomerException：自定义异常类

    CastException：异常抛出类

  • 常量类

    ShopCode：系统状态类

  • 响应实体类

    Result：封装响应状态和响应信息

1）接口定义

  • IOrderService
 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
 

2）业务类实现
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
 

3）校验订单
 
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
 
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
 

5）扣减库存
 

  • 通过dubbo调用商品服务完成扣减库存
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
 

  • 商品服务GoodsService扣减库存
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
 

6）扣减优惠券
 

  • 通过dubbo完成扣减优惠券
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
 

  • 优惠券服务CouponService更改优惠券状态
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
 

7）扣减用户余额
 

  • 通过用户服务完成扣减余额
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
 

  • 用户服务UserService,更新余额
 
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
 

8）确认订单
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
 

9）小结
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
 
 

4.2.1 消息发送方
 

  • 配置RocketMQ属性值
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
 

  • 注入模板类和属性值信息
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
 

  • 发送下单失败消息
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
 

4.2.2 消费接收方
 

  • 配置RocketMQ属性值
 

 

  • 1
  • 2
  • 3
 

  • 创建监听类，消费消息
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
 

1）回退库存
 

  • 流程分析
 
 

  • 消息消费者
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95
  • 96
  • 97
  • 98
  • 99
  • 100
  • 101
  • 102
  • 103
  • 104
  • 105
  • 106
  • 107
  • 108
  • 109
  • 110
  • 111
  • 112
  • 113
  • 114
  • 115
  • 116
  • 117
  • 118
  • 119
  • 120
  • 121
  • 122
  • 123
  • 124
  • 125
  • 126
  • 127
  • 128
  • 129
  • 130
  • 131
  • 132
  • 133
  • 134
  • 135
  • 136
  • 137
  • 138
 

2）回退优惠券
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
 

3）回退余额
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
 

4）取消订单
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
 
 

1）准备测试环境
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
 

1）准备测试数据
 

  • 用户数据
  • 商品数据
  • 优惠券数据
 

2）测试下单成功流程
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
 

执行完毕后,查看数据库中用户的余额、优惠券数据，及订单的状态数据
 

3）测试下单失败流程
 

代码同上。
 

执行完毕后，查看用户的余额、优惠券数据是否发生更改，订单的状态是否为取消。
 
 
 
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
 
 

5.2.1 流程分析
 
 

5.2.2 代码实现
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
 

线程池优化消息发送逻辑
 

  • 创建线程池对象
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
 

  • 使用线程池
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
 

5.2.3 处理消息
 

支付成功后，支付服务payService发送MQ消息，订单服务、用户服务、日志服务需要订阅消息进行处理
 

  1. 订单服务修改订单状态为已支付
  2. 日志服务记录支付日志
  3. 用户服务负责给用户增加积分
 

以下用订单服务为例说明消息的处理情况
 

1）配置RocketMQ属性值
 

 

  • 1
  • 2
 

2）消费消息
 

  • 在订单服务中，配置公共的消息处理类
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
 

  • 接受订单支付成功消息
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
 
 

通过Rest客户端请求shop-order-web和shop-pay-web完成下单和支付操作
 
 

1）配置RestTemplate类
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
 

2）配置请求地址
 

  • 订单系统
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
 

  • 支付系统
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
 
 

 

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42



    以上就是本篇文章【RocketMQ+SpringBoot+Dubbo+Zookeeper的下单支付场景实战】的全部内容了，欢迎阅览 ！ 文章地址：http://keair.bhha.com.cn/quote/5244.html 
     
动态     
相关文章     
文章     
同类文章     
热门文章     
栏目首页     
网站地图     
返回首页 康宝晨移动站 http://keair.bhha.com.cn/mobile/ , 查看更多