文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

怎么用springboot+zookeeper实现分布式锁

2023-06-29 14:51

关注

本篇内容主要讲解“怎么用springboot+zookeeper实现分布式锁”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“怎么用springboot+zookeeper实现分布式锁”吧!

InterProcessMutex内部实现了zookeeper分布式锁的机制,所以接下来我们尝试使用这个工具来为我们的业务加上分布式锁处理的功能

zookeeper分布式锁的特点:1、分布式 2、公平锁 3、可重入

依赖

<dependency>   <groupId>org.apache.zookeeper</groupId>   <artifactId>zookeeper</artifactId>   <version>3.4.10</version></dependency><!-- zookeeper 客户端 --><dependency>   <groupId>org.apache.curator</groupId>   <artifactId>curator-framework</artifactId>   <version>2.12.0</version></dependency><dependency>   <groupId>org.apache.curator</groupId>   <artifactId>curator-recipes</artifactId>   <version>2.12.0</version></dependency><!-- lombok --><dependency>   <groupId>org.projectlombok</groupId>   <artifactId>lombok</artifactId>   <version>1.18.16</version>   <scope>provided</scope></dependency>

本地封装

这个工具类主要封装CuratorFramework这个client(连接Zookeeper)

@Slf4jpublic class CuratorClientUtil {    private String zookeeperServer;    @Getter    private CuratorFramework client;    public CuratorClientUtil(String zookeeperServer) {        this.zookeeperServer = zookeeperServer;    }  // 创建CuratorFrameworkFactory并且启动    public void init() {       // 重试策略,等待1s,最大重试3次        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000,3);        this.client = CuratorFrameworkFactory.builder()                .connectString(zookeeperServer)                .sessionTimeoutMs(5000)                .connectionTimeoutMs(5000)                .retryPolicy(retryPolicy)                .build();        this.client.start();    }   // 容器关闭,CuratorFrameworkFactory关闭    public void destroy() {        try {            if (Objects.nonNull(getClient())) {                getClient().close();            }        } catch (Exception e) {            log.info("CuratorFramework close error=>{}", e.getMessage());        }    }}

配置

@Configurationpublic class CuratorConfigration {    @Value("${zookeeper.server}")    private String zookeeperServer;    // 注入时,指定initMethod和destroyMethod    @Bean(initMethod = "init", destroyMethod = "destroy")    public CuratorClientUtil curatorClientUtil() {        CuratorClientUtil clientUtil = new CuratorClientUtil(zookeeperServer);        return clientUtil;    }}

测试代码

模拟不同客户端的请求

@Slf4j@RestController@RequestMapping("/test")public class TestController {    // 注入client工具类    @Autowired    private CuratorClientUtil curatorClientUtil;    // 在zookeeper的/rootLock节点下创建锁对应的临时有序节点    private String rootLock = "/rootLock";    @GetMapping("/testLock")    public Object testLock() throws Exception {        // 获取当前线程的名字,方便观察那些线程在获取锁        String threadName = Thread.currentThread().getName();        InterProcessMutex mutex = new InterProcessMutex(curatorClientUtil.getClient(), rootLock);        try {            log.info("{}---获取锁start", threadName);            // 尝试获取锁,最长等待3s,超时放弃获取            boolean lockFlag = mutex.acquire(3000, TimeUnit.SECONDS);            // 获取锁成功,进行业务处理            if (lockFlag) {                log.info("{}---获取锁success", threadName);                // 模拟业务处理,时间为3s                Thread.sleep(3000);            } else {                log.info("{}---获取锁fail", threadName);            }        } catch (Exception e) {            log.info("{}---获取锁异常", threadName);        } finally {            // 业务处理完成,释放锁,唤醒比当前线程创建的节点序号大(最靠近)的线程获取锁            mutex.release();            log.info("{}---锁release", threadName);        }        return "线程:" + threadName + "执行完成";    }}

JMeter测试

我们使用JMeter模拟100个客户端同时并发的访问 localhost:8081/test/testLock,相当于100个客户端争抢分布式锁,结果如图右上角所示,100个请求花了5分6s,每个线程获取到锁后业务处理3s,100个线程理想时间为300s(Thread.sleep(3000)),所以运行时间符合。

怎么用springboot+zookeeper实现分布式锁

怎么用springboot+zookeeper实现分布式锁

zookeeper每个线程在/rooLock节点下创建的临时有序节点如下图,由于是临时的,所以线程释放锁后这些节点也会删除

怎么用springboot+zookeeper实现分布式锁

100个线程程序日志打印

怎么用springboot+zookeeper实现分布式锁

到此,相信大家对“怎么用springboot+zookeeper实现分布式锁”有了更深的了解,不妨来实际操作一番吧!这里是编程网网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯