Go と Lua を使用して Redis フラッシュセールの在庫と過剰販売の問題を解決する方法-Redis-php.cn

Go と Lua を使用して Redis フラッシュセールの在庫と過剰販売の問題を解決する方法

王林

リリース： 2023-05-26 15:57:41

転載

1082 人が閲覧しました

0. はじめに

Go 言語は go-redis を接続してデータベースに接続します。この部分をまだ理解していない場合は、この部分を学習することをお勧めします。まずは知識。
また、このフラッシュセールでは、主に売れすぎ問題と在庫問題の 2 つの問題を解決します。
同時実行性をシミュレートするように設計された特別なページはありませんが、Goruntine を直接使用し、リクエストを呼び出す前に 10 秒間待機します。
売られすぎの問題に対処するには、トランザクション処理 [楽観的ロックと同等] を備えた go-redis watch を導入するだけです。

インベントリの問題は少し厄介です。スクリプトを編集するには Lua を使用する必要がありますが、自分のマシンに Lua コンパイル環境をダウンロードする必要はありません。Go は、関連するサポート。この部分ではパニックにならないでください。基本的な構造は次のとおりです:

Go と Lua を使用して Redis フラッシュセールの在庫と過剰販売の問題を解決する方法

1. 簡易バージョン

同時状況では売られすぎとマイナスの値Redis データベースに表示されます。運用前にデータで判断したとしても。

func MsCode(uuid, prodid string) bool {  
   // 1、对uuid和prodid进行非空判断  
   if uuid == "" || prodid == "" {  
      return false  
   }  
  
   //2、获取连接  
   rdb := DB  
  
   //3、拼接key  
   kcKey := "kc:" + prodid + ":qt"  
   userKey := "sk:" + prodid + ":user"  
  
   //4、获取库存  
   str, err := rdb.Get(ctx, kcKey).Result()  
   if err != nil {  
      fmt.Println(err)  
      fmt.Println("秒杀还未开始.......")  
      return false  
   }  
  
   // 5、判断用户是否重复秒杀操作  
   flag, err := rdb.SIsMember(ctx, userKey, userKey).Result()  
   if err != nil {  
      fmt.Println(err)  
   }  
   if flag {  
      fmt.Println("你已经参加了秒杀，无法再次参加。。。。")  
      return false  
   }  
  
   // 6、判断商品数量，如果库存数量小于1，秒杀结束  
   str, err = rdb.Get(ctx, kcKey).Result()  
   if err != nil {  
      fmt.Println(err)  
   }  
   n, err := strconv.Atoi(str)  
   if err != nil {  
      fmt.Println(err)  
   }  
   if n < 1 {  
      fmt.Println("秒杀结束，请下次再来吧。。。。")  
      return false  
   }  
  
   // 7、秒杀过程  
   // 7.1、库存减1  
   num, err := rdb.Decr(ctx, kcKey).Result()  
   if err != nil {  
      fmt.Println(err)  
   }  
   if num != 0 {  
      // 7.2、添加用户  
      rdb.SAdd(ctx, userKey, uuid)  
   }  
   return true  
}

func main() {
    // 并发的版本
    for i := 0; i < 20; i++ {
        go func() {
            uuid := GenerateUUID()
            prodid := "1023"
            time.Sleep(10 * time.Second)
            MsCode(uuid, prodid)
        }()
    }
    time.Sleep(15 * time.Second)
}

ログイン後にコピー

2. 売られすぎを解決する

watch を使用してキーを監視する重要な部分は次のとおりです。しかし、このままでは問題が発生し、在庫が残っていたとしても買えない人が出てきます。

err = rdb.Watch(ctx, func(tx *redis.Tx) error {  
   n, err := tx.Get(ctx, kcKey).Int()  
   if err != nil && err != redis.Nil {  
      return err  
   }  
   if n <= 0 {  
      return fmt.Errorf("抢购结束了！请下次早点来。。。。")  
   }  
   _, err = tx.TxPipelined(ctx, func(pipeliner redis.Pipeliner) error {  
      err := pipeliner.Decr(ctx, kcKey).Err()  
      if err != nil {  
         return err  
      }  
      err = pipeliner.SAdd(ctx, userKey, uuid).Err()  
      if err != nil {  
         return err  
      }  
      return nil  
   })  
   return err  
}, kcKey)

ログイン後にコピー

3. インベントリの問題を解決する Lua

Lua は、redis を操作することでこの問題をより適切に解決できます。 Redis で悲観的ロックが引き起こす可能性のあるインベントリの問題を回避するには、楽観的ロックの使用を検討する必要があります。 Redis にはオプティミスティックロックのサポートが組み込まれていないため、Lua を使用して関連するスクリプトを作成する必要があります。これには主に次の利点があります。

複雑なまたは複数ステップの Redis 操作をスクリプトとして作成し、それを Redis に送信して一度に実行できるため、Redis への繰り返し接続の数が減ります。性能を上げる。
luan スクリプトは Redis トランザクションに似ており、ある程度の原子性を持ち、他のコマンドによってキューに入れられることはなく、一部の Redis トランザクション操作を完了できます。
redis の Lua スクリプト機能は、redis2.6 以降のバージョンでのみ使用できます。
lua スクリプトを使用してユーザーを排除し、過剰販売の問題を解決します。
redis バージョン 2.6 以降では、競合の問題は Lua スクリプトによって解決され、実際、redis はシングルスレッド機能を使用して、タスクキューを使用してマルチタスクの同時実行の問題を解決します。

うわー

以上がGo と Lua を使用して Redis フラッシュセールの在庫と過剰販売の問題を解決する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。