redis抢购mysql_Redis两种秒杀抢购思路_weixin_39934085的博客-程序员宅基地

技术标签: redis抢购mysql  

方式一:使用DECR减库存

/**

* 外卡进入减库存

* @param competitionQuarterInDTO

* @return

*/

@Override

public int otherCardEnter(CompetitionQuarterInDTO competitionQuarterInDTO) throws IOL8ServiceException, IOL8CommonException {

if(NumberUtils.isNumberNull(competitionQuarterInDTO.getCompetitionQuarter())

|| StringUtils.isBlank(competitionQuarterInDTO.getTranslatorId())){

throw IOL8ServiceExceptionBuilder.exceptionBuilder().createException(ErrorCode.ERROR_CODE_240002);

}

Jedis jedis = null;

try{

JedisPool pool = JedisUtils.getJedisPool();

jedis = pool.getResource();

Integer num = getPassStock(jedis, competitionQuarterInDTO.getCompetitionQuarter());

if(num > 0){

Integer isEnter = (Integer)redisTemplate.opsForHash().get(RedisConstants.TRANSLATOR_PREHEAT_PASS_STOCK, competitionQuarterInDTO.getTranslatorId());

if(isEnter == null){

redisTemplate.opsForHash().put(RedisConstants.TRANSLATOR_PREHEAT_PASS_STOCK, competitionQuarterInDTO.getTranslatorId(), 1);

jedis.decrBy(RedisConstants.PREHEAT_PASS_STOCK, 1);

}

} else {

throw IOL8ServiceExceptionBuilder.exceptionBuilder().createException(ErrorCode.ERROR_CODE_241001);

}

} finally {

JedisUtils.closeResource(jedis);

}

return 1;

}

/**

* 获取pass卡剩余库存

* @return

*/

private Integer getPassStock(Jedis jedis, Long competitionQuarter){

String preheatPassStock = jedis.get(RedisConstants.PREHEAT_PASS_STOCK);

Integer num = 0;

//第一次获取外卡,取库存放入缓存

if(preheatPassStock == null || StringUtils.isBlank(preheatPassStock)){

CompetitionQuarter competitionQuarterResult = competitionQuarterMapper.selectByPrimaryKey(competitionQuarter);

jedis.set(RedisConstants.PREHEAT_PASS_STOCK, competitionQuarterResult.getPassStock().toString());

num = competitionQuarterResult.getPassStock();

} else {

num = Integer.valueOf(preheatPassStock);

}

return num;

}

方式二:使用Redis Watch

1、使用watch,采用乐观锁

2、不使用悲观锁,因为等待时间非常长,响应慢

3、不使用队列,因为并发量会让队列内存瞬间升高

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import redis.clients.jedis.Jedis;

/**

* redis测试抢购

*

*@author 10255_000

*

*/

public class RedisTest {

public static void main(String[] args) {

final String watchkeys = "watchkeys";

ExecutorService executor = Executors.newFixedThreadPool(20);

final Jedis jedis = new Jedis("192.168.3.202", 6379);

jedis.set(watchkeys, "0");// 重置watchkeys为0

jedis.del("setsucc", "setfail");// 清空抢成功的,与没有成功的

jedis.close();

for (int i = 0; i < 10000; i++) {// 测试一万人同时访问

executor.execute(new MyRunnable());

}

executor.shutdown();

}

}

import java.util.List;

import java.util.UUID;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.Transaction;

public class MyRunnable implements Runnable {

String watchkeys = "watchkeys";// 监视keys

Jedis jedis = new Jedis("192.168.3.202", 6379);

public MyRunnable() {

}

@Override

public void run() {

try {

jedis.watch(watchkeys);// watchkeys

String val = jedis.get(watchkeys);

int valint = Integer.valueOf(val);

String userifo = UUID.randomUUID().toString();

if (valint < 10) {

Transaction tx = jedis.multi();// 开启事务

tx.incr("watchkeys");

List list = tx.exec();// 提交事务,如果此时watchkeys被改动了,则返回null

if (list != null) {

System.out.println("用户:" + userifo + "抢购成功,当前抢购成功人数:"

+ (valint + 1));

/* 抢购成功业务逻辑 */

jedis.sadd("setsucc", userifo);

} else {

System.out.println("用户:" + userifo + "抢购失败");

/* 抢购失败业务逻辑 */

jedis.sadd("setfail", userifo);

}

} else {

System.out.println("用户:" + userifo + "抢购失败");

jedis.sadd("setfail", userifo);

// Thread.sleep(500);

return;

}

} catch (Exception e) {

e.printStackTrace();

} finally {

jedis.close();

}

}

}

Redis对事物的支持目前比较简单。Redis只能保证一个client发起的事务中的命令可以连续的执行,但后面命令出错前面不会回滚。而中间不会插入其他client的命令。当一个client在找一个连续中发出multi命令时,这个链接会进入一个事务上下文,该链接后续的命令不会立即执行,而是先放到队列中,当执行exec命令是,redis会顺序的执行队列中的所有命令。当如果队列中有命令错误,不会回滚。

乐观锁:大多数是基于数据版本(version)的记录机制实现的。即为数据增加一个版本标识,在基于数据库表的版本解决方案中,一般是通过为数据库表添加一个”version”字段来实现读取出数据时,将此版本号一同读出,之后更新时,对此版本号+1。此时,将提交数据的版本号与数据库表对应记录版本号进行比对,如果提交的数据版本号大于数据当前版本号,则予以更新,否则认为是过去数据。

在Redis中,使用watch命令实现乐观锁(watch key):

watch命令会监视给定的key,当exec时,如果监视的key从调用watch后发生过变化,则事务会失败,也可以调用wathc多长监视多个key。这样就可以对指定key加乐观锁了。注意watch的可以是对整个连接有效的。事务也一样。如果连接断开,监视和事务都会被自动清除。当然exec,discard,unwatch命令都会清除连接中的所有监视。

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/weixin_39934085/article/details/113538730

智能推荐

Container Station docker是什么_清@尘的博客-程序员宅基地_container station

DOCKER 是什么?我的定义是:一个可以快速移植,复制配置环境的容器就是你要运行一个服务,需要配置很多环境内容,开发完成后,还要在实体机器上部署。这个docker就是解决部署复制问题的。ssh登录linux修改docker镜像找到docker目录find / -name docker.json修改docker.json配置文件打开docker.json编辑{undefined "registry-mirrors": ["http://hub-mirror.c.163.com","

c++ fatal error LNK1104_weixin_34008933的博客-程序员宅基地

错误 5 fatal error LNK1104: 无法打开文件“..\..\..\..\api\vc6.0\lib\shp_a3.lib”解决方案:程序设置了链接包含   shp_a3.lib 这个文件 但是 目录或文件名不对.编译当然就通不过了方法一: 看看   工程属性   --&amp;gt;   链接   --&amp;gt;  输入   --&amp;gt;   附加依赖项       ...... ...

一球从M米高度自由下落,每次落地后返回原高度的一半,再落下。 它在第N次落地时反弹多高?共经过多少米? 保留两位小数_Filter-lil的博客-程序员宅基地_一球从m米高度自由落下,每次落地后

输入从键盘输入M和N的值。输出它在第N次落地时反弹多高?共经过多少米? 保留两位小数,空格隔开,放在一行。样例输入:1024 10样例输出:1.00 3068.00满分通过的C语言答案:#include&lt;stdio.h&gt;&nbsp;int main(void)&nbsp;{&nbsp;&nbsp;&nbsp; float sum=0,a,m;&nbsp;&nbsp...

安卓机器人做图软件_美图绘画机器人Andy_weixin_39977776的博客-程序员宅基地

美图绘画机器人Andy是美图最新发布的智能功能,是以人工智能为主的新功能,利用虚拟重建技术为你提供全新美图模式,只要上传一张你的自拍照,Andy就能把你的自拍照画出不同风格的插画。绘画机器人Andy和机器重建图片技术美图绘画机器人Andy特点其中,绘画机器人Andy是全球首款将人工智能用于绘画的产品,只要上传自拍,Andy就能把你的自拍照画出不同风格的插画,将很快在美图秀秀上线。而机器重建图片技术...

黑马OC听课笔记(第二天)_科小喵的博客-程序员宅基地

内存中的五大区域栈:存储局部变量 堆:开发人员通过malloc、calloc、realloc函数申请的字节空间 BSS段:存储未被初始化的全局变量、静态变量 数据段(常量区):存储已被初始化的全局变量、静态变量、常量 代码段:存储程序的代码类加载在程序运行过程中,当某个类第一次被访问的时候,类的信息会被加载到代码段中,这个过程叫做类加载。一旦类被加载到代码段中,就不需要重复加载了,直到程序结束才会被释放。在创建对象的时候,肯定是需要访问这个类的。 在声明一个类的时候,CPU需要检查这

随便推点

oracle备份文件恢复,Oracle 从备份的控制文件进行完全恢复_echus'oulas的博客-程序员宅基地

[email protected]#shutdown abort;Oracle 例程已经关闭。[email protected]#[email protected]:~/product/10.2/db_1/dbs&gt; rman target /恢复管理器: Release 11.1.0.6.0 - Production on 星期三 6月 5 23:13:10 2013Copyright (c) 1982, 2007, Oracle....

2018年刑侦科推理试题_z544912284的博客-程序员宅基地

hello各位小伙伴最近过的怎么样有没有按时吃饭,睡觉,敲代码一定要照顾好自己呀~不知道大家前段时间,有没有在朋友圈中收到一份,『2018的刑侦科目推理试题』娜娜偶然在朋友圈中看到过一次~原图奉上,没有看过的小伙伴可以仔细的看一下哈~我看到第一题的反应是题呢?你到给我题呀~连题都不给我~我怎么知道答案~看到第二题我的脑袋已经无法思考一片空白了~这尼玛是什么玩意儿,简直就是一个坑啊,然后我就放弃了。...

linux php添加redis,linux下的redis安装以及php添加redis扩展_黄之昊的博客-程序员宅基地

一、redis的安装win版本详见:下面是linux版本的安装步骤:step1、下载http://redis.io/download下载完后直接make然后make install,注意sudostep2、启动服务&gt;cd redis安装目录/src&gt;./redis-server  //注意,这种是带默认配置启动,如果要带配置使用:&gt;./redis-server redis-co...

androidutilcode使用_AndroidUtilCodeKTX !是时候提升你的开发效率了 !(持续更新中...)..._weixin_39916511的博客-程序员宅基地

前言第一次接触 Kotlin 还是 2017 年,当时 Kotlin 还没扶正,也不是 Android 的官方开发语言。至于我是怎么被安利的,没记错的话,应该是 开源实验室 的 Kotlin 教程。当时身边几乎没有人在学 Kotlin,网上相关的资料也很少,我还翻译了一部分官网文档,写了一本 GitBook 。 当然现在有更好的 Kotlin 语言中文站 了,对于英文基础不是很好的同学,这是一个不...

那些古风_weixin_34319999的博客-程序员宅基地

扶桑画师浅溪,居泰安,喜绘鲤。院前一方荷塘,锦鲤游曳,溪常与嬉戏。溪始觉如梦,奔塘边,但见池水干涸,莲叶皆枯,塘中鲤亦不知所踪。自始至终,未辨眉目,只记襟上层迭莲华,其色魅惑,似血着泪。后有青岩居士闻之,叹曰:魑祟动情,必作灰飞。犹蛾之投火耳,非愚,乃命数也。我愿记忆静止在枯瘦指尖随黄花褪色真爱散落静静地静静搁浅蝉声陪伴着行云流浪回忆的远方其实我看不太懂戏文里咿咿...

【Qt】Qt再学习(十五):关于paintEvent、QPainter学习这一个demo就够了_郭老二的博客-程序员宅基地

1、描述关于绘画事件paintEvent和绘制类QPainter的使用,推荐参考QtCreator中自带的示例basicdrawing。通过这个例子就能掌握QPainter的所有基本用法。下面是这个例子的几张截图:2、关键代码void RenderArea::paintEvent(QPaintEvent * /* event */){ static const QPoint points[4] = { QPoint(10, 80), QPoint(20

推荐文章

热门文章

相关标签