++ 分布式锁控制多线程有序输出【黑马java培训】

更新时间:2019年07月26日 10时48分29秒来源:黑马程序员论坛

当很多进程需要访问共享资源时，我们可以通过zk来实现分布式锁。主要步骤是：
1.建立一个节点，假如名为：lock 。节点类型为持久节点（PERSISTENT）
2.每当进程需要访问共享资源时，会调用分布式锁的lock()或tryLock()方法获得锁，这个时候会在第一步创建的lock节点下建立相应的顺序子节点，节点类型为临时顺序节点（EPHEMERAL_SEQUENTIAL），通过组成特定的名字name+lock+顺序号。
3.在建立子节点后，对lock下面的所有以name开头的子节点进行排序，判断刚刚建立的子节点顺序号是否是最小的节点，假如是最小节点，则获得该锁对资源进行访问。
4.假如不是该节点，就获得该节点的上一顺序节点，并给该节点是否存在注册监听事件。同时在这里阻塞。等待监听事件的发生，获得锁控制权。
5.当调用完共享资源后，调用unlock（）方法，关闭zk，进而可以引发监听事件，释放该锁。
实现的分布式锁是严格的按照顺序访问的并发锁。

以下代码实现：
package com.itheima.jishutie;

public interface ExtLock {

//ExtLock基于zk实现分布式锁
public void  getLock() throws InterruptedException;

//释放锁
public void unLock();

}

package com.itheima.jishutie;

import org.I0Itec.zkclient.ZkClient;

//将重复代码抽象到子类中（模板方法设计模式）
public abstract class ZookeeperAbstractLock implements ExtLock {
public static final String CONNECTION="192.168.12.131:2181";
protected ZkClient zkClient = new ZkClient(CONNECTION);
public  String lockPath="/lockPath";

   //获取锁
   public void getLock() throws InterruptedException {
      //1、连接zkClient 创建一个/lock的临时节点
      // 2、如果节点创建成果，直接执行业务逻辑，如果节点创建失败，进行等待
      if (tryLock()) {
         System.out.println("#####成功获取锁######");
      }else {
         //进行等待
         waitLock();
      }

      //3、使用事件通知监听该节点是否被删除，如果是，重新进入获取锁的资源

}

//创建失败进行等待
abstract void waitLock() throws InterruptedException;

abstract boolean tryLock();


//释放锁
   public void unLock() {
      //执行完毕直接连接
      if (zkClient != null) {
            System.out.println("######释放锁完毕######");
         zkClient.close();

      }

}

}

package com.itheima.jishutie;

import java.util.concurrent.CountDownLatch;

import org.I0Itec.zkclient.IZkDataListener;

public class ZookeeperDistrbuteLock extends ZookeeperAbstractLock {
private static  ThreadLocal<CountDownLatch> countDownLatch = new ThreadLocal<CountDownLatch>() {
      @Override
      protected CountDownLatch initialValue() {
         return new CountDownLatch(1);
      }
};
@Override
boolean tryLock() {
      try {
         zkClient.createEphemeral(lockPath);
//          System.out.println("#########获取锁######");
         return true;
      } catch (Exception e) {
         // 如果失败直接catch
         return false;
      }
}

@Override
void waitLock()  {

      IZkDataListener iZkDataListener = new IZkDataListener() {

         // 节点被删除
         public void handleDataDeleted(String arg0) throws Exception {
            if (countDownLatch.get() != null) {
                  countDownLatch.get().countDown(); // 计数器为0的情况，await 后面的继续执行
            }

         }

         // 节点被修改
         public void handleDataChange(String arg0, Object arg1) throws Exception {

         }
      };

      // 监听事件通知
      zkClient.subscribeDataChanges(lockPath, iZkDataListener);
      // 控制程序的等待
      if (zkClient.exists(lockPath)) {  //如果检查出已经被创建了就new 然后进行等待

         if (countDownLatch.get() != null) {
            countDownLatch.remove();
         }
         countDownLatch.set(new CountDownLatch(1));
         try {
            countDownLatch.get().wait(); //等待时候就不往下走了当为0 时候后面的继续执行
         } catch (InterruptedException e) {
         //    e.printStackTrace();
         }

      }
      //后面代码继续执行
      //为了不影响程序的执行建议删除该事件监听监听完了就删除掉
      zkClient.unsubscribeDataChanges(lockPath, iZkDataListener);

}

}
package com.itheima.jishutie;

import java.text.SimpleDateFormat;
import java.util.Date;

//生成订单号时间戳
public class OrderNumGenerator {
  //区分不同的订单号
private static int count = 0;
//单台服务器，多个线程同事生成订单号
public String getNumber(){

      SimpleDateFormat simpt = new SimpleDateFormat("yyyy-MM-dd-HH-mm-ss");
      return simpt.format(new Date()) + "-" + ++count;  //时间戳后面加了 count

}

}
package com.itheima.jishutie;

public class OrderService implements Runnable {

private OrderNumGenerator orderNumGenerator = new OrderNumGenerator(); // 定义成全局的
private ExtLock lock = new ZookeeperDistrbuteLock();

public void run() {
      getNumber();
}

public synchronized void getNumber() { // 加锁保证线程安全问题让一个线程操作
      try {
         lock.getLock();
         String number = orderNumGenerator.getNumber();

         System.out.println("順序输出:" + number);

      } catch (Exception e) {

      } finally {
         lock.unLock();
      }
}

public static void main(String[] args) {
//       OrderService orderService = new OrderService();
      for (int i = 0; i < 100; i++) { // 开启100个线程
         //模拟分布式锁的场景
         new Thread(new OrderService()).start();
      }
}

}

控制台输出结果：######成功获取锁######
順序输出:2019-07-25-11-30-16-1######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-2######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-3######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-4######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-5######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-6######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-7######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-8######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-9######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-10######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-11######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-12######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-13######释放锁完毕###########成功获取锁######順序输出:2019-07-25-11-30-16-14

推荐了解热门学科

java培训	Python人工智能	Web前端培训	PHP培训
区块链培训	影视制作培训	C++培训	产品经理培训
UI设计培训	新媒体培训	产品经理培训	Linux运维
大数据培训	智能机器人软件开发

传智播客是一家致力于培养高素质软件开发人才的科技公司，“黑马程序员”是传智播客旗下高端IT教育品牌。自“黑马程序员”成立以来，教学研发团队一直致力于打造精品课程资源，不断在产、学、研3个层面创新自己的执教理念与教学方针，并集中“黑马程序员”的优势力量，针对性地出版了计算机系列教材50多册，制作教学视频数+套，发表各类技术文章数百篇。

传智播客从未停止思考

传智播客副总裁毕向东在2019IT培训行业变革大会提到，“传智播客意识到企业的用人需求已经从初级程序员升级到中高级程序员，具备多领域、多行业项目经验的人才成为企业用人的首选。”

中级程序员和初级程序员的差别在哪里?
项目经验。毕向东表示，“中级程序员和初级程序员最大的差别在于中级程序员比初级程序员多了三四年的工作经验，从而多出了更多的项目经验。“为此，传智播客研究院引进曾在知名IT企业如阿里、IBM就职的高级技术专家，集中研发面向中高级程序员的课程，用以满足企业用人需求，尽快补全IT行业所需的人才缺口。

何为中高级程序员课程?

传智播客进行了定义。中高级程序员课程，是在当前主流的初级程序员课程的基础上，增加多领域多行业的含金量项目，从技术的广度和深度上进行拓展。“我们希望用5年的时间，打造上百个高含金量的项目，覆盖主流的32个行业。”传智播客课程研发总监于洋表示。

黑马程序员热门视频教程【点击播放】

Python入门教程完整版（懂中文就能学会）	零起点打开Java世界的大门
C++\| 匠心之作从0到1入门学编程	PHP\|零基础入门开发者编程核心技术
Web前端入门教程_Web前端html+css+JavaScript	软件测试入门到精通

全国中心

++ 分布式锁控制多线程有序输出【黑马java培训】

相关阅读