springboot中怎么利用redis实现一个秒杀系统

这篇文章将为大家详细讲解有关springboot中怎么利用redis实现一个秒杀系统，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。

创新互联是一家专业提供故城企业网站建设,专注与成都做网站、网站建设、外贸营销网站建设、H5高端网站建设、小程序制作等业务。10年已为故城众多企业、政府机构等服务。创新互联专业网站建设公司优惠进行中。

1. 直接service，我们会介绍两种秒杀模式

public interface GoodsService { /** * 通过lua脚本实现的秒杀 * @param skuCode 商品编码 * @param buyNum 购买数量 * @return 购买数量 */ Long flashSellByLuaScript(String skuCode,int buyNum); /** * 通过redis 事务实现的秒杀 * @param skuCode 商品编码 * @param buyNum 购买数量 * @return 购买数量 */ Long flashSellByRedisWatch(String skuCode,int buyNum);}

2. service实现类

import org.springframework.dao.DataAccessException;import org.springframework.data.redis.core.RedisOperations;import org.springframework.data.redis.core.SessionCallback;import org.springframework.data.redis.core.StringRedisTemplate;import org.springframework.data.redis.core.ValueOperations;import org.springframework.data.redis.core.script.DefaultRedisScript;import org.springframework.data.redis.serializer.RedisSerializer;import org.springframework.stereotype.Service;import javax.annotation.Resource;import java.util.Collections;import java.util.List;@Servicepublic class GoodsServiceImpl implements GoodsService { @Resource private StringRedisTemplate stringRedisTemplate; @Override public Long flashSellByLuaScript(String skuCode,int num) { //下面是lua脚本 String luaScript ="local buyNum = ARGV[1]\n" + "local goodsKey = KEYS[1] \n" + "local goodsNum = redis.call('get',goodsKey) \n" + "if goodsNum >= buyNum \n" + "then redis.call('decrby',goodsKey,buyNum) \n" + "return buyNum \n" + "else \n" + "return '0'\n" + "end\n" + "\n" ; DefaultRedisScript<String> re = new DefaultRedisScript<String>(); //设置脚本 re.setScriptText(luaScript); //定义返回值类型，注意，如果没有这个定义，Spring不会返回结果 re.setResultType(String.class); RedisSerializer<String> stringRedisSerializer = stringRedisTemplate.getStringSerializer(); //执行LUA脚本 String result = (String) stringRedisTemplate.execute(re, stringRedisSerializer, stringRedisSerializer, null); return Long.valueOf(result); } @Override public Long flashSellByRedisWatch(String skuCode,int num){ SessionCallback<Long> sessionCallback = new SessionCallback<Long>() { @Override public Long execute(RedisOperations operations) throws DataAccessException { int result = num; //redis 乐观锁 //我们观察商品编码是否发生改变 operations.watch(skuCode); ValueOperations<String, String> valueOperations = operations.opsForValue(); String goodsNumStr = valueOperations.get(skuCode); Integer goodsNum = Integer.valueOf(goodsNumStr); //标记一个事务块的开始。 //事务块内的多条命令会按照先后顺序被放进一个队列当中， //最后由 EXEC 命令原子性(atomic)地执行。 operations.multi(); if (goodsNum >= num) { valueOperations.increment(skuCode, 0 - num); } else { result = 0; } //多条命令执行的结果集合 List exec = operations.exec(); if(exec.size()>0){ System.out.println(exec); } return (long) result; } }; return stringRedisTemplate.execute(sessionCallback); }//省略其他的方法}

3. controller

但是首先要向你的redis里面仍一个数据，key='xiaomi'，value='100'

@ApiOperation(value = "用事务秒杀测试接口", notes = "用事务秒杀测试接口")@RequestMapping(value = "/miaoTransaction", method = RequestMethod.GET)@ResponseBody public Long miaoTransaction() { Long res = goodsService.flashSellByRedisWatch("xiaomi", 1); return res; } @ApiOperation(value = " 秒杀Lua测试接口", notes = "秒杀Lua测试接口") @RequestMapping(value = "/miaoLua", method = RequestMethod.GET) @ResponseBody public Long miaoLua() { Long res = goodsService.flashSellByRedisWatch("xiaomi", 1); System.out.println(res.toString()); return res; }

关于springboot中怎么利用redis实现一个秒杀系统就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。

文章题目：springboot中怎么利用redis实现一个秒杀系统
本文链接：https://www.cdcxhl.com/article44/jdcehe.html

成都网站建设公司_创新互联，为您提供网站改版、微信小程序、自适应网站、搜索引擎优化、网站建设、用户体验

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容