博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
redis使用watch秒杀抢购思路
阅读量:7073 次
发布时间:2019-06-28

本文共 2222 字,大约阅读时间需要 7 分钟。

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();        }    }}

 

转载地址:http://rkkml.baihongyu.com/

你可能感兴趣的文章
【架构】微服务系列文章
查看>>
Eclipse:The superclass javax.servlet.http.HttpServlet was not found on the Java Build Path
查看>>
PAT1005
查看>>
深入理解java的抽象类和接口(转载)
查看>>
HTML元素坐标定位,这些知识点得掌握
查看>>
【服务器环境搭建-Centos】jdk的安装
查看>>
mysql主从复制的配置总结
查看>>
three.js正交投影照相机
查看>>
构建自己的PHP框架--构建模版引擎(1)
查看>>
Linux之一次性安装开发工具:yum groupinstall Development tools
查看>>
dos.orm的事务处理
查看>>
Odoo 二次开发教程(五)-新API的介绍与应用
查看>>
VC++ 一个简单的Log类
查看>>
Java内存模型深度解析:重排序 --转
查看>>
CentOS防火墙iptables的配置方法详解
查看>>
webpack搭建前端一条龙服务
查看>>
1.ASP.NET MVC使用EPPlus,导出数据到Excel中
查看>>
redis学习笔记
查看>>
ios UIApplocation 中APP启动方式
查看>>
推送知识点2
查看>>