升级到0.0.6

Author: 夜色

pom.xml

@@ -42,16 +42,6 @@
     </properties>
 
     <dependencies>
-        <dependency>
-            <groupId>com.github.mpusher</groupId>
-            <artifactId>mpush-cache</artifactId>
-            <version>0.0.6</version>
-        </dependency>
-        <dependency>
-            <groupId>com.github.mpusher</groupId>
-            <artifactId>mpush-common</artifactId>
-            <version>0.0.6</version>
-        </dependency>
         <dependency>
             <groupId>com.github.mpusher</groupId>
             <artifactId>mpush-client</artifactId>

src/main/java/com/shinemo/mpush/alloc/AllocHandler.java

@@ -54,9 +54,11 @@
 
     public void start() {
         ZKClient.I.start();//启动ZK
-        watcher = new ZKServerNodeWatcher(ZKPath.CONNECT_SERVER, new ConnectServerZKNodeCache());//监听长链接服务器节点
-        watcher.beginWatch();
+        watcher = new ZKServerNodeWatcher(ZKPath.CONNECT_SERVER, new ConnServerZKNodeCache());//监听长链接服务器节点
+        watcher.watch();
+
         RedisManager.I.init();
+
         scheduledExecutor = Executors.newSingleThreadScheduledExecutor();
         scheduledExecutor.scheduleAtFixedRate(this::refresh, 0, 5, TimeUnit.MINUTES);
     }
@@ -116,7 +118,7 @@ private ServerNode convert(ZKServerNode node) {
         return serverNode;
     }
 
-    private class ConnectServerZKNodeCache extends ZKServerNodeCache {
+    private class ConnServerZKNodeCache extends ZKServerNodeCache {
 
         @Override
         public void put(String fullPath, ZKServerNode node) {