分布式锁实现----单Redisson

引入 Redisson 即可 ,会自动帮我们续期

RedissonClient 和 Redisson 引入一个即可，和版本有关

实现逻辑如下；

public class GrabRedisRedissonServiceImpl implements GrabService {

    @Autowired
    RedissonClient redissonClient;
//	@Autowired
//	Redisson redisson;     
    @Autowired
    OrderService orderService;
    @Override
    public String grabOrder(int orderId , int driverId){
        //生成key
    	String lock = "order_"+(orderId+"");
    	RLock rlock = redissonClient.getLock(lock.intern());
        //RLock lock1 = redisson.getLock(lock.intern());
        try {
            // 此代码默认 设置key 超时时间30秒，过10秒，再延时
            rlock.lock();
                //lock1.lock();
            try {
                TimeUnit.MINUTES.sleep(3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            //lock1.lock();
            System.out.println("司机:"+driverId+" 执行抢单逻辑");
            boolean b = orderService.grab(orderId, driverId);
            if(b) {
            	System.out.println("司机:"+driverId+" 抢单成功");
            }else {
            	System.out.println("司机:"+driverId+" 抢单失败");
            }
        } finally {
        	rlock.unlock();
            //lock1.unlock();
        }
        return null;
    }
}

Redis 配置类

@Component
public class RedisConfig {
    @Bean
    public RedissonClient redissonClient() {
      Config config = new Config();
      config.useSingleServer().setAddress("127.0.0.1:6379").setDatabase(0);

      return Redisson.create(config);
    }

//    @Bean
//    public Redisson redisson(){
//        Config config = new Config();
//        config.useSingleServer().setAddress("redis://localhost:6379").setDatabase(0);
//        return (Redisson) Redisson.create(config);
//    }
}