![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260209060529-698979292e6a4.png\")
<\/p>\n\u57fa\u4e8e Redis \u7684\u79d2\u6740\u5355\u673a\u7cfb\u7edf\u8fed\u4ee3\u5b9e\u73b0（\u9644\u8be6\u7ec6\u6d41\u7a0b\u56fe）-CSDN\u535a\u5ba2<\/p>\n
\u57fa\u4e8e Redis \u7684\u79d2\u6740\u96c6\u7fa4\u7cfb\u7edf\u8fed\u4ee3\u5b9e\u73b0\u3010SETNX\u3011（\u9644\u8be6\u7ec6\u6d41\u7a0b\u56fe）-CSDN\u535a\u5ba2<\/p>\n
\u57fa\u4e8e Redis \u7684\u79d2\u6740\u96c6\u7fa4\u7cfb\u7edf\u8fed\u4ee3\u5b9e\u73b0\u3010Redisson\u6e90\u7801\u5206\u6790\u3011（\u9644\u8be6\u7ec6\u6d41\u7a0b\u56fe）-CSDN\u535a\u5ba2<\/p>\n
<\/p>\n
\u6211\u4eec\u539f\u6765\u7528\u7684\u4e50\u89c2\u9501\u548cMysql\u5e95\u5c42\u7684\u4e92\u65a5\u9501\u67e5\u8be2\u6570\u636e\u5e93\u6765\u5224\u65ad\u5e93\u5b58\u6709\u65e0\u5269\u4f59\u5e76\u66f4\u65b0，\u4f46\u662f\u66f4\u65b0\u6570\u636e\u5e93\u662f\u6bd4\u8f83\u8017\u65f6\u7684，\u6240\u4ee5\u7528redis\u6765\u66ff\u4ee3，\u5e76\u4e14\u662f\u8981lua\u811a\u672c\u4fdd\u8bc1\u4e00\u81f4\u6027\u3002<\/p>\n
\u7b2c\u4e00\u6b21\u67e5\u8be2\u4f9d\u65e7\u662f\u6570\u636e\u5e93\u67e5\u8be2，\u56e0\u4e3a\u6211\u4eec\u8981\u8fdb\u884c\u4e00\u4e9b\u8be6\u7ec6\u7684\u5224\u65ad，\u800credis\u662f\u952e\u503c\u5bf9\u7c7b\u578b，\u786e\u5b9a\u5e93\u5b58\u6709\u5269\u4f59，\u518d\u52a0\u5165\u5230\u8ba2\u5355set\u96c6\u5408\u4e2d，\u4fdd\u8bc1\u4e00\u4eba\u4e00\u5355，\u6240\u4ee5\u7ed9\u7528\u6237\u4e0b\u5355\u5224\u65ad\u662f\u5426\u4e70\u8fc7\u7684\u52a0\u4e0aRedisson\u9501\u4e5f\u53ef\u4ee5\u7701\u53bb\u4e86，set\u662f\u4fdd\u8bc1\u4e0d\u91cd\u590d\u7684，\u4f46\u662f\u5c06\u7528\u6237\u8ba2\u5355\u4fdd\u5b58\u5230\u6570\u636e\u5e93\u4e2d\u8fd8\u662f\u8981\u6267\u884c\u7684，\u91c7\u7528\u5f02\u6b65\u6765\u4f18\u5316\u3002<\/p>\n
— 1.\u53c2\u6570\u5217\u8868
\n— 1.1.\u4f18\u60e0\u5238id
\nlocal voucherId = ARGV[1]
\n— 1.2.\u7528\u6237id
\nlocal userId = ARGV[2]<\/p>\n
— 2.\u6570\u636ekey
\n— 2.1.\u5e93\u5b58key
\nlocal stockKey = 'seckill:stock:' .. voucherId
\n— 2.2.\u8ba2\u5355key
\nlocal orderKey = 'seckill:order:' .. voucherId<\/p>\n
— 3.\u811a\u672c\u4e1a\u52a1
\n— 3.1.\u5224\u65ad\u5e93\u5b58\u662f\u5426\u5145\u8db3 get stockKey
\nif(tonumber(redis.call('get', stockKey)) <= 0) then
\n — 3.2.\u5e93\u5b58\u4e0d\u8db3，\u8fd4\u56de1
\n return 1
\nend
\n— 3.2.\u5224\u65ad\u7528\u6237\u662f\u5426\u4e0b\u5355 SISMEMBER orderKey userId
\nif(redis.call('sismember', orderKey, userId) == 1) then
\n — 3.3.\u5b58\u5728，\u8bf4\u660e\u662f\u91cd\u590d\u4e0b\u5355，\u8fd4\u56de2
\n return 2
\nend
\n— 3.4.\u6263\u5e93\u5b58 incrby stockKey -1
\nredis.call('incrby', stockKey, -1)
\n— 3.5.\u4e0b\u5355（\u4fdd\u5b58\u7528\u6237）sadd orderKey userId
\nredis.call('sadd', orderKey, userId)
\nreturn 0 <\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260209060531-6989792b8e345.png\")
<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260209060532-6989792c59806.png\")
<\/p>\n
\u6dfb\u52a0\u79d2\u6740\u7684\u65f6\u5019\u628a\u4f18\u60e0\u5377\u653e\u5230Redis\u4e2d<\/p>\n
@Override
\n @Transactional
\n public void addSeckillVoucher(Voucher voucher) {
\n \/\/ \u4fdd\u5b58\u4f18\u60e0\u5238
\n save(voucher);
\n \/\/ \u4fdd\u5b58\u79d2\u6740\u4fe1\u606f
\n SeckillVoucher seckillVoucher = new SeckillVoucher();
\n seckillVoucher.setVoucherId(voucher.getId());
\n seckillVoucher.setStock(voucher.getStock());
\n seckillVoucher.setBeginTime(voucher.getBeginTime());
\n seckillVoucher.setEndTime(voucher.getEndTime());
\n seckillVoucherService.save(seckillVoucher);
\n stringRedisTemplate.opsForValue().set(RedisConstants.getSeckillStockKey(voucher.getId()), voucher.getStock().toString());
\n } <\/p>\n
\u518d\u4fee\u6539\u79d2\u6740\u63a5\u53e3<\/p>\n
\/\/lua\u811a\u672c
\n private static final DefaultRedisScript<Long> SECKILL_SCRIPT ;
\n static {
\n SECKILL_SCRIPT = new DefaultRedisScript<>();
\n SECKILL_SCRIPT.setLocation(new ClassPathResource("seckill.lua"));
\n SECKILL_SCRIPT.setResultType(Long.class);
\n }<\/p>\n
\/\/\u5f53\u524d\u4ee3\u7406\u5bf9\u8c61
\n private IVoucherOrderService proxy;<\/p>\n
@Override
\n @Transactional
\n public Long seckillVoucher(Long voucherId) {
\n \/\/ 1.\u67e5\u8be2\u4f18\u60e0\u5238
\n SeckillVoucher voucher = seckillVoucherService.getById(voucherId);
\n \/\/ 2.\u5224\u65ad\u79d2\u6740\u662f\u5426\u5f00\u59cb
\n if (voucher.getBeginTime().isAfter(LocalDateTime.now())) {
\n \/\/ \u5c1a\u672a\u5f00\u59cb
\n throw new BaseException(ExceptionConstants.NOT_START);
\n }
\n \/\/ 3.\u5224\u65ad\u79d2\u6740\u662f\u5426\u5df2\u7ecf\u7ed3\u675f
\n if (voucher.getEndTime().isBefore(LocalDateTime.now())) {
\n \/\/ \u5c1a\u672a\u5f00\u59cb
\n throw new BaseException(ExceptionConstants.IS_END);
\n }
\n \/\/ 4.\u5224\u65ad\u5e93\u5b58\u662f\u5426\u5145\u8db3
\n if (voucher.getStock() < 1) {
\n \/\/ \u5e93\u5b58\u4e0d\u8db3
\n throw new BaseException(ExceptionConstants.NOT_ENOUGH);
\n }
\n \/\/ 5.\u6267\u884clua\u811a\u672c
\n Long userId = UserHolder.getUser().getId();
\n long orderId = redisIdWorker.nextId("order");
\n Long result = stringRedisTemplate.execute(
\n SECKILL_SCRIPT,
\n Collections.emptyList(),
\n voucherId.toString(), userId.toString()
\n );
\n int r = result.intValue();
\n if (r == NumberConstants.NOT_ENOUGH){
\n \/\/ 6.\u5224\u65ad\u5e93\u5b58\u662f\u5426\u5145\u8db3
\n throw new BaseException(ExceptionConstants.NOT_ENOUGH);
\n } else if (r == NumberConstants.EXIST_BUY) {
\n \/\/ 7.\u7528\u6237\u5df2\u7ecf\u8d2d\u4e70\u8fc7\u4e86
\n throw new BaseException(ExceptionConstants.EXIST_BUY);
\n }
\n VoucherOrder voucherOrder = new VoucherOrder();
\n voucherOrder.setId(orderId);
\n voucherOrder.setUserId(userId);
\n voucherOrder.setVoucherId(voucherId);
\n \/\/ 8.\u83b7\u53d6\u4ee3\u7406\u5bf9\u8c61
\n proxy = (IVoucherOrderService)AopContext.currentProxy();
\n \/\/ 9.\u653e\u5165\u963b\u585e\u961f\u5217
\n orderTasks.add(voucherOrder);
\n \/\/10.\u8fd4\u56de\u8ba2\u5355id
\n return orderId;
\n }<\/p>\n
@Transactional
\n public void createVoucherOrder(VoucherOrder voucherOrder) {
\n Long userId = voucherOrder.getUserId();
\n \/\/ 1.\u67e5\u8be2\u8ba2\u5355
\n int count = query().eq("user_id", userId).eq("voucher_id", voucherOrder.getVoucherId()).count();
\n \/\/ 2.\u5224\u65ad\u662f\u5426\u5b58\u5728
\n if (count > 0) {
\n \/\/ \u7528\u6237\u5df2\u7ecf\u8d2d\u4e70\u8fc7\u4e86
\n throw new BaseException(ExceptionConstants.EXIST_BUY);
\n }
\n \/\/ 2.\u6263\u51cf\u5e93\u5b58
\n boolean success = seckillVoucherService.update()
\n .setSql("stock = stock – 1") \/\/ set stock = stock – 1
\n .eq("voucher_id", voucherOrder.getVoucherId()).gt("stock", 0) \/\/ where id = ? and stock > 0
\n .update();
\n if (!success) {
\n throw new BaseException(ExceptionConstants.NOT_ENOUGH);
\n }
\n save(voucherOrder);<\/p>\n
}<\/p>\n
\/\/\u963b\u585e\u961f\u5217
\n private BlockingQueue<VoucherOrder> orderTasks =new ArrayBlockingQueue<>(1024 * 1024);<\/p>\n
\/\/\u5f02\u6b65\u5904\u7406\u7ebf\u7a0b\u6c60
\n private static final ExecutorService SECKILL_ORDER_EXECUTOR = Executors.newSingleThreadExecutor();<\/p>\n
\/\/\u5728\u7c7b\u521d\u59cb\u5316\u4e4b\u540e\u6267\u884c，\u56e0\u4e3a\u5f53\u8fd9\u4e2a\u7c7b\u521d\u59cb\u5316\u597d\u4e86\u4e4b\u540e，\u968f\u65f6\u90fd\u662f\u6709\u53ef\u80fd\u8981\u6267\u884c\u7684
\n @PostConstruct
\n private void init() {
\n SECKILL_ORDER_EXECUTOR.submit(new VoucherOrderHandler());
\n }<\/p>\n
\/\/ \u7528\u4e8e\u7ebf\u7a0b\u6c60\u5904\u7406\u7684\u4efb\u52a1
\n private class VoucherOrderHandler implements Runnable {<\/p>\n
@Override
\n public void run() {
\n while (true) {
\n try {
\n \/\/ 1.\u83b7\u53d6\u961f\u5217\u4e2d\u7684\u8ba2\u5355\u4fe1\u606f
\n VoucherOrder voucherOrder = orderTasks.take();
\n \/\/ 2.\u521b\u5efa\u8ba2\u5355
\n handleVoucherOrder(voucherOrder);
\n } catch (Exception e) {
\n log.error("\u5904\u7406\u8ba2\u5355\u5f02\u5e38", e);
\n }
\n }
\n }<\/p>\n
private void handleVoucherOrder(VoucherOrder voucherOrder) {
\n \/\/1.\u83b7\u53d6\u7528\u6237
\n Long userId = voucherOrder.getUserId();
\n \/\/ 2.\u521b\u5efa\u9501\u5bf9\u8c61
\n String key = RedisConstants.getLockOrderKey(userId);
\n \/\/ 3.\u5c1d\u8bd5\u83b7\u53d6\u9501
\n RLock lock = redissonClient.getLock(key);
\n try {
\n boolean isLock = lock.tryLock();
\n \/\/ 4.\u5224\u65ad\u662f\u5426\u83b7\u5f97\u9501\u6210\u529f
\n if (!isLock) {
\n \/\/ \u83b7\u53d6\u9501\u5931\u8d25，\u76f4\u63a5\u8fd4\u56de\u5931\u8d25\u6216\u8005\u91cd\u8bd5
\n throw new BaseException(ExceptionConstants.EXIST_BUY);
\n }
\n \/\/\u6ce8\u610f：\u7531\u4e8e\u662fspring\u7684\u4e8b\u52a1\u662f\u653e\u5728threadLocal\u4e2d
\n proxy.createVoucherOrder(voucherOrder);
\n } finally {
\n \/\/ \u91ca\u653e\u9501
\n lock.unlock();
\n }
\n }
\n }
\n\/\/ \u7528\u4e8e\u7ebf\u7a0b\u6c60\u5904\u7406\u7684\u4efb\u52a1
\n@Slf4j
\n@Component
\npublic class VoucherOrderHandler implements Runnable {<\/p>\n
@Autowired
\n private IVoucherOrderService voucherOrderService;
\n @Autowired
\n private RedissonClient redissonClient;
\n @Autowired
\n private StringRedisTemplate stringRedisTemplate;<\/p>\n
@Override
\n public void run() {
\n while (true) {
\n try {
\n \/\/ 1.\u83b7\u53d6\u6d88\u606f\u961f\u5217\u4e2d\u7684\u8ba2\u5355\u4fe1\u606f XREADGROUP GROUP g1 c1 COUNT 1 BLOCK 2000 STREAMS s1 >
\n List<MapRecord<String, Object, Object>> list = stringRedisTemplate.opsForStream().read(
\n Consumer.from("g1", "c1"),
\n StreamReadOptions.empty().count(1).block(Duration.ofSeconds(2)),
\n StreamOffset.create("stream.orders", ReadOffset.lastConsumed())
\n );
\n \/\/ 2.\u5224\u65ad\u8ba2\u5355\u4fe1\u606f\u662f\u5426\u4e3a\u7a7a
\n if (list == null || list.isEmpty()) {
\n \/\/ \u5982\u679c\u4e3anull，\u8bf4\u660e\u6ca1\u6709\u6d88\u606f，\u7ee7\u7eed\u4e0b\u4e00\u6b21\u5faa\u73af
\n continue;
\n }
\n \/\/ \u89e3\u6790\u6570\u636e
\n MapRecord<String, Object, Object> record = list.get(0);
\n Map<Object, Object> value = record.getValue();
\n VoucherOrder voucherOrder = BeanUtil.fillBeanWithMap(value, new VoucherOrder(), true);
\n \/\/3.\u83b7\u53d6\u7528\u6237
\n Long userId = voucherOrder.getUserId();
\n \/\/ 4.\u521b\u5efa\u9501\u5bf9\u8c61
\n String key = RedisConstants.getLockOrderKey(userId);
\n \/\/ 5.\u5c1d\u8bd5\u83b7\u53d6\u9501
\n RLock lock = redissonClient.getLock(key);
\n try {
\n boolean isLock = lock.tryLock();
\n \/\/ 6.\u5224\u65ad\u662f\u5426\u83b7\u5f97\u9501\u6210\u529f
\n if (!isLock) {
\n \/\/ \u83b7\u53d6\u9501\u5931\u8d25，\u76f4\u63a5\u8fd4\u56de\u5931\u8d25\u6216\u8005\u91cd\u8bd5
\n throw new BaseException(ExceptionConstants.EXIST_BUY);
\n }
\n \/\/ 7.\u786e\u8ba4\u6d88\u606f XACK
\n stringRedisTemplate.opsForStream().acknowledge("s1", "g1", record.getId());
\n } finally {
\n \/\/ \u91ca\u653e\u9501
\n lock.unlock();
\n }
\n } catch (Exception e) {
\n log.error("\u5904\u7406\u8ba2\u5355\u5f02\u5e38", e);
\n \/\/\u5904\u7406\u5f02\u5e38\u6d88\u606f
\n handlePendingList();
\n }
\n }
\n }<\/p>\n
private void handlePendingList() {
\n while (true) {
\n try {
\n \/\/ 1.\u83b7\u53d6pending-list\u4e2d\u7684\u8ba2\u5355\u4fe1\u606f XREADGROUP GROUP g1 c1 COUNT 1 BLOCK 2000 STREAMS s1 0
\n List<MapRecord<String, Object, Object>> list = stringRedisTemplate.opsForStream().read(
\n Consumer.from("g1", "c1"),
\n StreamReadOptions.empty().count(1),
\n StreamOffset.create("stream.orders", ReadOffset.from("0"))
\n );
\n \/\/ 2.\u5224\u65ad\u8ba2\u5355\u4fe1\u606f\u662f\u5426\u4e3a\u7a7a
\n if (list == null || list.isEmpty()) {
\n \/\/ \u5982\u679c\u4e3anull，\u8bf4\u660e\u6ca1\u6709\u5f02\u5e38\u6d88\u606f，\u7ed3\u675f\u5faa\u73af
\n break;
\n }
\n \/\/ \u89e3\u6790\u6570\u636e
\n MapRecord<String, Object, Object> record = list.get(0);
\n Map<Object, Object> value = record.getValue();
\n VoucherOrder voucherOrder = BeanUtil.fillBeanWithMap(value, new VoucherOrder(), true);
\n \/\/3.\u83b7\u53d6\u7528\u6237
\n Long userId = voucherOrder.getUserId();
\n \/\/ 4.\u521b\u5efa\u9501\u5bf9\u8c61
\n String key = RedisConstants.getLockOrderKey(userId);
\n \/\/ 5.\u5c1d\u8bd5\u83b7\u53d6\u9501
\n RLock lock = redissonClient.getLock(key);
\n try {
\n boolean isLock = lock.tryLock();
\n \/\/ 6.\u5224\u65ad\u662f\u5426\u83b7\u5f97\u9501\u6210\u529f
\n if (!isLock) {
\n \/\/ \u83b7\u53d6\u9501\u5931\u8d25，\u76f4\u63a5\u8fd4\u56de\u5931\u8d25\u6216\u8005\u91cd\u8bd5
\n throw new BaseException(ExceptionConstants.EXIST_BUY);
\n }
\n \/\/\u6ce8\u610f：\u7531\u4e8e\u662fspring\u7684\u4e8b\u52a1\u662f\u653e\u5728threadLocal\u4e2d
\n voucherOrderService.createVoucherOrder(voucherOrder);
\n \/\/ 7.\u786e\u8ba4\u6d88\u606f XACK
\n stringRedisTemplate.opsForStream().acknowledge("s1", "g1", record.getId());
\n } finally {
\n \/\/ \u91ca\u653e\u9501
\n lock.unlock();
\n }
\n } catch (Exception e) {
\n log.error("\u5904\u7406pendding\u8ba2\u5355\u5f02\u5e38", e);
\n try {
\n Thread.sleep(20);
\n } catch (Exception ex) {
\n ex.printStackTrace();
\n }
\n }
\n }
\n }
\n} <\/p>\n
JVM\u7684\u963b\u585e\u961f\u5217\u5728\u9ad8\u5e76\u53d1\u7684\u60c5\u51b5\u4e0b\u53ef\u80fd\u4f1a\u6709\u5185\u5b58\u6ea2\u51fa\u7684\u98ce\u9669，\u5982\u679c\u670d\u52a1\u5668\u5b95\u673a\u4e86，\u5185\u5b58\u91cc\u9762\u7684\u6570\u636e\u5c31\u4f1a\u4e22\u5931，\u51fa\u73b0\u4e86\u6570\u636e\u4e0d\u4e00\u81f4\u7684\u60c5\u51b5\u3002<\/p>\n
Redis\u7684list\u6570\u636e\u7ed3\u6784\u662f\u4e00\u4e2a\u53cc\u5411\u94fe\u8868 ，\u4f7f\u7528BRPOP\u6216\u8005BLPOP\u6765\u5b9e\u73b0\u963b\u585e\u6548\u679c\u3002<\/p>\n
\u4f18\u70b9：<\/p>\n
\u5229\u7528Redis\u5b58\u50a8，\u4e0d\u53d7\u9650\u4e8eJVM\u5185\u5b58\u4e0a\u9650<\/p>\n<\/li>\n
\u57fa\u4e8eRedis\u7684\u6301\u4e45\u5316\u673a\u5236，\u6570\u636e\u5b89\u5168\u6027\u6709\u4fdd\u8bc1<\/p>\n<\/li>\n
\u53ef\u4ee5\u6ee1\u8db3\u6d88\u606f\u6709\u5e8f\u6027<\/p>\n<\/li>\n<\/ul>\n
\u7f3a\u70b9：<\/p>\n
\u51fa\u961f\u53ea\u80fd\u4fdd\u8bc1\u6d88\u606f\u88ab\u79fb\u51fa，\u65e0\u6cd5\u4fdd\u8bc1\u6709\u6ca1\u6709\u5bf9\u8fd9\u4e2a\u6d88\u606f\u8fdb\u884c\u5904\u7406，\u65e0\u6cd5\u907f\u514d\u6d88\u606f\u4e22\u5931<\/p>\n<\/li>\n
\u53ea\u652f\u6301\u5355\u6d88\u8d39\u8005，\u4e00\u4e2a\u4fe1\u606f\u53ea\u80fd\u88ab\u4e00\u4e2a\u6d88\u8d39\u8005\u53d6\u51fa<\/p>\n<\/li>\n<\/ul>\n
\u6d88\u8d39\u8005\u53ef\u4ee5\u8ba2\u9605\u4e00\u4e2a\u6216\u591a\u4e2achannel，\u751f\u4ea7\u8005\u5411\u5bf9\u5e94channel\u53d1\u9001\u6d88\u606f\u540e，\u6240\u6709\u8ba2\u9605\u8005\u90fd\u80fd\u6536\u5230\u76f8\u5173\u6d88\u606f\u3002<\/p>\n
\u4f18\u70b9：<\/p>\n
\u91c7\u7528\u53d1\u5e03\u8ba2\u9605\u6a21\u578b，\u652f\u6301\u591a\u751f\u4ea7\u3001\u591a\u6d88\u8d39<\/p>\n<\/li>\n<\/ul>\n
\u7f3a\u70b9：<\/p>\n
\u5982\u679c\u4e00\u4e2achannel\u65e0\u4eba\u8ba2\u9605，\u90a3\u4e48\u8fd9\u4e2a\u6d88\u606f\u5c31\u4e22\u5931\u4e86，\u65e0\u6cd5\u505a\u5230\u6570\u636e\u7684\u6301\u4e45\u5316<\/p>\n<\/li>\n
\u6d88\u606f\u5806\u79ef\u6709\u4e0a\u9650，\u53d1\u9001\u7684\u6d88\u606f\u5982\u679c\u6709\u6d88\u8d39\u8005\u76d1\u542c，\u4f1a\u5b58\u5728\u6d88\u8d39\u8005\u7684\u7f13\u5b58\u533a\u57df，\u5982\u679c\u5904\u7406\u5f97\u6162\u6d88\u606f\u6709\u591a，\u5c31\u4f1a\u8d85\u51fa\u4e0a\u7ebf，\u6570\u636e\u4e22\u5931<\/p>\n<\/li>\n<\/ul>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260209060534-6989792e024a4.png\")
<\/p>\n
\u4f18\u70b9：<\/span><\/p>\n \u6d88\u606f\u53ef\u56de\u6eaf<\/p>\n<\/li>\n \u4e00\u4e2a\u6d88\u606f\u53ef\u4ee5\u88ab\u591a\u4e2a\u6d88\u8d39\u8005\u8bfb\u53d6<\/p>\n<\/li>\n \u53ef\u4ee5\u963b\u585e\u8bfb\u53d6<\/p>\n<\/li>\n<\/ul>\n \u7f3a\u70b9：<\/p>\n \u5f53\u6211\u4eec\u5904\u7406\u5b8c\u4e00\u6761\u6d88\u606f\u65f6\u53ef\u80fd\u4e00\u4e0b\u5b50\u591a\u4e86\u5f88\u591a\u6761\u6d88\u606f，\u4f46\u53ea\u8bfb\u53d6\u4e86\u6700\u65b0\u7684\u6d88\u606f，\u5bfc\u81f4\u6d88\u606f\u6f0f\u8bfb<\/p>\n<\/li>\n<\/ul>\n XREADGROUP GROUP group consumer [COUNT count] [BLOCK milliseconds] [NOACK] STREAMS key [key …] ID [ID …] <\/p>\n group：\u6d88\u8d39\u7ec4\u540d\u79f0<\/p>\n<\/li>\n consumer：\u6d88\u8d39\u8005\u540d\u79f0，\u5982\u679c\u6d88\u8d39\u8005\u4e0d\u5b58\u5728，\u4f1a\u81ea\u52a8\u521b\u5efa\u4e00\u4e2a\u6d88\u8d39\u8005<\/p>\n<\/li>\n count：\u672c\u6b21\u67e5\u8be2\u7684\u6700\u5927\u6570\u91cf<\/p>\n<\/li>\n BLOCK milliseconds：\u5f53\u6ca1\u6709\u6d88\u606f\u65f6\u6700\u957f\u7b49\u5f85\u65f6\u95f4<\/p>\n<\/li>\n NOACK：\u65e0\u9700\u624b\u52a8ACK，\u83b7\u53d6\u5230\u6d88\u606f\u540e\u81ea\u52a8\u786e\u8ba4<\/p>\n<\/li>\n STREAMS key：\u6307\u5b9a\u961f\u5217\u540d\u79f0<\/p>\n<\/li>\n ID：\u83b7\u53d6\u6d88\u606f\u7684\u8d77\u59cbID<\/p>\n ">"：\u4ece\u4e0b\u4e00\u4e2a\u672a\u6d88\u8d39\u7684\u6d88\u606f\u5f00\u59cb<\/p>\n<\/li>\n \u5176\u5b83：\u6839\u636e\u6307\u5b9aid\u4ecepending-list\u4e2d\u83b7\u53d6\u5df2\u6d88\u8d39\u4f46\u672a\u786e\u8ba4\u7684\u6d88\u606f，\u4f8b\u59820，\u662f\u4ecepending-list\u4e2d\u7684\u7b2c\u4e00\u4e2a\u6d88\u606f\u5f00\u59cb<\/p>\n<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n \u5c06\u591a\u4e2a\u6d88\u8d39\u8005\u5212\u5206\u5230\u4e00\u4e2a\u7ec4\u4e2d，\u76d1\u542c\u540c\u4e00\u4e2a\u961f\u5217\u3002\u5177\u5907\u4e0b\u5217\u7279\u70b9：<\/p>\n \u4f18\u70b9：<\/p>\n \u6d88\u606f\u53ef\u56de\u6eaf<\/p>\n<\/li>\n \u53ef\u4ee5\u591a\u6d88\u8d39\u8005\u4e89\u62a2\u6d88\u606f，\u52a0\u5feb\u6d88\u8d39\u901f\u5ea6<\/p>\n<\/li>\n \u53ef\u4ee5\u963b\u585e\u8bfb\u53d6<\/p>\n<\/li>\n \u6ca1\u6709\u6d88\u606f\u6f0f\u8bfb\u7684\u98ce\u9669<\/p>\n<\/li>\n \u6709\u6d88\u606f\u786e\u8ba4\u673a\u5236，\u4fdd\u8bc1\u6d88\u606f\u81f3\u5c11\u88ab\u6d88\u8d39\u4e00\u6b21<\/p>\n<\/li>\n<\/ul>\n \u76f4\u63a5\u5728\u6210\u529f\u4e0b\u5355\u540e\u53d1\u9001\u6d88\u606f\u7ed9\u6d88\u606f\u961f\u5217，\u51cf\u5c11java\u548credis\u7684\u4ea4\u4e92<\/p>\n — 1.\u53c2\u6570\u5217\u8868 — 2.\u6570\u636ekey — 3.\u811a\u672c\u4e1a\u52a1 \u76f4\u63a5\u5728redis\u91cc\u9762\u521b\u5efa\u5c31\u53ef\u4ee5\u4e86<\/p>\n XGROUP CREATE stream.orders g1 0 MKSTREAM <\/p>\n @Service @Autowired \/\/lua\u811a\u672c \/\/\u5f02\u6b65\u5904\u7406\u7ebf\u7a0b\u6c60 \/\/\u5728\u7c7b\u521d\u59cb\u5316\u4e4b\u540e\u6267\u884c，\u56e0\u4e3a\u5f53\u8fd9\u4e2a\u7c7b\u521d\u59cb\u5316\u597d\u4e86\u4e4b\u540e，\u968f\u65f6\u90fd\u662f\u6709\u53ef\u80fd\u8981\u6267\u884c\u7684 @Override @Transactional \u4e3b\u4e1a\u52a1\u66f4\u52a0\u7b80\u6d01\u660e\u4e86<\/p>\n @Slf4j @Autowired @Override private void handlePendingList() { \u4e00\u3001\u524d\u7f6e\u5185\u5bb9\n
\n
3.4\u00a0\u57fa\u4e8eStream\u7684\u6d88\u606f\u961f\u5217（XREADGROUP ）<\/h3>\n
\n
\n
\n
\n
\n
\n
\n
3.5 \u5bf9\u6bd4<\/h3>\n
\n
\u7279\u6027\u57fa\u4e8e List \u5b9e\u73b0\u57fa\u4e8e PubSub \u5b9e\u73b0\u57fa\u4e8e Stream (XREAD)\u57fa\u4e8e Stream (XREADGROUP)<\/tr>\n \n\n \u6838\u5fc3\u539f\u7406<\/td>\n \u4f7f\u7528\u00a0LPUSH\/RPOP\u00a0\u7b49\u547d\u4ee4，\u57fa\u4e8e\u94fe\u8868\u7ed3\u6784\u5b9e\u73b0\u7b80\u5355\u7684\u5148\u8fdb\u5148\u51fa\u961f\u5217<\/td>\n \u53d1\u5e03 – \u8ba2\u9605\u6a21\u5f0f，\u6d88\u606f\u4f1a\u88ab\u5e7f\u64ad\u7ed9\u6240\u6709\u8ba2\u9605\u8005<\/td>\n \u57fa\u4e8e Stream \u6570\u636e\u7ed3\u6784，\u901a\u8fc7\u6e38\u6807\u00a0XREAD\u00a0\u62c9\u53d6\u6d88\u606f，\u652f\u6301\u6301\u4e45\u5316<\/td>\n \u57fa\u4e8e Stream \u7684\u6d88\u8d39\u8005\u7ec4\u6a21\u5f0f，\u652f\u6301\u591a\u6d88\u8d39\u8005\u534f\u540c\u6d88\u8d39，\u901a\u8fc7 XACK \u786e\u8ba4\u6d88\u606f<\/td>\n<\/tr>\n \n \u6301\u4e45\u5316<\/td>\n \u652f\u6301（Redis \u6301\u4e45\u5316\u673a\u5236\u4fdd\u969c）<\/td>\n \u4e0d\u652f\u6301（\u6d88\u606f\u65e0\u6301\u4e45\u5316，\u8ba2\u9605\u8005\u79bb\u7ebf\u540e\u6d88\u606f\u4e22\u5931）<\/td>\n \u652f\u6301（Stream \u6570\u636e\u6301\u4e45\u5316\u5230\u78c1\u76d8）<\/td>\n \u652f\u6301（Stream \u6570\u636e\u6301\u4e45\u5316，\u6d88\u8d39\u8005\u7ec4\u72b6\u6001\u4e5f\u6301\u4e45\u5316）<\/td>\n<\/tr>\n \n \u6d88\u606f\u53ef\u9760\u6027<\/td>\n \u4e00\u822c（\u6d88\u8d39\u8005\u5b95\u673a\u53ef\u80fd\u5bfc\u81f4\u672a\u5904\u7406\u6d88\u606f\u4e22\u5931，\u9700\u989d\u5916\u673a\u5236\u4fdd\u969c）<\/td>\n \u5dee（\u6d88\u606f\u4e0d\u6301\u4e45\u5316，\u8ba2\u9605\u8005\u79bb\u7ebf\u5373\u4e22\u5931）<\/td>\n \u9ad8（\u6d88\u606f\u6301\u4e45\u5316，\u53ef\u901a\u8fc7\u6e38\u6807\u56de\u6eaf）<\/td>\n \u6781\u9ad8（\u6d88\u8d39\u8005\u7ec4\u7ef4\u62a4\u72b6\u6001，\u6d88\u606f\u786e\u8ba4\u673a\u5236\u4fdd\u969c\u4e0d\u4e22\u5931\u3001\u4e0d\u91cd\u590d）<\/td>\n<\/tr>\n \n \u6d88\u8d39\u6a21\u5f0f<\/td>\n \u5355\u6d88\u8d39\u8005\u7ade\u4e89\u6d88\u8d39（\u4e00\u4e2a\u6d88\u606f\u53ea\u80fd\u88ab\u4e00\u4e2a\u6d88\u8d39\u8005\u5904\u7406）<\/td>\n \u591a\u6d88\u8d39\u8005\u5e7f\u64ad\u6d88\u8d39（\u4e00\u4e2a\u6d88\u606f\u4f1a\u88ab\u6240\u6709\u8ba2\u9605\u8005\u63a5\u6536）<\/td>\n \u5355\u6d88\u8d39\u8005\u6216\u591a\u6d88\u8d39\u8005\u91cd\u590d\u6d88\u8d39（\u591a\u4e2a\u6d88\u8d39\u8005\u7528\u76f8\u540c\u6e38\u6807\u4f1a\u6536\u5230\u91cd\u590d\u6d88\u606f）<\/td>\n \u591a\u6d88\u8d39\u8005\u5206\u6d41\u6d88\u8d39（\u4e00\u4e2a\u6d88\u606f\u4ec5\u88ab\u7ec4\u5185\u4e00\u4e2a\u6d88\u8d39\u8005\u5904\u7406，\u652f\u6301\u8d1f\u8f7d\u5747\u8861）<\/td>\n<\/tr>\n \n \u6d88\u606f\u56de\u6eaf<\/td>\n \u4ec5\u652f\u6301\u6309\u961f\u5217\u987a\u5e8f\u4ece\u5934 \/ \u5c3e\u8bfb\u53d6，\u65e0\u6e38\u6807\u56de\u6eaf\u80fd\u529b<\/td>\n \u65e0\u56de\u6eaf\u80fd\u529b（\u8ba2\u9605\u8005\u53ea\u80fd\u6536\u5230\u8ba2\u9605\u540e\u7684\u65b0\u6d88\u606f）<\/td>\n \u652f\u6301（\u901a\u8fc7\u6e38\u6807\u53ef\u4ee5\u4ece\u4efb\u610f\u4f4d\u7f6e\u5f00\u59cb\u8bfb\u53d6\u5386\u53f2\u6d88\u606f）<\/td>\n \u652f\u6301（\u6d88\u8d39\u8005\u7ec4\u7ef4\u62a4\u6700\u540e\u5904\u7406\u4f4d\u7f6e，\u5b95\u673a\u91cd\u542f\u540e\u53ef\u4ece\u65ad\u70b9\u7ee7\u7eed）<\/td>\n<\/tr>\n \n \u8d1f\u8f7d\u5747\u8861<\/td>\n \u4f9d\u8d56\u5ba2\u6237\u7aef\u81ea\u884c\u5b9e\u73b0\u7ade\u4e89\u6d88\u8d39，\u5929\u7136\u5177\u5907\u4e00\u5b9a\u8d1f\u8f7d\u5747\u8861\u80fd\u529b<\/td>\n \u4e0d\u652f\u6301（\u6d88\u606f\u5e7f\u64ad\u7ed9\u6240\u6709\u8ba2\u9605\u8005，\u65e0\u6cd5\u5206\u6d41）<\/td>\n \u4e0d\u652f\u6301（\u591a\u6d88\u8d39\u8005\u4f1a\u6536\u5230\u91cd\u590d\u6d88\u606f）<\/td>\n \u652f\u6301（\u6d88\u606f\u81ea\u52a8\u5206\u6d41\u7ed9\u7ec4\u5185\u4e0d\u540c\u6d88\u8d39\u8005）<\/td>\n<\/tr>\n \n \u6d88\u606f\u786e\u8ba4\u673a\u5236<\/td>\n \u65e0\u539f\u751f\u786e\u8ba4\u673a\u5236，\u9700\u81ea\u884c\u5b9e\u73b0 ACK<\/td>\n \u65e0<\/td>\n \u65e0\u539f\u751f\u786e\u8ba4\u673a\u5236，\u9700\u81ea\u884c\u7ef4\u62a4\u6d88\u8d39\u8fdb\u5ea6<\/td>\n \u539f\u751f\u652f\u6301\u00a0XACK\u00a0\u786e\u8ba4，\u6d88\u606f\u5904\u7406\u5b8c\u6210\u540e\u624d\u4f1a\u4ece pending-list \u79fb\u9664<\/td>\n<\/tr>\n \n \u9002\u7528\u573a\u666f<\/td>\n \u7b80\u5355\u7684\u4efb\u52a1\u961f\u5217\u3001\u4f4e\u5e76\u53d1\u573a\u666f<\/td>\n \u5b9e\u65f6\u901a\u77e5\u3001\u65e5\u5fd7\u5e7f\u64ad\u7b49\u4e0d\u8981\u6c42\u53ef\u9760\u6027\u7684\u573a\u666f<\/td>\n \u9700\u8981\u6301\u4e45\u5316\u3001\u652f\u6301\u56de\u6eaf\u7684\u5355\u6d88\u8d39\u8005\u6216\u91cd\u590d\u6d88\u8d39\u573a\u666f<\/td>\n \u9ad8\u53ef\u9760\u3001\u9ad8\u5e76\u53d1\u7684\u5206\u5e03\u5f0f\u6d88\u8d39\u573a\u666f，\u5982\u8ba2\u5355\u5904\u7406\u3001\u65e5\u5fd7\u5206\u6d41\u7b49<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n \u56db\u3001\u57fa\u4e8eRedis\u6d88\u606f\u961f\u5217\u5b9e\u73b0\u5f02\u6b65\u79d2\u6740<\/h2>\n
4.1 \u4fee\u6539lua\u811a\u672c<\/h3>\n
\n— 1.1.\u4f18\u60e0\u5238id
\nlocal voucherId = ARGV[1]
\n— 1.2.\u7528\u6237id
\nlocal userId = ARGV[2]
\n— 1.3.\u8ba2\u5355id
\nlocal orderId = ARGV[3]<\/p>\n
\n— 2.1.\u5e93\u5b58key
\nlocal stockKey = 'seckill:stock:' .. voucherId
\n— 2.2.\u8ba2\u5355key
\nlocal orderKey = 'seckill:order:' .. voucherId<\/p>\n
\n— 3.1.\u5224\u65ad\u5e93\u5b58\u662f\u5426\u5145\u8db3 get stockKey
\nif(tonumber(redis.call('get', stockKey)) <= 0) then
\n — 3.2.\u5e93\u5b58\u4e0d\u8db3，\u8fd4\u56de1
\n return 1
\nend
\n— 3.2.\u5224\u65ad\u7528\u6237\u662f\u5426\u4e0b\u5355 SISMEMBER orderKey userId
\nif(redis.call('sismember', orderKey, userId) == 1) then
\n — 3.3.\u5b58\u5728，\u8bf4\u660e\u662f\u91cd\u590d\u4e0b\u5355，\u8fd4\u56de2
\n return 2
\nend
\n— 3.4.\u6263\u5e93\u5b58 incrby stockKey -1
\nredis.call('incrby', stockKey, -1)
\n— 3.5.\u4e0b\u5355（\u4fdd\u5b58\u7528\u6237）sadd orderKey userId
\nredis.call('sadd', orderKey, userId)
\n— 3.6.\u53d1\u9001\u6d88\u606f\u5230\u961f\u5217\u4e2d， XADD stream.orders * k1 v1 k2 v2 …
\nredis.call('xadd', 'stream.orders', '*', 'userId', userId, 'voucherId', voucherId, 'id', orderId)
\nreturn 0 <\/p>\n4.2 \u521b\u5efa\u6d88\u606f\u961f\u5217<\/h3>\n
4.3 \u4ee3\u7801\u5b9e\u73b0<\/h3>\n
\npublic class VoucherOrderServiceImpl extends ServiceImpl<VoucherOrderMapper, VoucherOrder> implements IVoucherOrderService {<\/p>\n
\n private ISeckillVoucherService seckillVoucherService;
\n @Autowired
\n private RedisIdWorker redisIdWorker;
\n @Autowired
\n private StringRedisTemplate stringRedisTemplate;<\/p>\n
\n private static final DefaultRedisScript<Long> SECKILL_SCRIPT ;
\n static {
\n SECKILL_SCRIPT = new DefaultRedisScript<>();
\n SECKILL_SCRIPT.setLocation(new ClassPathResource("seckill.lua"));
\n SECKILL_SCRIPT.setResultType(Long.class);
\n }<\/p>\n
\n private static final ExecutorService SECKILL_ORDER_EXECUTOR = Executors.newSingleThreadExecutor();<\/p>\n
\n @PostConstruct
\n private void init() {
\n SECKILL_ORDER_EXECUTOR.submit(new VoucherOrderHandler());
\n }<\/p>\n
\n @Transactional
\n public Long seckillVoucher(Long voucherId) {
\n \/\/ 1.\u67e5\u8be2\u4f18\u60e0\u5238
\n SeckillVoucher voucher = seckillVoucherService.getById(voucherId);
\n \/\/ 2.\u5224\u65ad\u79d2\u6740\u662f\u5426\u5f00\u59cb
\n if (voucher.getBeginTime().isAfter(LocalDateTime.now())) {
\n \/\/ \u5c1a\u672a\u5f00\u59cb
\n throw new BaseException(ExceptionConstants.NOT_START);
\n }
\n \/\/ 3.\u5224\u65ad\u79d2\u6740\u662f\u5426\u5df2\u7ecf\u7ed3\u675f
\n if (voucher.getEndTime().isBefore(LocalDateTime.now())) {
\n \/\/ \u5c1a\u672a\u5f00\u59cb
\n throw new BaseException(ExceptionConstants.IS_END);
\n }
\n \/\/ 4.\u5224\u65ad\u5e93\u5b58\u662f\u5426\u5145\u8db3
\n if (voucher.getStock() < 1) {
\n \/\/ \u5e93\u5b58\u4e0d\u8db3
\n throw new BaseException(ExceptionConstants.NOT_ENOUGH);
\n }
\n \/\/ 6.\u6267\u884clua\u811a\u672c
\n Long userId = UserHolder.getUser().getId();
\n long orderId = redisIdWorker.nextId("order");
\n Long result = stringRedisTemplate.execute(
\n SECKILL_SCRIPT,
\n Collections.emptyList(),
\n voucherId.toString(), userId.toString(), String.valueOf(orderId)
\n );
\n int r = result.intValue();
\n if (r == NumberConstants.NOT_ENOUGH){
\n \/\/ 7.\u5224\u65ad\u5e93\u5b58\u662f\u5426\u5145\u8db3
\n throw new BaseException(ExceptionConstants.NOT_ENOUGH);
\n } else if (r == NumberConstants.EXIST_BUY) {
\n \/\/ 8.\u7528\u6237\u5df2\u7ecf\u8d2d\u4e70\u8fc7\u4e86
\n throw new BaseException(ExceptionConstants.EXIST_BUY);
\n }
\n \/\/9.\u8fd4\u56de\u8ba2\u5355id
\n return orderId;
\n }<\/p>\n
\n public void createVoucherOrder(VoucherOrder voucherOrder) {
\n Long userId = voucherOrder.getUserId();
\n \/\/ 1.\u67e5\u8be2\u8ba2\u5355
\n int count = query().eq("user_id", userId).eq("voucher_id", voucherOrder.getVoucherId()).count();
\n \/\/ 2.\u5224\u65ad\u662f\u5426\u5b58\u5728
\n if (count > 0) {
\n \/\/ \u7528\u6237\u5df2\u7ecf\u8d2d\u4e70\u8fc7\u4e86
\n throw new BaseException(ExceptionConstants.EXIST_BUY);
\n }
\n \/\/ 2.\u6263\u51cf\u5e93\u5b58
\n boolean success = seckillVoucherService.update()
\n .setSql("stock = stock – 1") \/\/ set stock = stock – 1
\n .eq("voucher_id", voucherOrder.getVoucherId()).gt("stock", 0) \/\/ where id = ? and stock > 0
\n .update();
\n if (!success) {
\n \/\/ \u6263\u51cf\u5931\u8d25
\n throw new BaseException(ExceptionConstants.NOT_ENOUGH);
\n }
\n save(voucherOrder);
\n }
\n}<\/p>\n
\n@Component
\npublic class VoucherOrderHandler implements Runnable {<\/p>\n
\n private IVoucherOrderService voucherOrderService;
\n @Autowired
\n private RedissonClient redissonClient;
\n @Autowired
\n private StringRedisTemplate stringRedisTemplate;<\/p>\n
\n public void run() {
\n while (true) {
\n try {
\n \/\/ 1.\u83b7\u53d6\u6d88\u606f\u961f\u5217\u4e2d\u7684\u8ba2\u5355\u4fe1\u606f XREADGROUP GROUP g1 c1 COUNT 1 BLOCK 2000 STREAMS s1 >
\n List<MapRecord<String, Object, Object>> list = stringRedisTemplate.opsForStream().read(
\n Consumer.from("g1", "c1"),
\n StreamReadOptions.empty().count(1).block(Duration.ofSeconds(2)),
\n StreamOffset.create("stream.orders", ReadOffset.lastConsumed())
\n );
\n \/\/ 2.\u5224\u65ad\u8ba2\u5355\u4fe1\u606f\u662f\u5426\u4e3a\u7a7a
\n if (list == null || list.isEmpty()) {
\n \/\/ \u5982\u679c\u4e3anull，\u8bf4\u660e\u6ca1\u6709\u6d88\u606f，\u7ee7\u7eed\u4e0b\u4e00\u6b21\u5faa\u73af
\n continue;
\n }
\n \/\/ \u89e3\u6790\u6570\u636e
\n MapRecord<String, Object, Object> record = list.get(0);
\n Map<Object, Object> value = record.getValue();
\n VoucherOrder voucherOrder = BeanUtil.fillBeanWithMap(value, new VoucherOrder(), true);
\n \/\/3.\u83b7\u53d6\u7528\u6237
\n Long userId = voucherOrder.getUserId();
\n \/\/ 4.\u521b\u5efa\u9501\u5bf9\u8c61
\n String key = RedisConstants.getLockOrderKey(userId);
\n \/\/ 5.\u5c1d\u8bd5\u83b7\u53d6\u9501
\n RLock lock = redissonClient.getLock(key);
\n try {
\n boolean isLock = lock.tryLock();
\n \/\/ 6.\u5224\u65ad\u662f\u5426\u83b7\u5f97\u9501\u6210\u529f
\n if (!isLock) {
\n \/\/ \u83b7\u53d6\u9501\u5931\u8d25，\u76f4\u63a5\u8fd4\u56de\u5931\u8d25\u6216\u8005\u91cd\u8bd5
\n throw new BaseException(ExceptionConstants.EXIST_BUY);
\n }
\n voucherOrderService.createVoucherOrder(voucherOrder);
\n \/\/ 7.\u786e\u8ba4\u6d88\u606f XACK
\n stringRedisTemplate.opsForStream().acknowledge("s1", "g1", record.getId());
\n } finally {
\n \/\/ \u91ca\u653e\u9501
\n lock.unlock();
\n }
\n } catch (Exception e) {
\n log.error("\u5904\u7406\u8ba2\u5355\u5f02\u5e38", e);
\n \/\/\u5904\u7406\u5f02\u5e38\u6d88\u606f
\n handlePendingList();
\n }
\n }
\n }<\/p>\n
\n while (true) {
\n try {
\n \/\/ 1.\u83b7\u53d6pending-list\u4e2d\u7684\u8ba2\u5355\u4fe1\u606f XREADGROUP GROUP g1 c1 COUNT 1 BLOCK 2000 STREAMS s1 0
\n List<MapRecord<String, Object, Object>> list = stringRedisTemplate.opsForStream().read(
\n Consumer.from("g1", "c1"),
\n StreamReadOptions.empty().count(1),
\n StreamOffset.create("stream.orders", ReadOffset.from("0"))
\n );
\n \/\/ 2.\u5224\u65ad\u8ba2\u5355\u4fe1\u606f\u662f\u5426\u4e3a\u7a7a
\n if (list == null || list.isEmpty()) {
\n \/\/ \u5982\u679c\u4e3anull，\u8bf4\u660e\u6ca1\u6709\u5f02\u5e38\u6d88\u606f，\u7ed3\u675f\u5faa\u73af
\n break;
\n }
\n \/\/ \u89e3\u6790\u6570\u636e
\n MapRecord<String, Object, Object> record = list.get(0);
\n Map<Object, Object> value = record.getValue();
\n VoucherOrder voucherOrder = BeanUtil.fillBeanWithMap(value, new VoucherOrder(), true);
\n \/\/3.\u83b7\u53d6\u7528\u6237
\n Long userId = voucherOrder.getUserId();
\n \/\/ 4.\u521b\u5efa\u9501\u5bf9\u8c61
\n String key = RedisConstants.getLockOrderKey(userId);
\n \/\/ 5.\u5c1d\u8bd5\u83b7\u53d6\u9501
\n RLock lock = redissonClient.getLock(key);
\n try {
\n boolean isLock = lock.tryLock();
\n \/\/ 6.\u5224\u65ad\u662f\u5426\u83b7\u5f97\u9501\u6210\u529f
\n if (!isLock) {
\n \/\/ \u83b7\u53d6\u9501\u5931\u8d25，\u76f4\u63a5\u8fd4\u56de\u5931\u8d25\u6216\u8005\u91cd\u8bd5
\n throw new BaseException(ExceptionConstants.EXIST_BUY);
\n }
\n voucherOrderService.createVoucherOrder(voucherOrder);
\n \/\/ 7.\u786e\u8ba4\u6d88\u606f XACK
\n stringRedisTemplate.opsForStream().acknowledge("s1", "g1", record.getId());
\n } finally {
\n \/\/ \u91ca\u653e\u9501
\n lock.unlock();
\n }
\n } catch (Exception e) {
\n log.error("\u5904\u7406pendding\u8ba2\u5355\u5f02\u5e38", e);
\n try {
\n Thread.sleep(20);
\n } catch (Exception ex) {
\n ex.printStackTrace();
\n }
\n }
\n }
\n }
\n} <\/p>\n4.4 \u6d41\u7a0b\u56fe<\/h3>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260209060534-6989792e63e2d.png\")
<\/p>\n","protected":false},"excerpt":{"rendered":"
\n1.1 \u5355\u673a\u79d2\u6740\u5b9e\u73b0
\n\u57fa\u4e8e Redis \u7684\u79d2\u6740\u5355\u673a\u7cfb\u7edf\u8fed\u4ee3\u5b9e\u73b0（\u9644\u8be6\u7ec6\u6d41\u7a0b\u56fe）-CSDN\u535a\u5ba2
\n1.2 SETNX\u5b9e\u73b0\u96c6\u7fa4\u6a21\u5f0f\u4e0b
\n\u57fa\u4e8e Redis \u7684\u79d2\u6740\u96c6\u7fa4\u7cfb\u7edf\u8fed\u4ee3\u5b9e\u73b0\u3010SETNX\u3011（\u9644\u8be6\u7ec6\u6d41\u7a0b\u56fe）-CSDN\u535a\u5ba2
\n1.3 Redisson\u9501\u5b9e\u73b0
\n\u57fa\u4e8e Redis \u7684\u79d2\u6740\u96c6\u7fa4\u7cfb\u7edf\u8fed\u4ee3\u5b9e\u73b0\u3010Redisson\u6e90\u7801\u5206\u6790\u3011（\u9644\u8be6\u7ec6\u6d41\u7a0b\u56fe）-CSDN\u535a\u5ba2
\n1.4 \u524d\u7f6e\u6d41\u7a0b\u56fe \u4e8c<\/p>\n","protected":false},"author":2,"featured_media":74238,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[99,105,292,586,100,4647,1155],"topic":[],"class_list":["post-74243","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-java","tag-redis","tag-292","tag-586","tag-100","tag-4647","tag-1155"],"yoast_head":"\n