乐观锁VS分布式锁实现抢单服务

司机开始接单，乘客填写出发地——目标地，开始下单

service-order模块

1. @Operation(summary="司机抢单")
2. @GetMapping("/robNewOrder/{driverId}/{orderId}")
3. public Result<Boolean> robNewOrder(@PathVariable Long driverId,@PathVariable Long orderId){
4.         return Result.ok(orderInfoServcie.robNewOrder(driverId,orderId));
5. }

复制代码

1. @Override
2. public Boolean robNewOrder(Long driverId,Long orderId){
3.        
4.         /**
5.                 为了防止数据库压力过大，在saveOrderInfo添加订单的时候
6.                 需要向redis添加,redisTemplate.opsForValue().set(RedisConstant.ORDER_ACCEPT_MARK,
7.                                                 "0",RedisConstant.ORDER_ACCEPT_MARK_EXPIRES_TIME,
8.                                                 TimeUnit.MINUTES);
9.         */
10.         if(redisTemplate.hasKey(RedisConstant.ORDER_ACCEPT_MARK)){
11.                 throw new GuiguException(ResultCodeEnum.COB_NEW_ORDER_FAIL);
12.         }
14.         //如果订单存在Redis，则修改订单状态"已经接单"
15.         //修改条件：根据订单id+司机id
16.         LambdaQueryWrapper<OrderInfo> wrapper = new LambdaQueryWrapper<>();
17.         wrapper.eq(orderInfo::getId,orderId);
18.         OrderInfo orderInfo = orderInfoMapper.selectOne(wrapper);
19.        
20.         orderInfo.setStatus(OrderStatus.ACCEPTED.getStats());
21.         orderInfo.setDriverId(driverId);
22.         orderInfo.setAccpetTime(new Date());
23.        
24.         int rows = orderInfoMapper.updateById(orderInfo);
25.         if(rows != 1){
26.                 throw new GuiguException(ResultCodeEnum.COB_NEW_ORDER_FAIL);
27.         }
28.         redisTemplate.delete(RedisConstant.ORDER_ACCEPT_MARK);
29.         return true;
30. }

复制代码

server-order-client远程界说模块

1. @GetMapping("/order/info/robNewOrder/{driverId}/{orderId}")
2. Result<Boolean> robNewOrder(@PathVariable("driverId") Long driverId,@PathVariable("orderId") Long orderId);

复制代码

web调用模块

1. @Operation(summary = "司机抢单")
2. @GuiguLogin()
3. @GetMapping("/robNewOrder/{orderId}")
4. public Result<Boolean> robNewOrder(@PathVariable Long orderId){
5.        
6.         Long driverId = AuthContextHolder.getUserId();
7.         return Result.ok(orderService.robNewOrder(driverId,orderId));
8. }

复制代码

1. @Override
2. public Boolean robNewOrder(Long driverId,Long orderId){
3.         return orderInfoFeignClient.robNewOrder(driverId,orderId).getData();
4. }

复制代码

当地锁VS分布式锁

乐观锁进行对抢单功能的优化

司机抢单 update order_info set status=2,driver_id=?,accept_time=> where id=? and status= 1
其中将status订单状态(等待接单)作为版本号来判断

1. @Override
2. public Boolean robNewOrder(Long driverId,Long orderId){
3.        
4.         /**
5.                 为了防止数据库压力过大，在saveOrderInfo添加订单的时候
6.                 需要向redis添加,redisTemplate.opsForValue().set(RedisConstant.ORDER_ACCEPT_MARK,
7.                                                 "0",RedisConstant.ORDER_ACCEPT_MARK_EXPIRES_TIME,
8.                                                 TimeUnit.MINUTES);
9.         */
10.         if(redisTemplate.hasKey(RedisConstant.ORDER_ACCEPT_MARK)){
11.                 throw new GuiguException(ResultCodeEnum.COB_NEW_ORDER_FAIL);
12.         }
14.         //司机抢单 update order_info set status=2,driver_id=?,accept_time=> where id=? and status= 1
15.         //其中将status订单状态(等待接单)作为版本号来判断
16.         LambdaQueryWrapper<OrderInfo> wrapper = new LambdaQueryWrapper<>();
17.         wrapper.eq(OrderInfo::getId,orderId);
18.         wrapper.eq(OrderInfo::getStatus,OrderStatus.WAITING_ACCEPT.getStatus());//以1作为条件
20.         OrderInfo orderInfo = new OrderInfo();
21.         orderInfo.setStatus(OrderStatus.ACCEPTED.getStatus());//改成2
22.         orderInfo.setDriverId(driverId);
23.         orderInfo.setAcceptTime(new Date());
24.        
25.         int rows = orderInfoMapper.updateById(orderInfo,wrapper);
26.         if(rows != 1){
27.                 throw new GuiguException(ResultCodeEnum.COB_NEW_ORDER_FAIL);
28.         }
29.         redisTemplate.delete(RedisConstant.ORDER_ACCEPT_MARK);
30.         return true;
31. }

复制代码

分布式锁Redisson进行对抢单功能的优化

当地锁的范围

1. @GetMapping("testLock")
2. public Result testLock(){
3.        
4.         testService.testLock();
5.         return Return.ok();
6. }

复制代码

使用synchronized解决并发问题，通过jmeter工具实现模仿测试

1. @Override
2. public synchronized void testLock(){
3.        
4.         String value = redisTemplate.opsForValue().get("num");
5.         if(StringUtils.isBlank(value)){
6.                 return;
7.         }
8.         int num = Integer.parseInt(value);
9.         retisTemplate.opsForValue().set("num",String.valueOf(++num));
10. }

复制代码

通过idea进行对服务的复制，模仿集群场景
通过网关服务进行转发，jmeter进行车市

Redis实现分布式锁

• 通过redis的setnx命令，具有原子性
  

1. @Override
2. public void testLock(){
3.        
4.         //获取锁
5.         Boolean ifAbsent = redisTemplate.opsForValue().setIfAbsent("lock","lock");
6.        
7.         //如果为true，表示获取锁成功
8.         if(ifAbsent){
9.                 String value = redisTemplate.opsForValue().get("num");
10.                 if(StringUtils.isBlank(value)){
11.                         return;
12.                 }
14.                 //释放锁
15.                 redisTemplate.delete("lock");
16.         }else {
17.                 try{
18.                         Thread.sleep(100);
19.                         this.testLock();
20.                 }catch(InterrutedException e){
21.                         e.printStackTrace();
22.                 }
23.         }
24.        
25.        
26. }

复制代码

如果开释锁之前，出现了非常，导致无法开释锁
解决方案：以下两种

• 将redisTemplate.delete(“lock”)开释锁放到finally中
  
• 为锁设置过期时间 redisTemplate.opsForValue().setIfAbsent(“lock”,“lock”,3,Time.SECONDS);
  

如果开释的是别人的锁

解决方案：

• UUID防止锁误删
  

1. @Override
2. public void testLock(){
3.        
4.         String uuid = UUID.randomUUID().toString();
6.         //key   value    过期时间   过期时间的单位
7.         Boolean ifAbsent = redisTemplate.opsForValue().setIfAbsent("lock",uuid,3,TimeUnit.SECONDS);
8.         if(ifAbsent){
9.                 String value = redisTemplate.opsForValue().get("num");
10.                 if(StringUtils.isBlank(value)){
11.                         return;
12.                 }
13.                 int num = Integer.parseInt(value);
14.                 redisTemplate.opsForValue().set("num",String.valueOf(++num));
15.                
16.                 //释放锁
17.                 String redisUUID = redisTemplate.opsForValue().get("lock");
18.                 if(uuid.equals(redisUUID)){
19.                         redisTemplate.delete("lock");
20.                 }
21.                
22.         }else{
23.                 try{
24.                         Thread.sleep(100);
25.                         this.testLock();
26.                 }catch(InterruptedException e){
27.                         e.printStackTrace();
28.                 }
29.         }
30. }

复制代码

判断开释锁后，锁过期自动开释
当2获取锁，1直接开释2的锁了，不能包管原子性

解决方案：

• lua脚本
  

1. @Override
2. public void testLock(){
3.        
4.         String uuid = UUID.randomUUID().toString();
6.         //key   value    过期时间   过期时间的单位
7.         Boolean ifAbsent = redisTemplate.opsForValue().setIfAbsent("lock",uuid,3,TimeUnit.SECONDS);
8.         if(ifAbsent){
9.                 String value = redisTemplate.opsForValue().get("num");
10.                 if(StringUtils.isBlank(value)){
11.                         return;
12.                 }
13.                 int num = Integer.parseInt(value);
14.                 redisTemplate.opsForValue().set("num",String.valueOf(++num));
15.                
16.                 //释放锁（通过lua脚本）
17.                 DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>();
18.                 String script = "if redis.call('get',KEYS[1]) == ARGV[1] then return redis.call('del',KEYS[1]) else return 0 end";
19.                 redisScript.setScriptText(script);
20.                 redisScript.setResultType(Long.class);
21.                 stringRedisTemplate.execute(redisScript,Arrays.asList("lock"),uuid);
22.                
23.         }else{
24.                 try{
25.                         Thread.sleep(100);
26.                         this.testLock();
27.                 }catch(InterruptedException e){
28.                         e.printStackTrace();
29.                 }
30.         }
31. }

复制代码

Redisson实现分布式锁

• 获取锁 redissonClient.getLock(“lock”)
  
• 阻塞一直等待直到获取锁，获取锁之后默认过期时间30s lock.lock()
  
• 获取到锁，锁过期时间10s lock.lock(10,TimeUnit.SECONDS)
  
• 第一个参数获取锁等待时间，第二个参数获取锁过期时间 lock.tryLock(30,10,TimeUnit.SECONDS)
  
• 开释锁 lock.unlock()
  

①、引入依靠redisson
②、设置类

1. @Data
2. @Configuration
3. @ConfigurationProperties(prefix = "spring.data.redis")
4. public class RedissonConfig{
5.        
6.         private String host;
7.         private String password;
8.         private String port;
10.         private int timeout = 3000;
11.         private static String ADDRESS_PREFIX = "redis://";
13.         @Bean
14.         RedissonClient redissonSingle(){
15.                
16.                 Config config = new Config();
17.                 if(!StringUtils.hasText(host)){
18.                         throw new RuntimeException("host is empty");
19.                 }
20.                 SingleServerConfig serverConfig = config.useSingleServer()
21.                                                                                 .setAddress(ADDRESS_PREFIX + THIS.HOST + ":" + port)
22.                                                                                 .setTimeout(this.timeout);
23.                 if(StringUtils.hasText(this.password)){
24.                         serverConfig.setPassword(this.password);
25.                 }       
26.                 return Redisson.create(config);                                       
27.         }
28. }

复制代码

③、添加Redisson分布式锁到司机抢单功能
OrderInfoServiceImpl添加分布式锁

1. @Autowired
2. private RedissonClient redissonClient;
4. @Override
5. public Boolean robNewOrder(Long driverId,Long orderId){
6.        
7.         if(!redisTemplate.hasKey(RedisConstant.ORDER_ACCEPT_MARK)){
8.                 throw new GuiguException(ResultCodeEnum.COB_NEW_ORDER_FAIL);
9.         }
11.         //创建锁
12.         RLock lock = redissonClient.getLock(RedisConstant.ROB_NEW_ORDER_LOCK + orderId);
14.         try{
15.                 //获取锁  等待时间  过期时间  时间单位
16.                 boolean flag = lock.tryLock(10,5,TimeUnit.SECONDS);
17.                
18.                 if(flag){//获取锁成功
19.                         LambdaQueryWrapper<OrderInfo> wrapper = new LambdaQueryWrapper<>();
20.                         wrapper.eq(OrderInfo::getId,orderId);
21.                         OrderInfo orderInfo = orderInfoMapper.selectOne(wrapper);
22.                         orderInfo.setStatus(OrderStatus.ACCEPTED.getStatus());
23.                         orderInfo.setDriverId(driverId);
24.                         orderInfo.setAccpetTime(new Date());
25.                
26.                         int rows = orderInfoMapper.updateById(orderInfo);
27.                         if(rows!=1){
28.                                 throw new GuiguException(ResultCodeEnum.COB_NEW_ORDER_FAIL);
29.                         }
30.                        
31.                         redisTemplate.delete(RedisConstant.ORDER_ACCEPT_MARK);
32.                 }
33.                
34.         }catch(Exception e){
35.                 throw new GuiguException(ResultCodeEnum.COB_NEW_ORDER_FAIL);
36.         }finally{
37.                 //释放锁
38.                 if(lock.isLocked()){
39.                         lock.unlock();
40.                 }
41.         }
42.        
43.         return true;
44. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。