Zookeeper 4 Zookeeper JavaAPI 操作 4.9 模拟12306 售票案例

news2025/4/17 7:14:03

Zookeeper

【黑马程序员Zookeeper视频教程，快速入门zookeeper技术】

文章目录

- - Zookeeper
  - 4 Zookeeper JavaAPI 操作
  - - 4.9 模拟12306 售票案例
    - - 4.9.1 Curator 实现分布式锁 API
      - 4.9.2 分布式锁案例 - 模拟12306 售票

4 Zookeeper JavaAPI 操作

4.9 模拟12306 售票案例

4.9.1 Curator 实现分布式锁 API

在Curator中有五种锁方案：

InterProcessSemaphoreMutex：分布式排它锁（非可重入锁）
InterProcessMutex：分布式可重入排它锁
InterProcessReadWriteLock：分布式读写锁
InterProcessMultiLock：将多个锁作为单个实体管理的容器
InterProcessSemaphoreV2：共享信号量

4.9.2 分布式锁案例 - 模拟12306 售票

在这里插入图片描述

平时我们用这些，它们其实都不是真正出票的，它们只是代理商

12306 才是真正的出票的

在这里插入图片描述

12306 不多解释，那个请求量，单机…，肯定会搭集群的

在这里插入图片描述

代理商访问 12306，然后12306 访问自己的数据库【当然数据库也会做成集群，对外访问接口一个】

资源在谁那儿，分布式锁就加到谁那儿，所以肯定是在 12306 上加

在这里插入图片描述

引入Zookeeper 后，12306 就可以作为 Zookeeper 的客户端【分布式锁由Zookeeper 提供】

【简单模拟】

先来一个票类

package com.dingjiaxiong.curator;

/**
 * ClassName: Ticket12306
 * date: 2022/11/15 15:18
 *
 * @author DingJiaxiong
 */


public class Ticket12306 implements Runnable{

    private int tickets = 10; //数据库的票数

    @Override
    public void run() {

        //一直对外提供服务
        while (true){
            if (tickets > 0){

                System.out.println(Thread.currentThread() + ":" + tickets);
                tickets --;
            }
        }

    }
}

来一个新的测试类

package com.dingjiaxiong.curator;

/**
 * ClassName: LockTest
 * date: 2022/11/15 15:17
 *
 * @author DingJiaxiong
 */


public class LockTest {

    public static void main(String[] args) {

        Ticket12306 ticket12306 = new Ticket12306();

        //创建客户端【买票的】
        Thread t1 = new Thread(ticket12306,"携程");
        Thread t2 = new Thread(ticket12306,"飞猪");

        t1.start();
        t2.start();
    }
}

现在直接运行就会产生并发问题，看看结果

在这里插入图片描述

很明显这样是不行的

【现在就给它加上分布式锁】

package com.dingjiaxiong.curator;

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
import org.apache.curator.retry.ExponentialBackoffRetry;

import java.util.concurrent.TimeUnit;

/**
 * ClassName: Ticket12306
 * date: 2022/11/15 15:18
 *
 * @author DingJiaxiong
 */


public class Ticket12306 implements Runnable {

    private int tickets = 10; //数据库的票数

    private InterProcessMutex lock;

    public Ticket12306() {

        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);

        CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString("zookeeper的IP :2181")
                .sessionTimeoutMs(60 * 1000)
                .connectionTimeoutMs(15 * 1000)
                .retryPolicy(retryPolicy)
                .build();

        client.start();

        lock = new InterProcessMutex(client, "/lock");
    }

    @Override
    public void run() {

        //一直对外提供服务
        while (true) {
            //加个【获取】锁
            try {
                lock.acquire(3, TimeUnit.SECONDS);
                if (tickets > 0) {

                    System.out.println(Thread.currentThread() + ":" + tickets);
                    tickets--;
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                // 释放锁
                try {
                    lock.release();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }

    }
}