Rumah > pangkalan data > Redis > teks badan

Bagaimana untuk menyelesaikan masalah jualan kilat kupon Redis

王林
Lepaskan: 2023-05-28 14:52:17
ke hadapan
1205 orang telah melayarinya

1 Laksanakan fungsi jualan kilat kupon

Bagaimana untuk menyelesaikan masalah jualan kilat kupon Redis

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

Bagaimana untuk menyelesaikan masalah jualan kilat kupon Redis

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);
    }
}
Salin selepas log masuk

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

Bagaimana untuk menyelesaikan masalah jualan kilat kupon Redis

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)

Bagaimana untuk menyelesaikan masalah jualan kilat kupon Redis

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

Bagaimana untuk menyelesaikan masalah jualan kilat kupon Redis

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.

Bagaimana untuk menyelesaikan masalah jualan kilat kupon Redis

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)

Bagaimana untuk menyelesaikan masalah jualan kilat kupon Redis

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.

Bagaimana untuk menyelesaikan masalah jualan kilat kupon Redis

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

Bagaimana untuk menyelesaikan masalah jualan kilat kupon Redis

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();
Salin selepas log masuk
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);
    }
}
Salin selepas log masuk

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!

Label berkaitan:
sumber:yisu.com
Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Tutorial Popular
Lagi>
Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan
Tentang kita Penafian Sitemap
Laman web PHP Cina:Latihan PHP dalam talian kebajikan awam,Bantu pelajar PHP berkembang dengan cepat!