怎么分析ZooKeeper分布式任务调度中心

发布时间:2021-12-24 16:23:19 作者:柒染
来源:亿速云 阅读:140

怎么分析ZooKeeper分布式任务调度中心,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。

一: 背景

软件系统中,定时任务往往不可或缺,大家可能会采用Spring quartz 建立定时任务模块。 当任务模块进行了分布式部署,通常会出现定时任务重复执行的情况。 怎么避免这种情况呢,是否可以构建一个任务注册中心,Quartz负责注册任务,但不具体执行任务内的业务逻辑。

任务注册中心解决任务重复注册的问题,同时将任务分配给若干处理器进行具体的业务处理,保证在同一个时间内,一个任务只会被一个处理器进行处理。如下图

怎么分析ZooKeeper分布式任务调度中心

二:任务注册中心与调度中心

采用ZooKeeper的客户端框架Curator,  利用ZooKeeper的Master选举机制实现。 注册任务就相当于在ZooKeeper中创建或更新一个节点。通过更新节点的内容,来记录任务的执行状态。

三:代码模拟

  1. public class ZookeeperDemo5 {


  2.     private static String PATH = "/zkbk2";

  3.     private static String FINISH_FLAG="finish";


  4.     private static CuratorFramework client = CuratorFrameworkFactory.builder()

  5.             .connectString("10.243.3.18:2181,10.243.3.17:2181,10.243.3.27:2181").sessionTimeoutMs(5000)

  6.             .retryPolicy(new ExponentialBackoffRetry(100, 3)).build();


  7.     public static void main(String[] args) throws Exception {

  8.         client.start();

  9.         PathChildrenCache cache = new PathChildrenCache(client, PATH, true);

  10.         cache.start(StartMode.POST_INITIALIZED_EVENT);


  11.         cache.getListenable().addListener(new PathChildrenCacheListener() {


  12.             @Override

  13.             public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) {

  14.                 switch (event.getType()) {

  15.                     case CHILD_ADDED:

  16.                         System.out.println("CHILD_ADDED," + event.getData().getPath());

  17.                         deal(event);

  18.                         break;

  19.                     case CHILD_UPDATED:

  20.                         System.out.println("CHILD_UPDATED," + event.getData().getPath());

  21.                         deal(event);

  22.                         break;

  23.                     case CHILD_REMOVED:

  24.                         System.out.println("CHILD_REMOVED," + event.getData().getPath());

  25.                         break;

  26.                     default:

  27.                         break;

  28.                 }

  29.             }

  30.         });


  31.        Thread.sleep(Integer.MAX_VALUE);

  32.     }

  33.     

  34.     

  35.     

  36.     

  37.     private static void deal( PathChildrenCacheEvent event)

  38.     {

  39.         final LeaderLatch latch = new LeaderLatch(client, event.getData().getPath());


  40.         latch.addListener(new LeaderLatchListener() {


  41.             @Override

  42.             public void notLeader() {

  43.             }


  44.             @Override

  45.             public void isLeader() {

  46.                 try {

  47.                     System.out.println("======begin deal==========" + event.getData().getPath());


  48.                     String data = new String(client.getData().forPath(event.getData().getPath()));

  49.                    


  50.                     if (!data.contains("finish")) {

  51.                         Thread.sleep(10000L);

  52.                         System.out.println("");

  53.                         System.out.println("");

  54.                         System.out.println("**************************************");

  55.                         System.out.println("**************************************");

  56.                         System.out.println("**************************************");

  57.                         System.out.println("**************************************");

  58.                         System.out.println("");

  59.                         System.out.println("");

  60.                         client.setData().forPath(event.getData().getPath(), FINISH_FLAG.getBytes());

  61.                     }

  62.                     System.out.println("======finish deal==========" + event.getData().getPath());

  63.                     latch.close();

  64.                 }

  65.                 catch (Exception e) {

  66.                     e.printStackTrace();

  67.                 }

  68.             }

  69.         });

  70.         try {

  71.             latch.start();

  72.         }

  73.         catch (Exception e) {

  74.             e.printStackTrace();

  75.         }

  76.     }

  77. }

看完上述内容,你们掌握怎么分析ZooKeeper分布式任务调度中心的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注亿速云行业资讯频道,感谢各位的阅读!

推荐阅读:
  1. Zookeeper详解(一):分布式与Zookeeper
  2. Zookeeper 分布式部署

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

zookeeper

上一篇:kubernetes中Istio如何配置请求路由

下一篇:linux中如何删除用户组

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》