[009 - 交易技术优化] 缓存以及RocketMQ的使用

[TemplarJQ]

解决问题

• 高效交易验证模型
• 缓存库存模型

交易性能瓶颈

• 交易验证完全依赖数据库（在订单下发的过程中有数次对于数据库的sql操作）
• 库存行锁问题
• 后置处理逻辑

现有逻辑

• 一共有6次SQL操作

[TemplarJQ]

交易验证优化

• 用户风控策略优化：缓存模型优化
• 活动校验策略优化：引入活动发布流程，模型缓存化，紧急下线能力

实现方式

• 增设service减少对数据库的依赖，是实现对SQL的语句优化（使用redis）

  @Override
  public ItemModel getItemByIdInCache(Integer id) {
      ItemModel itemModel = (ItemModel) redisTemplate.opsForValue().get("item_validate_"+id);
      if(itemModel == null) {
          itemModel = this.getItemById(id);
          redisTemplate.opsForValue().set("item_validate_"+id, itemModel);
      }
      return itemModel;
  }

• 库存行锁优化 主要的SQL语句为：

  //加入行锁，给对应的表加上索引可以优化
  <update id="decreaseStock">
  update item_stock
  set stock = stock - #{amount}
  where item_id = #{itemId} and stock >= #{amount}
  </update>

• 优化瓶颈

  • 扣减库存缓存化
    • 1.活动发布同步到缓存
    • 2.下单交易减缓存库存
      • 此时数据容易不一致，更改SQL的更新过程
      • 此时数据库记录是不一致的
    • 3.异步消息扣减数据库内库存（既保证用户C端体验，又保证一致性）使用RocketMQ（改进自Kaflka）
  • 异步同步数据库
  • 库存数据库最终一致性的保证

• RocketMQ

  • 高性能，高并发，分布式消息中间件
  • 典型场景：分布式事务，异步解耦

[TemplarJQ]

RocketMQ的部署

部署步骤

• 1)所处位置：//var/www/rocketmq
• 2)修改命令：chmod -R 777 *
• 3)命令解压：unzip xxx
• 4)按照操作步骤开始操作：RocketMQ官网，启动成功就可以进行下一步的操作

FAQ 1.启动server不成功，是runserver.sh的脚本所书写的java虚拟机大小有限制 安装问题的FAQ

使用RocketMQ