Spring Boot 分布式锁与并发控制的应用场景_Java

spring boot 分布式锁与并发控制

30.1 学习目标与重点提示

学习目标：掌握spring boot分布式锁与并发控制的核心概念与使用方法，包括分布式锁的定义与特点、并发控制的定义与特点、spring boot与分布式锁的集成、spring boot的实际应用场景，学会在实际开发中处理分布式锁与并发控制问题。
重点：分布式锁的定义与特点、并发控制的定义与特点、spring boot与分布式锁的集成、spring boot的实际应用场景。

30.2 分布式锁与并发控制概述

分布式锁与并发控制是java开发中的重要组件，用于处理分布式系统中的并发访问问题。

30.2.1 分布式锁的定义

定义：分布式锁是一种用于在分布式系统中实现资源共享访问控制的机制，确保在同一时间只有一个进程或线程能够访问共享资源。
作用：

防止资源的并发修改。
确保数据的一致性。
提高系统的可靠性。

常见的分布式锁：

redis分布式锁：redis是一种开源的内存数据库，支持分布式锁。
zookeeper分布式锁：zookeeper是一种开源的分布式协调服务，支持分布式锁。
etcd分布式锁：etcd是一种开源的分布式键值存储系统，支持分布式锁。

✅ 结论：分布式锁是一种用于在分布式系统中实现资源共享访问控制的机制，作用是防止资源的并发修改、确保数据的一致性、提高系统的可靠性。

30.2.2 并发控制的定义

定义：并发控制是指在多进程或多线程环境中，控制对共享资源的访问，防止数据不一致和并发冲突。
作用：

防止数据不一致。
防止并发冲突。
提高系统的性能。

常见的并发控制技术：

锁机制：包括悲观锁和乐观锁。
事务机制：包括acid属性。
并发集合：包括concurrenthashmap和copyonwritearraylist。

✅ 结论：并发控制是指在多进程或多线程环境中，控制对共享资源的访问，作用是防止数据不一致、防止并发冲突、提高系统的性能。

30.3 spring boot与分布式锁的集成

spring boot与分布式锁的集成是java开发中的重要内容。

30.3.1 集成redis分布式锁的步骤

定义：集成redis分布式锁的步骤是指使用spring boot与redis分布式锁集成的方法。
步骤：

创建spring boot项目。
添加所需的依赖。
配置redis。
创建分布式锁工具类。
创建业务层。
创建控制器类。
测试应用。

示例：
pom.xml文件中的依赖：

<dependencies>
    <!-- web依赖 -->
    <dependency>
        <groupid>org.springframework.boot</groupid>
        <artifactid>spring-boot-starter-web</artifactid>
    </dependency>
    <!-- redis依赖 -->
    <dependency>
        <groupid>org.springframework.boot</groupid>
        <artifactid>spring-boot-starter-data-redis</artifactid>
    </dependency>
    <!-- 测试依赖 -->
    <dependency>
        <groupid>org.springframework.boot</groupid>
        <artifactid>spring-boot-starter-test</artifactid>
        <scope>test</scope>
    </dependency>
</dependencies>

application.properties文件中的配置：

# 服务器端口
server.port=8080
# redis连接信息
spring.redis.host=localhost
spring.redis.port=6379
spring.redis.password=
spring.redis.database=0

分布式锁工具类：

import org.springframework.beans.factory.annotation.autowired;
import org.springframework.data.redis.core.stringredistemplate;
import org.springframework.stereotype.component;
import java.util.concurrent.timeunit;
@component
public class redislock {
    @autowired
    private stringredistemplate stringredistemplate;
    private static final string lock_key = "product-lock";
    private static final long lock_expire_time = 30; // 锁的过期时间，单位秒
    public boolean trylock(string lockvalue) {
        boolean result = stringredistemplate.opsforvalue().setifabsent(lock_key, lockvalue, lock_expire_time, timeunit.seconds);
        return boolean.true.equals(result);
    }
    public void releaselock(string lockvalue) {
        string value = stringredistemplate.opsforvalue().get(lock_key);
        if (lockvalue.equals(value)) {
            stringredistemplate.delete(lock_key);
        }
    }
}

实体类：

public class product {
    private long id;
    private string productid;
    private string productname;
    private double price;
    private int stock;
    public product() {
    }
    public product(long id, string productid, string productname, double price, int stock) {
        this.id = id;
        this.productid = productid;
        this.productname = productname;
        this.price = price;
        this.stock = stock;
    }
    // getter和setter方法
    public long getid() {
        return id;
    }
    public void setid(long id) {
        this.id = id;
    }
    public string getproductid() {
        return productid;
    }
    public void setproductid(string productid) {
        this.productid = productid;
    }
    public string getproductname() {
        return productname;
    }
    public void setproductname(string productname) {
        this.productname = productname;
    }
    public double getprice() {
        return price;
    }
    public void setprice(double price) {
        this.price = price;
    }
    public int getstock() {
        return stock;
    }
    public void setstock(int stock) {
        this.stock = stock;
    }
    @override
    public string tostring() {
        return "product{" +
                "id=" + id +
                ", productid='" + productid + '\'' +
                ", productname='" + productname + '\'' +
                ", price=" + price +
                ", stock=" + stock +
                '}';
    }
}

repository接口：

import org.springframework.stereotype.repository;
import java.util.arraylist;
import java.util.list;
import java.util.stream.collectors;
@repository
public class productrepository {
    private list<product> products = new arraylist<>();
    public productrepository() {
        products.add(new product(1l, "p001", "手机", 1000.0, 100));
        products.add(new product(2l, "p002", "电脑", 5000.0, 50));
        products.add(new product(3l, "p003", "电视", 3000.0, 80));
        products.add(new product(4l, "p004", "手表", 500.0, 200));
        products.add(new product(5l, "p005", "耳机", 300.0, 150));
    }
    public list<product> getallproducts() {
        return products;
    }
    public product getproductbyid(long id) {
        return products.stream().filter(product -> product.getid().equals(id)).findfirst().orelse(null);
    }
    public void addproduct(product product) {
        product.setid((long) (products.size() + 1));
        products.add(product);
    }
    public void updateproduct(product product) {
        product existingproduct = getproductbyid(product.getid());
        if (existingproduct != null) {
            existingproduct.setproductid(product.getproductid());
            existingproduct.setproductname(product.getproductname());
            existingproduct.setprice(product.getprice());
            existingproduct.setstock(product.getstock());
        }
    }
    public void deleteproduct(long id) {
        products.removeif(product -> product.getid().equals(id));
    }
}

service类：

import org.springframework.beans.factory.annotation.autowired;
import org.springframework.stereotype.service;
import java.util.list;
import java.util.uuid;
@service
public class productservice {
    @autowired
    private productrepository productrepository;
    @autowired
    private redislock redislock;
    public list<product> getallproducts() {
        return productrepository.getallproducts();
    }
    public product getproductbyid(long id) {
        return productrepository.getproductbyid(id);
    }
    public void addproduct(product product) {
        productrepository.addproduct(product);
    }
    public void updateproduct(product product) {
        productrepository.updateproduct(product);
    }
    public void deleteproduct(long id) {
        productrepository.deleteproduct(id);
    }
    public boolean reducestock(long id, int quantity) {
        string lockvalue = uuid.randomuuid().tostring();
        try {
            if (redislock.trylock(lockvalue)) {
                product product = productrepository.getproductbyid(id);
                if (product != null && product.getstock() >= quantity) {
                    product.setstock(product.getstock() - quantity);
                    productrepository.updateproduct(product);
                    return true;
                }
                return false;
            }
            return false;
        } finally {
            redislock.releaselock(lockvalue);
        }
    }
}

控制器类：

import org.springframework.beans.factory.annotation.autowired;
import org.springframework.web.bind.annotation.*;
import java.util.list;
@restcontroller
@requestmapping("/api/products")
public class productcontroller {
    @autowired
    private productservice productservice;
    @getmapping("/")
    public list<product> getallproducts() {
        return productservice.getallproducts();
    }
    @getmapping("/{id}")
    public product getproductbyid(@pathvariable long id) {
        return productservice.getproductbyid(id);
    }
    @postmapping("/add")
    public void addproduct(@requestbody product product) {
        productservice.addproduct(product);
    }
    @putmapping("/edit/{id}")
    public void editproduct(@pathvariable long id, @requestbody product product) {
        product.setid(id);
        productservice.updateproduct(product);
    }
    @deletemapping("/delete/{id}")
    public void deleteproduct(@pathvariable long id) {
        productservice.deleteproduct(id);
    }
    @postmapping("/reducestock/{id}/{quantity}")
    public boolean reducestock(@pathvariable long id, @pathvariable int quantity) {
        return productservice.reducestock(id, quantity);
    }
}

应用启动类：

import org.springframework.boot.springapplication;
import org.springframework.boot.autoconfigure.springbootapplication;
@springbootapplication
public class redislockapplication {
    public static void main(string[] args) {
        springapplication.run(redislockapplication.class, args);
    }
}

测试类：

import org.junit.jupiter.api.test;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.boot.test.context.springboottest;
import org.springframework.boot.test.web.client.testresttemplate;
import org.springframework.boot.web.server.localserverport;
import static org.assertj.core.api.assertions.assertthat;
@springboottest(webenvironment = springboottest.webenvironment.random_port)
class redislockapplicationtests {
    @localserverport
    private int port;
    @autowired
    private testresttemplate resttemplate;
    @test
    void contextloads() {
    }
    @test
    void testgetallproducts() {
        list products = resttemplate.getforobject("http://localhost:" + port + "/api/products/", list.class);
        assertthat(products).hassize(5);
    }
    @test
    void testreducestock() {
        boolean result = resttemplate.postforobject("http://localhost:" + port + "/api/products/reducestock/1/10", null, boolean.class);
        assertthat(result).istrue();
    }
}

✅ 结论：集成redis分布式锁的步骤包括创建spring boot项目、添加所需的依赖、配置redis、创建分布式锁工具类、创建业务层、创建控制器类、测试应用。

30.4 spring boot的实际应用场景

在实际开发中，spring boot分布式锁与并发控制的应用场景非常广泛，如：

实现产品库存的并发扣减。
实现用户账户的并发扣款。
实现订单的并发创建。
实现数据的并发更新。

示例：

import org.springframework.beans.factory.annotation.autowired;
import org.springframework.stereotype.service;
import java.util.list;
import java.util.uuid;
@service
class productservice {
    @autowired
    private productrepository productrepository;
    @autowired
    private redislock redislock;
    public list<product> getallproducts() {
        return productrepository.getallproducts();
    }
    public product getproductbyid(long id) {
        return productrepository.getproductbyid(id);
    }
    public void addproduct(product product) {
        productrepository.addproduct(product);
    }
    public void updateproduct(product product) {
        productrepository.updateproduct(product);
    }
    public void deleteproduct(long id) {
        productrepository.deleteproduct(id);
    }
    public boolean reducestock(long id, int quantity) {
        string lockvalue = uuid.randomuuid().tostring();
        try {
            if (redislock.trylock(lockvalue)) {
                product product = productrepository.getproductbyid(id);
                if (product != null && product.getstock() >= quantity) {
                    product.setstock(product.getstock() - quantity);
                    productrepository.updateproduct(product);
                    return true;
                }
                return false;
            }
            return false;
        } finally {
            redislock.releaselock(lockvalue);
        }
    }
}
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.data.redis.core.stringredistemplate;
import org.springframework.stereotype.component;
import java.util.concurrent.timeunit;
@component
class redislock {
    @autowired
    private stringredistemplate stringredistemplate;
    private static final string lock_key = "product-lock";
    private static final long lock_expire_time = 30;
    public boolean trylock(string lockvalue) {
        boolean result = stringredistemplate.opsforvalue().setifabsent(lock_key, lockvalue, lock_expire_time, timeunit.seconds);
        return boolean.true.equals(result);
    }
    public void releaselock(string lockvalue) {
        string value = stringredistemplate.opsforvalue().get(lock_key);
        if (lockvalue.equals(value)) {
            stringredistemplate.delete(lock_key);
        }
    }
}
import org.springframework.stereotype.repository;
import java.util.arraylist;
import java.util.list;
import java.util.stream.collectors;
@repository
class productrepository {
    private list<product> products = new arraylist<>();
    public productrepository() {
        products.add(new product(1l, "p001", "手机", 1000.0, 100));
        products.add(new product(2l, "p002", "电脑", 5000.0, 50));
        products.add(new product(3l, "p003", "电视", 3000.0, 80));
        products.add(new product(4l, "p004", "手表", 500.0, 200));
        products.add(new product(5l, "p005", "耳机", 300.0, 150));
    }
    public list<product> getallproducts() {
        return products;
    }
    public product getproductbyid(long id) {
        return products.stream().filter(product -> product.getid().equals(id)).findfirst().orelse(null);
    }
    public void addproduct(product product) {
        product.setid((long) (products.size() + 1));
        products.add(product);
    }
    public void updateproduct(product product) {
        product existingproduct = getproductbyid(product.getid());
        if (existingproduct != null) {
            existingproduct.setproductid(product.getproductid());
            existingproduct.setproductname(product.getproductname());
            existingproduct.setprice(product.getprice());
            existingproduct.setstock(product.getstock());
        }
    }
    public void deleteproduct(long id) {
        products.removeif(product -> product.getid().equals(id));
    }
}
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.web.bind.annotation.*;
import java.util.list;
@restcontroller
@requestmapping("/api/products")
class productcontroller {
    @autowired
    private productservice productservice;
    @getmapping("/")
    public list<product> getallproducts() {
        return productservice.getallproducts();
    }
    @getmapping("/{id}")
    public product getproductbyid(@pathvariable long id) {
        return productservice.getproductbyid(id);
    }
    @postmapping("/add")
    public void addproduct(@requestbody product product) {
        productservice.addproduct(product);
    }
    @putmapping("/edit/{id}")
    public void editproduct(@pathvariable long id, @requestbody product product) {
        product.setid(id);
        productservice.updateproduct(product);
    }
    @deletemapping("/delete/{id}")
    public void deleteproduct(@pathvariable long id) {
        productservice.deleteproduct(id);
    }
    @postmapping("/reducestock/{id}/{quantity}")
    public boolean reducestock(@pathvariable long id, @pathvariable int quantity) {
        return productservice.reducestock(id, quantity);
    }
}
@springbootapplication
public class redislockapplication {
    public static void main(string[] args) {
        springapplication.run(redislockapplication.class, args);
    }
}
// 测试类
@springboottest(webenvironment = springboottest.webenvironment.random_port)
class redislockapplicationtests {
    @localserverport
    private int port;
    @autowired
    private testresttemplate resttemplate;
    @test
    void contextloads() {
    }
    @test
    void testgetallproducts() {
        list products = resttemplate.getforobject("http://localhost:" + port + "/api/products/", list.class);
        assertthat(products).hassize(5);
    }
    @test
    void testreducestock() {
        boolean result = resttemplate.postforobject("http://localhost:" + port + "/api/products/reducestock/1/10", null, boolean.class);
        assertthat(result).istrue();
    }
}

输出结果：

访问http://localhost:8080/api/products/：返回所有产品信息。
访问http://localhost:8080/api/products/reducestock/1/10：返回true，表示库存扣减成功。

✅ 结论：在实际开发中，spring boot分布式锁与并发控制的应用场景非常广泛，需要根据实际问题选择合适的分布式锁和并发控制方法。

总结

本章我们学习了spring boot分布式锁与并发控制，包括分布式锁的定义与特点、并发控制的定义与特点、spring boot与分布式锁的集成、spring boot的实际应用场景，学会了在实际开发中处理分布式锁与并发控制问题。其中，分布式锁的定义与特点、并发控制的定义与特点、spring boot与分布式锁的集成、spring boot的实际应用场景是本章的重点内容。从下一章开始，我们将学习spring boot的其他组件、微服务等内容。

到此这篇关于spring boot 分布式锁与并发控制的应用场景的文章就介绍到这了,更多相关spring boot 分布式锁与并发控制内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！

Spring Boot 分布式锁与并发控制的应用场景

2026年03月26日 • Java •我要评论