文档章节

Redis做分布式无锁CAS的问题

算法之名
 算法之名
发布于 07/15 23:51
字数 578
阅读 33
收藏 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个结果了。

© 著作权归作者所有

共有 人打赏支持
算法之名
粉丝 10
博文 75
码字总数 41827
作品 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

没有更多内容

加载失败,请刷新页面

加载更多

下一页

困扰当前数据中心管理的三大难题

导读 当企业发展到一定程度,或者之前的机房不能满足现在的数据中心使用时,企业会对数据中心进行迁移。那么在数据中心进行迁移的时候会遇到哪些风险呢?针对这些风险我们应该做出怎样的措施来...

问题终结者
16分钟前
0
0
设计模式:工厂方法模式(工厂模式)

工厂方法模式才是真正的工厂模式,前面讲到的静态工厂模式实际上不能说是一种真正意义上的设计模式,只是一种变成习惯。 工厂方法的类图: 这里面涉及到四个种类: 1、抽象产品: Product 2、...

京一
32分钟前
0
0
区块链和数据库,技术到底有何区别?

关于数据库和区块链,总会有很多的困惑。区块链其实是一种数据库,因为他是数字账本,并且在区块的数据结构上存储信息。数据库中存储信息的结构被称为表格。但是,区块链是数据库,数据库可不...

HiBlock
40分钟前
0
0
react native 开发碰到的问题

react-navigation v2 问题 问题: static navigationOptions = ({navigation, navigationOptions}) => ({ headerTitle: ( <Text style={{color:"#fff"}}>我的</Text> ), headerRight: ( <View......

罗培海
47分钟前
0
0
Mac Docker安装流程

久仰Docker大名已久,于是今天趁着有空,尝试了一下Docker 先是从docker的官网上下载下来mac版本的docker安装包,安装很简易,就直接拖图标就好了。 https://www.docker.com/products/docker...

writeademo
55分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部