快捷導(dǎo)航

Springboot使用redisson實(shí)現(xiàn)分布式鎖的代碼示例

更新時(shí)間：2023年06月07日 10:25:12 作者：夜空下的星

在實(shí)際項(xiàng)目中，某些場(chǎng)景下可能需要使用到分布式鎖功能，那么實(shí)現(xiàn)分布式鎖有多種方式，常見(jiàn)的如mysql分布式鎖、zookeeper分布式鎖、redis分布式鎖，本文介紹springboot如何使用redisson實(shí)現(xiàn)分布式鎖,需要的朋友可以參考下

一、前言

在實(shí)際項(xiàng)目中，某些場(chǎng)景下可能需要使用到分布式鎖功能，那么實(shí)現(xiàn)分布式鎖有多種方式，常見(jiàn)的如mysql分布式鎖、zookeeper分布式鎖、redis分布式鎖，從效率上講，redis無(wú)疑是性能最好的，但也會(huì)存在一些問(wèn)題

1.獲取鎖的線程在執(zhí)行任務(wù)的過(guò)程中掛掉，來(lái)不及釋放鎖，這塊資源將會(huì)永遠(yuǎn)被鎖住（死鎖），別的線程再也別想進(jìn)來(lái)，因此我們需要給key加個(gè)過(guò)期時(shí)間，保證這把鎖要在一定時(shí)間后自動(dòng)釋放。

2.高并發(fā)情況下redis分布式鎖永久失效的問(wèn)題（一個(gè)線程可能刪除了別的線程的鎖）
假設(shè)線程 A 可能某些原因執(zhí)行的很慢很慢，到達(dá)過(guò)期時(shí)間都沒(méi)執(zhí)行完，這時(shí)候鎖過(guò)期自動(dòng)釋放，此時(shí)線程 B 得到了鎖；

隨后，線程 A 執(zhí)行完了任務(wù)，線程 A 隨之釋放鎖。但這時(shí)候線程 B 還沒(méi)執(zhí)行完，線程A實(shí)際上刪除的是線程 B加的鎖
解決方法：
可以在釋放鎖之前做一個(gè)判斷，驗(yàn)證當(dāng)前的鎖是不是自己加的鎖

3.可能出現(xiàn)并發(fā)情況
當(dāng)線程 A 執(zhí)行的很慢很慢，到達(dá)過(guò)期時(shí)間都沒(méi)執(zhí)行完，這時(shí)候鎖過(guò)期自動(dòng)釋放，線程 B得到了鎖。此時(shí)就有多個(gè)線程在訪問(wèn)同步代碼塊。
解決方法：我們可以使用redisson實(shí)現(xiàn)，內(nèi)部實(shí)現(xiàn)鎖續(xù)期功能。

二、實(shí)現(xiàn)

1.在springboot中引入redisson依賴(lài)包

 <dependency>
    		<groupId>org.redisson</groupId>
    		<artifactId>redisson-spring-boot-starter</artifactId>
    		<version>3.10.6</version>
		</dependency>

2.配置redisson，代碼如下：

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.ClassPathResource;
@Configuration
public class RedissonConfig {
	@Bean(destroyMethod = "shutdown")
	public RedissonClient redisson() throws IOException{
		//RedissonClient redisson = Redisson.create(Config.fromYAML(new //ClassPathResource("redisson-single.yml").getInputStream()));
		Config config = new Config();
        config.useSingleServer()
        .setAddress("redis://192.168.6.52:6379").setPassword("123456")
        .setRetryInterval(5000)
        .setTimeout(10000)
        .setConnectTimeout(10000);
        return Redisson.create(config);
   }
}

3.我們以商品庫(kù)存為例：

import java.util.concurrent.TimeUnit;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.suntree.entity.Price;
import com.suntree.mapper.PriceMapper;
@Service
public class ProductService {
	@Autowired
	RedissonClient redissonClient;
	@Autowired
	ProductMapper productMapper;
	@Transactional
	public String descreaseProduct(String productId,Integer quanlity) {
		String key="des_product_lock:"+productId;
		RLock lock=redissonClient.getLock(key);
		lock.lock();
		Product product =productMapper.selectById(productId);
		if(product ==null) {
			return "產(chǎn)品未找到";
		}
		String result="";
		try {
			if(product .getQuanlity()==0) {
				return "當(dāng)前數(shù)量為0，不能再扣了??！";
			}
			product .setQuanlity(product .getQuanlity()-1);
			productMapper.updateById(product );
			result = "當(dāng)前數(shù)量：" + product .getQuanlity();
			System.err.println(result);
		}catch (Exception e) {
			System.err.println(e.getMessage());
			throw new RuntimeException("扣庫(kù)存操作失敗了");
		}finally {
			lock.unlock();
		}
		return result;
	}
}

這就是實(shí)現(xiàn)分布式鎖常見(jiàn)場(chǎng)景。

4.接著我們可以在controller層調(diào)用，我們可以模擬多線程操作，看扣庫(kù)存是否會(huì)有問(wèn)題。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.suntree.service.ProductService ;
@RestController
@RequestMapping("/product")
public class ProductController {
	@Autowired
	ProductService productService ;
	@GetMapping("/descrease")
	public String descreaseProduct() {
		return productService .descreaseProduct("2020-2020", 200);
	}
}

大家可以自己嘗試下。

到此這篇關(guān)于Springboot使用redisson實(shí)現(xiàn)分布式鎖的代碼示例的文章就介紹到這了,更多相關(guān)Springboot redisson實(shí)現(xiàn)分布式鎖內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: