Bagaimana untuk menyelesaikan masalah jualan kilat kupon Redis

1 Laksanakan fungsi jualan kilat kupon

Anda perlu menilai dua perkara semasa membuat pesanan: 1. Sama ada jualan kilat telah bermula atau tamat 2. Sama ada inventori adalah mencukupi

Oleh itu, logik perniagaan kami adalah seperti berikut

1 Dapatkan maklumat kupon melalui id kupon

2. Tentukan sama ada jualan kilat telah bermula, jika tiada kesilapan mesej dikembalikan

3 Tentukan Sama ada jualan kilat telah tamat, jika ia telah tamat, mesej ralat akan dikembalikan

4 inventori sudah mencukupi

5 Jika mencukupi, tolak inventori

6. Buat maklumat pesanan dan simpan ke jadual pesanan kupon

6.1 Simpan id pesanan

6.2 Simpan id pengguna

6.3 Simpan id kupon

7 . Pulangan id pesanan

Pelaksanaan kod: (Lapisan perkhidmatan kelas pelaksanaan)

package com.hmdp.service.impl;
import com.hmdp.dto.Result;
import com.hmdp.entity.SeckillVoucher;
import com.hmdp.entity.VoucherOrder;
import com.hmdp.mapper.VoucherOrderMapper;
import com.hmdp.service.ISeckillVoucherService;
import com.hmdp.service.IVoucherOrderService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hmdp.utils.RedisIdWorker;
import com.hmdp.utils.UserHolder;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.time.LocalDateTime;
/**
 * <p>
 *  服务实现类
 * </p>
 *
 * @author 虎哥
 * @since 2021-12-22
 */
@Service
public class VoucherOrderServiceImpl extends ServiceImpl<VoucherOrderMapper, VoucherOrder> implements IVoucherOrderService {
    @Resource
    private ISeckillVoucherService iSeckillVoucherService;
    @Resource
    private RedisIdWorker redisIdWorker;
    @Override
    public Result seckillVoucher(Long voucherId) {
        //1.获取优惠券信息
        SeckillVoucher voucher = iSeckillVoucherService.getById(voucherId);
        //2.判断是否已经开始
        if (voucher.getBeginTime().isAfter(LocalDateTime.now())){
            Result.fail("秒杀尚未开始!");
        }
        //3.判断是否已经结束
        if (voucher.getEndTime().isBefore(LocalDateTime.now())){
            Result.fail("秒杀已经结束了!");
        }
        //4.判断库存是否充足
        if (voucher.getStock() < 1) {
            Result.fail("库存不充足!");
        }
        //5.扣减库存
        boolean success = iSeckillVoucherService.update()
                .setSql("stock = stock-1").eq("voucher_id",voucherId)
                .update();
        if (!success){
            Result.fail("库存不充足!");
        }
        //6. 创建订单
        VoucherOrder voucherOrder = new VoucherOrder();
        //6.1添加订单id
        Long orderId = redisIdWorker.nextId("order");
        voucherOrder.setId(orderId);
        //6.2添加用户id
        Long userId = UserHolder.getUser().getId();
        voucherOrder.setUserId(userId);
        //6.3添加优惠券id
        voucherOrder.setVoucherId(voucherId);
        save(voucherOrder);
        //7.返回订单id
        return Result.ok(orderId);
    }
}

2 Masalah terlebih jual (titik utama)

Mari kita cuba jalankan kod di atas dengan serentak tinggi. (Menggunakan alat jmx)

Gambar di bawah menunjukkan bahawa dua ratus utas telah dibuat dan permintaan kupon dikeluarkan dalam sekelip mata

Tetapi apabila kita lihat pada laporan agregasi, kami dapati Outlier hanya 45.5%, yang secara logiknya sepatutnya 50% (kerana terdapat 100 item dalam stok, 200 permintaan telah dihantar ke sini)

Lihat pada nombor inventori, lelaki yang baik, ia adalah -9

109 pesanan turut ditambah, yang jelas menyebabkan masalah terlebih jual.

Jadi, kenapa masalah ini berlaku?

Lihat gambar dan bincang:

Ikuti proses biasa kami, iaitu, benang 1 menyemak inventori dan kemudian menolak inventori Pada masa ini, utas 2 menyemak semula inventori dan menolak inventori, jadi tiada masalah.

Masalah terlebih jual ialah selepas pesanan 1 menyemak inventori, didapati 1, tetapi sebelum potongan dibuat, benang 2 juga menyemak inventori itu didapati ia juga 1, dan potongan juga dibuat (dalam senario konkurensi tinggi)

Ini membawa kepada masalah terlebih jual.

Untuk masalah konkurensi tinggi jenis ini, penyelesaian yang paling biasa ialah: kunci~

Tetapi kunci termasuk kunci pesimis dan kunci optimistik.

Ringkasnya, penguncian pesimis bermakna: Dipercayai bahawa benang itu pasti akan berlaku, dan kemudian semua orang mengambil kunci sebelum operasi Selepas anda selesai melaksanakan, giliran seterusnya untuk melaksanakan (. pelaksanaan bersiri)

Kunci optimistik: Ia adalah optimistik (memikirkan keselamatan utas tidak akan berlaku), selagi sebelum setiap pengubahsuaian data, ia dinilai sama ada utas lain telah mengubah suai data untuk memastikan keselamatan utas.

Penguncian pesimis agak mudah dan penguncian optimistik dilaksanakan di sini.

Kunci kepada penguncian optimistik adalah untuk menentukan sama ada data yang diperolehi oleh pertanyaan sebelumnya telah diubah suai Terdapat dua kaedah biasa

Peringatan hangat: Data dalam jadual di sebelah kiri adalah semuanya. data selepas pelaksanaan urutan 1 Oh~

1. Kaedah nombor versi

ialah menambah nombor versi pada langkah menanyakan inventori Selepas setiap pengubahsuaian data, tambahkan nombor versi + 1 dan tambahkan syarat tempat untuk menilai Adakah nombor versi konsisten dengan yang sebelum pengubahsuaian? 2. Kaedah CAS

Ini adalah Tidak perlu nombor versi Cuma tambahkan syarat where selepas mengubah suai pangkalan data untuk menentukan sama ada inventori adalah inventori sebelum pengubahsuaian

Pelaksanaan kod untuk menyelesaikan masalah terlebih jual:

Dalam analisis akhir, apabila kami menolak inventori, kami menambah syarat di mana untuk menentukan sama ada inventori lebih besar daripada 0

//5.1扣减库存
boolean success = iSeckillVoucherService.update()
.setSql("stock = stock-1").eq("voucher_id" , voucherId).gt("stock" ,0)
.update();

package com.hmdp.service.impl;
import com.hmdp.dto.Result;
import com.hmdp.entity.SeckillVoucher;
import com.hmdp.entity.VoucherOrder;
import com.hmdp.mapper.VoucherOrderMapper;
import com.hmdp.service.ISeckillVoucherService;
import com.hmdp.service.IVoucherOrderService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hmdp.utils.RedisIdWorker;
import com.hmdp.utils.UserHolder;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.time.LocalDateTime;
/**
 * <p>
 *  服务实现类
 * </p>
 */
@Service
public class VoucherOrderServiceImpl extends ServiceImpl<VoucherOrderMapper, VoucherOrder> implements IVoucherOrderService {
    @Resource
    private ISeckillVoucherService iSeckillVoucherService;
    @Resource
    private RedisIdWorker redisIdWorker;
    @Override
    public Result seckillVoucher(Long voucherId) {
        //1.获取优惠券信息
        SeckillVoucher voucher = iSeckillVoucherService.getById(voucherId);
        //2.判断是否已经开始
        if (voucher.getBeginTime().isAfter(LocalDateTime.now())){
            Result.fail("秒杀尚未开始!");
        }
        //3.判断是否已经结束
        if (voucher.getEndTime().isBefore(LocalDateTime.now())){
            Result.fail("秒杀已经结束了!");
        }
        //4.判断库存是否充足
        if (voucher.getStock() < 1) {
            Result.fail("库存不充足!");
        }
        //5.扣减库存
        boolean success = iSeckillVoucherService.update()
                .setSql("stock = stock-1").eq("voucher_id",voucherId).gt("stock",0)
                .update();
        if (!success){
            Result.fail("库存不充足!");
        }
        //6. 创建订单
        VoucherOrder voucherOrder = new VoucherOrder();
        //6.1添加订单id
        Long orderId = redisIdWorker.nextId("order");
        voucherOrder.setId(orderId);
        //6.2添加用户id
        Long userId = UserHolder.getUser().getId();
        voucherOrder.setUserId(userId);
        //6.3添加优惠券id
        voucherOrder.setVoucherId(voucherId);
        save(voucherOrder);
        //7.返回订单id
        return Result.ok(orderId);
    }
}

Atas ialah kandungan terperinci Bagaimana untuk menyelesaikan masalah jualan kilat kupon Redis. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!