怎么分析ZooKeeper分布式任務調度中心

怎么分析ZooKeeper分布式任務調度中心，相信很多沒有經驗的人對此束手無策，為此本文總結了問題出現的原因和解決方法，通過這篇文章希望你能解決這個問題。

一： 背景

軟件系統(tǒng)中，定時任務往往不可或缺，大家可能會采用Spring quartz 建立定時任務模塊。 當任務模塊進行了分布式部署，通常會出現定時任務重復執(zhí)行的情況。 怎么避免這種情況呢，是否可以構建一個任務注冊中心，Quartz負責注冊任務，但不具體執(zhí)行任務內的業(yè)務邏輯。

任務注冊中心解決任務重復注冊的問題，同時將任務分配給若干處理器進行具體的業(yè)務處理，保證在同一個時間內，一個任務只會被一個處理器進行處理。如下圖



二：任務注冊中心與調度中心

采用ZooKeeper的客戶端框架Curator,  利用ZooKeeper的Master選舉機制實現。 注冊任務就相當于在ZooKeeper中創(chuàng)建或更新一個節(jié)點。通過更新節(jié)點的內容，來記錄任務的執(zhí)行狀態(tài)。

三：代碼模擬

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分布式任務調度中心的方法了嗎？如果還想學到更多技能或想了解更多相關內容，歡迎關注億速云行業(yè)資訊頻道，感謝各位的閱讀！