当前位置：个人在线分享 > synchronized、Lock本地锁和Redisson分布式锁的简单使用

synchronized、Lock本地锁和Redisson分布式锁的简单使用

作者 : admin 本文共4320个字，预计阅读时间需要11分钟 发布时间： 2024-06-3 共1人阅读

文章目录

  • 概念
  • 准备工作
  • synchronized本地锁演示
  • JUC包的Lock本地锁演示
  • Redisson的RLock分布式锁演示
  • 源码地址
  • 参考来源

概念

redisson是一个简单易用的Redis客户端工具。不仅如此，它还具备分布式锁的功能

准备工作

  • 快速整合SSMP
    请参考我这篇文章 Spring Boot快速整合Spring MVC和Mybatis-Plus，实现基本的增删改查功能
  • 创建一张库存表
CREATE TABLE `t_storage` (
                             `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
                             `product_id` int(11) NOT NULL COMMENT '商品id',
                             `quantity` int(11) NOT NULL COMMENT '商品数量',
                             `flag` tinyint(4) NOT NULL DEFAULT '1' COMMENT '删除标志：0-删除，1-不删除',
                             `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
                             `update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
                             PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COMMENT='库存表';
  • 新增一条测试数据
INSERT INTO `t_storage` (`id`, `product_id`, `quantity`, `flag`, `create_time`, `update_time`) VALUES (1, 1, 1000, 1, '2024-06-01 09:22:56', '2024-06-01 15:17:55');
  • 创建实体类
@Data
@TableName("t_storage")
public class Storage implements Serializable {

    private static final long serialVersionUID = 1L;

    @TableId(value = "id", type = IdType.AUTO)
    private Integer id;
    private Integer productId;
    private Integer quantity;
    private Integer flag;
    private LocalDateTime createTime;
    private LocalDateTime updateTime;
}
  • 创建Mapper
public interface StorageMapper extends BaseMapper<Storage> {
    
}
  • 创建Service
public interface StorageService {
    String reduceStorage(Integer productId);
}

@Service
public class StorageServiceImpl implements StorageService {
    @Autowired
    private StorageMapper storageMapper;
    @Override
    public String reduceStorage(Integer productId) {
        return "库存扣减成功";
    }
}
  • 创建Controller
@RestController
@RequestMapping("/storage")
public class StorageController {
    @Autowired
    private StorageService storageService;

    @GetMapping("/reduceStorage/{productId}")
    public String reduceStorage(@PathVariable Integer productId) {
        return storageService.reduceStorage(productId);
    }
}

  • 下载解压Nginx服务器
    Nginx下载地址

  • 下载解压Jmeter压测工具
    Jmeter下载地址

  • 复制Spring Boot服务模拟集群环境
    synchronized、Lock本地锁和Redisson分布式锁的简单使用插图
    synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(1)
    synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(2)
    synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(3)
    synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(4)

  • 配置Nginx

    • 打开Nginx的conf/nginx.conf配置文件

    • 在http块内新增ip池

      	upstream webservers{
      server  ip:port; # 请写你的ip和端口。如127.0.0.1:10000
      server  ip:port; # 请写你的ip和端口。如127.0.0.1:10001
	}

    • 在server块替换location配置

      location / {
            proxy_pass   http://webservers;
            index  index.html index.htm;
        }

    • 重启Nginx

  • 配置Jmeter

    • 启动Jmeter
      双击 bin/jmeter.bat

    • 添加线程组
      synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(5)

    • 设置线程数和压测时间
      synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(6)

    • 添加http请求配置
      synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(7)

    • 配置Nginx地址和接口地址
      synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(8)

    • 添加一个结果报告
      synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(9)

synchronized本地锁演示

  • 编写代码
    @Override
    public String reduceStorage(Integer productId) {
        // synchronized 本地锁
        synchronized (this) {
            Storage storage = storageMapper.selectOne(new LambdaQueryWrapper<Storage>().eq(Storage::getProductId, productId));
            if (storage.getQuantity() > 0) {
                storage.setQuantity(storage.getQuantity() - 1);
                storageMapper.updateById(storage);
            } else {
                System.out.println("已经没有库存了");
            }
        }
        return "库存扣减成功";
    }
  • 单体环境（只启动其中一个服务）

Jmeter中开启1000个线程并10秒完成压测，数据库库存变为0。所以说单体环境中，synchronized本地锁保证了线程安全
synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(10)

  • 集群环境（启动两个服务）

Jmeter中开启1000个线程并10秒完成压测，数据库库存不再为0。所以说集群环境中，synchronized本地锁不保证线程安全
synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(11)

JUC包的Lock本地锁演示

  • 编写代码
 private final Lock lock = new ReentrantLock();
 @Override
 public String reduceStorage(Integer productId) {
     // Lock 本地锁
     try {
         lock.lock();
         Storage storage = storageMapper.selectOne(new LambdaQueryWrapper<Storage>().eq(Storage::getProductId, productId));
         if (storage.getQuantity() > 0) {
             storage.setQuantity(storage.getQuantity() - 1);
             storageMapper.updateById(storage);
         } else {
             System.out.println("已经没有库存了");
         }
     } finally {
         lock.unlock();
     }
     return "库存扣减成功";
 }
  • 单体环境（只启动其中一个服务）

Jmeter中开启1000个线程并10秒完成压测，数据库库存变为0。所以说单体环境中，Lock本地锁保证了线程安全
synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(12)

  • 集群环境（启动两个服务）

Jmeter中开启1000个线程并10秒完成压测，数据库库存不再为0。所以说集群环境中，Lock本地锁不保证线程安全
synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(13)

Redisson的RLock分布式锁演示

  • 启动Redis
    关于Redis的使用可以参考我的这篇文章 Docker快速安装Redis并实现Spring Boot整合Redis
  • 引入maven依赖
    
    <dependency>
      <groupId>org.redisson</groupId>
      <artifactId>redisson</artifactId>
      <version>3.30.0</version>
    </dependency>
  • 配置Redisson客户端
@Configuration
public class RedissonConfig {
    @Bean
    public RedissonClient redissonClient() {
        // 1. Create config object
        Config config = new Config();
        config.useSingleServer().setAddress("redis://redis_ip:redis_port");
        return Redisson.create(config);
    }
}
  • 编写代码
@Autowired
private RedissonClient redissonClient;
  @Override
public String reduceStorage(Integer productId) {
    // RLock 分布式琐
    RLock rLock = redissonClient.getLock("redissonLock");
    try {
        rLock.lock();
        Storage storage = storageMapper.selectOne(new LambdaQueryWrapper<Storage>().eq(Storage::getProductId, productId));
        if (storage.getQuantity() > 0) {
            storage.setQuantity(storage.getQuantity() - 1);
            storageMapper.updateById(storage);
        } else {
            System.out.println("已经没有库存了");
        }
    } finally {
        rLock.unlock();
    }
    return "库存扣减成功";
}
  • 单体环境（只启动其中一个服务）

Jmeter中开启1000个线程并10秒完成压测，数据库库存变为0。所以说单体环境中，Redisson分布式锁保证了线程安全
synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(14)

  • 集群环境（启动两个服务）

Jmeter中开启1000个线程并10秒完成压测，数据库库存变为0。所以说集群环境中，Redisson分布式锁保证了线程安全
synchronized、Lock本地锁和Redisson分布式锁的简单使用插图(15)

源码地址

git clone http://gitee.com/xiaolin-v-java/redission-demo.git

参考来源

  • Redisson官网
本站无任何商业行为
个人在线分享 » synchronized、Lock本地锁和Redisson分布式锁的简单使用
admin

admin 钻石

分享到：

相关推荐

E-->