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

成都网站设计、做网站的开发，更需要了解用户，从用户角度来建设网站，获得较好的用户体验。创新互联公司多年互联网经验，见的多，沟通容易、能帮助客户提出的运营建议。作为成都一家网络公司，打造的就是网站建设产品直销的概念。选择创新互联公司，不只是建站，我们把建站作为产品，不断的更新、完善，让每位来访用户感受到浩方产品的价值服务。

一： 背景

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

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



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

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

三：代码模拟

1. public class ZookeeperDemo5 {
   

2. 
   

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

4.     private static String FINISH_FLAG="finish";
   

5. 
   

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

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

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

9. 
   

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

11.         client.start();
    

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

13.         cache.start(StartMode.POST_INITIALIZED_EVENT);
    

14. 
    

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

16. 
    

17.             @Override
    

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

19.                 switch (event.getType()) {
    

20.                     case CHILD_ADDED:
    

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

22.                         deal(event);
    

23.                         break;
    

24.                     case CHILD_UPDATED:
    

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

26.                         deal(event);
    

27.                         break;
    

28.                     case CHILD_REMOVED:
    

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

30.                         break;
    

31.                     default:
    

32.                         break;
    

33.                 }
    

34.             }
    

35.         });
    

36. 
    

37.        Thread.sleep(Integer.MAX_VALUE);
    

38.     }
    

39.     
    

40.     
    

41.     
    

42.     
    

43.     private static void deal( PathChildrenCacheEvent event)
    

44.     {
    

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

46. 
    

47.         latch.addListener(new LeaderLatchListener() {
    

48. 
    

49.             @Override
    

50.             public void notLeader() {
    

51.             }
    

52. 
    

53.             @Override
    

54.             public void isLeader() {
    

55.                 try {
    

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

57. 
    

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

59.                    
    

60. 
    

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

62.                         Thread.sleep(10000L);
    

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

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

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

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

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

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

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

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

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

72.                     }
    

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

74.                     latch.close();
    

75.                 }
    

76.                 catch (Exception e) {
    

77.                     e.printStackTrace();
    

78.                 }
    

79.             }
    

80.         });
    

81.         try {
    

82.             latch.start();
    

83.         }
    

84.         catch (Exception e) {
    

85.             e.printStackTrace();
    

86.         }
    

87.     }
    

88. }

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

分享文章：怎么分析ZooKeeper分布式任务调度中心
URL链接：http://kswjz.com/article/posgsd.html