分布式锁之单个redis---Redisson

绝地灬酷狼 2022-12-29 01:44 43阅读 0赞

1.引入jar包，maven的相关依赖

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
    		
    <dependency>
        <groupId>org.redisson</groupId>
        <artifactId>redisson</artifactId>
        <version>3.3.2</version>
    </dependency>

较低版本的redis用Redisson,较高版本的用RedissonClient

package com.online.taxi.order.config;
    
    import org.redisson.Redisson;
    import org.redisson.api.RedissonClient;
    import org.redisson.config.Config;
    import org.springframework.context.annotation.Bean;
    import org.springframework.stereotype.Component;
    
    
    @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);
        }
    }

分布式锁的实现类 ，需要抢占资源的业务（使用分布式锁的服务都集合在该类中）

package com.online.taxi.order.service.impl;
    
    import java.util.concurrent.TimeUnit;
    
    import org.redisson.Redisson;
    import org.redisson.api.RLock;
    import org.redisson.api.RedissonClient;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.core.StringRedisTemplate;
    import org.springframework.stereotype.Service;
    
    import com.online.taxi.order.lock.MysqlLock;
    import com.online.taxi.order.lock.RedisLock;
    import com.online.taxi.order.service.GrabService;
    import com.online.taxi.order.service.OrderService;
    
    
    @Service("grabRedisRedissonService")
    public class GrabRedisRedissonServiceImpl implements GrabService {
    
    	@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;
        }
    }