文档章节

Redis做分布式无锁CAS的问题

算法之名
 算法之名
发布于 07/15 23:51
字数 578
阅读 50
收藏 8

因为Redis本身是单线程的,具备原子性,所以可以用来做分布式无锁的操作,但会有一点小问题。

public interface OrderService {
    public String getOrderNo();
}
public class OrderRedisServiceImpl implements OrderService {
    static JedisPool jedisPool;
    static {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPool = new JedisPool(jedisPoolConfig,"XXX.XXX.XXX.XXX",6379,0);
    }
    @Override
    public String getOrderNo() {
        try {
            Jedis jedis = jedisPool.getResource();
            SimpleDateFormat date = new SimpleDateFormat("YYYYMMDDHHMMSS");
            return date.format(new Date()) + jedis.incr("order_keys");
        }finally {
            jedisPool.close();
        }
    }
}

redis实现的接口

public class OrderTask implements Runnable {
    private CountDownLatch latch;
    private OrderService orderService;
    public OrderTask(CountDownLatch latch,OrderService orderService) {
        this.latch = latch;
        this.orderService = orderService;
    }

    @Override
    public void run() {
        try {
            latch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.printf("线程名%s订单号:%s\n",Thread.currentThread().getName(), orderService.getOrderNo());
    }
}

线程任务类

public static void main(String[] args) {
   ExecutorService service = Executors.newCachedThreadPool();
   final CountDownLatch latch = new CountDownLatch(1);
   OrderService orderService = new OrderRedisServiceImpl();
   for (int i = 0;i < 10;i++) {
      service.submit(new OrderTask(latch,orderService));
   }
   latch.countDown();
   service.shutdown();
}

运行结果如下

线程名pool-2-thread-5订单号:20180719623079251
线程名pool-2-thread-3订单号:20180719623079252
线程名pool-2-thread-4订单号:201807196230710755
线程名pool-2-thread-7订单号:201807196230710754
线程名pool-2-thread-9订单号:201807196230710756
线程名pool-2-thread-2订单号:201807196230710757
线程名pool-2-thread-8订单号:201807196230710753
线程名pool-2-thread-1订单号:201807196230730458

他只跑出了8个结果,我们的确是运行了10次,由此我们记得jedis的默认最大连接数为8,所以只要我们的运行的线程数大于8,也只会跑出8个结果。

所以我们要修改如下

public class OrderRedisServiceImpl implements OrderService {
    static JedisPool jedisPool;
    static {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxIdle(-1);
        jedisPoolConfig.setMaxTotal(-1);
        jedisPool = new JedisPool(jedisPoolConfig,"XXX.XXX.XXX.XXX",6379,0);
    }
    @Override
    public String getOrderNo() {
        try {
            Jedis jedis = jedisPool.getResource();
            SimpleDateFormat date = new SimpleDateFormat("YYYYMMDDHHMMSS");
            return date.format(new Date()) + jedis.incr("order_keys");
        }finally {
            jedisPool.close();
        }
    }
}

把redis连接池的最大连接数增大,运行结果如下

线程名pool-2-thread-4订单号:201807196230758759
线程名pool-2-thread-5订单号:201807196230758860
线程名pool-2-thread-2订单号:201807196230758961
线程名pool-2-thread-3订单号:201807196230758862
线程名pool-2-thread-7订单号:201807196230758763
线程名pool-2-thread-8订单号:201807196230758764
线程名pool-2-thread-10订单号:201807196230758765
线程名pool-2-thread-6订单号:201807196230758866
线程名pool-2-thread-1订单号:201807196230758768
线程名pool-2-thread-9订单号:201807196230759067

这一次就是10个结果了。

© 著作权归作者所有

共有 人打赏支持
算法之名
粉丝 12
博文 94
码字总数 73761
作品 0
广州
Spring-data-redis + redis 分布式锁(二)

分布式锁的解决方式 基于数据库表做乐观锁,用于分布式锁。(适用于小并发) 使用memcached的add()方法,用于分布式锁。 使用memcached的cas()方法,用于分布式锁。(不常用) 使用redis的setnx...

xiaolyuh
2017/11/16
0
0
Spring-data-redis + redis 分布式锁(一)

分布式锁的解决方式 基于数据库表做乐观锁,用于分布式锁。(适用于小并发) 使用memcached的add()方法,用于分布式锁。 使用memcached的cas()方法,用于分布式锁。(不常用) 使用redis的setnx...

xiaolyuh
2017/11/15
0
0
Java高级程序员面试大纲——错过了金三,你还要错过银四吗

跳槽时时刻刻都在发生,但是我建议大家跳槽之前,先想清楚为什么要跳槽。切不可跟风,看到同事一个个都走了,自己也盲目的开始面试起来(期间也没有准备充分),到底是因为技术原因(影响自己...

Java高级架构
04/27
0
0
Memcache和Redis区别

memcache官方定义 Free & open source, high-performance, distributed memory object caching system, generic in nature, but intended for use in speeding up dynamic web applications ......

RJKD
2014/04/29
0
0
Java程序员面试大纲—错过了金三银四,你还要错过2018吗?

跳槽时时刻刻都在发生,但是我建议大家跳槽之前,先想清楚为什么要跳槽。切不可跟风,看到同事一个个都走了,自己也盲目的开始面试起来(期间也没有准备充分),到底是因为技术原因(影响自己...

java高级架构牛人
04/27
0
0

没有更多内容

加载失败,请刷新页面

加载更多

vue组件传值之(父子)

⚠️组件的作用域是孤立的,vue解决组件传值问题是通过props ⚠️子传父的时候需要vm.$emit触发实例上的事件,页面需要定一个方法去取值 ⚠️一定要注意命名方式和书写,例如mylChart和myl-c...

peakedness丶
16分钟前
0
0
SpringBoot开发案例之整合Dubbo分布式服务

前言 在 SpringBoot 很火热的时候,阿里巴巴的分布式框架 Dubbo 不知是处于什么考虑,在停更N年之后终于进行维护了。在之前的微服务中,使用的是当当维护的版本 Dubbox,整合方式也是使用的 ...

微笑向暖wx
30分钟前
0
0
TypeScript基础入门之装饰器(二)

转发 TypeScript基础入门之装饰器(二) 装饰器求值 如何应用装饰器应用于类内的各种声明的顺序: 1. 对每个实例成员应用参数装饰器,后跟Method,Accessor或Property Decorators。 2. 对每个静...

durban
31分钟前
0
0
Java程序员年薪40W是什么水平?税前还是税后?

很多人学Java都是冲着Java的高薪来的,那么搞Java的程序员,年薪40W到底是个什么水平呢,本文达妹和大家一起探讨一下。 前几天在论坛看到这么一个问题,搞Java的程序员年薪40w是什么水平?一...

架构师springboot
36分钟前
1
0
区块链100讲:盘点那些常用的加密算法原理

在开发过程中,常常用到各种加密方法和算法,本文总结了几种常用加密方法的原理。 1 对称加密 原理:加密和解密数据使用同一个密钥,适合对大量数据进行加解密 安全性:关键是密钥的保存方式...

HiBlock
50分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部