zookeeper 实现一个简单的服务注册与发现（C++） 三：服务发现

git：git@github.com:ccx19930930/services_register_and_discovery.git

参考链接：https://www.cnblogs.com/haippy/archive/2013/02/21/2920280.html

down_service_mgr.h

#ifndef _DOWN_SERVICE_MGR_H_
#define _DOWN_SERVICE_MGR_H_

#include "base_class.h"

class CDownServiceMgr : CUnCopyable
{
public:
    CDownServiceMgr(int module_id) : m_module_id(module_id) {}
    ~CDownServiceMgr() {}
private:
    CDownServiceMgr() {}

public:
    int Register(const string& zk_path, CNodeInfo* node_info);
    int UnRegister(const string& zk_path);

private:
    int m_module_id;
    map<string, CNodeInfo *> m_node_list;
     pthread_mutex_t m_mutex;
};

#endif

down_service_mgr.cpp

#include "down_service_mgr.h"
#include "auto_lock.h"

int CDownServiceMgr::Register(const string& zk_path, CNodeInfo* node_info)
{
    CAutoMutexLock auto_lock(m_mutex);
    if (m_node_list.count(zk_path))
    {
        return -1;
    }
    m_node_list[zk_path] = node_info;
    //TODO 长连接等

    return 0;
}

int CDownServiceMgr::UnRegister(const string& zk_path)
{
    CAutoMutexLock auto_lock(m_mutex);
    if (m_node_list.count(zk_path) == 0)
    {
        return -1;
    }
    //TODO 长连接等

    m_node_list.erase(zk_path);
    return 0;
}

discovery.h

#ifndef _DISCOVERY_H_
#define _DISCOVERY_H_

#include "base_class.h"
#include "zk_handle.h"
#include "down_service_mgr.h"

#include <zookeeper.jute.h>

class CDownNode
{
public:
    CDownNode() { Reset(); }
    ~CDownNode() {}

    void Reset()
    {
        m_full_node = false;
        m_node_info.Reset();
        m_node_list.clear();
        m_invalid_node_path_list.clear();
    }

public:
    bool m_full_node;
    CNodeInfo m_node_info;

    map<string, CNodeInfo> m_node_list;
    set<string> m_invalid_node_path_list;

};

class CDiscovery : public CUnCopyable
{
private:
    static pthread_mutex_t m_mutex;
    static CDiscovery* m_pins;
    CDiscovery();
public:
    static CDiscovery* GetInstance();
    int Init(const set<string> & down_path_list, const set<int> & down_service_list);


public:
    int StartCheck();
    int Stop();
    static void OnZkHandleResetFunc();

private:
    static void* DiscoveryCheckThread(void * param);
    int DiscoveryCheck();
    int DownPathCheck();
    int InvalidNodeCheck();
    int DebugPrintAllNode();
    bool IsRunning();

private:
    static void ZkPathWatcher(zhandle_t* zh, int type, int state, const char* path, void* watcherCtx);
    static void ZkNodeWatcher(zhandle_t* zh, int type, int state, const char* path, void* watcherCtx);

private:
    int OnPathChange(string path);
    int OnNodeChange(string node);
    void OnZkHandleReset();
    
private:
    pthread_t m_down_check_thread_id;
    bool m_is_running;
    map<string, CDownNode*> m_down_path_list; // <zk_path, down_node_info>
    map<string, string> m_down_path_2_dir;    // <zk_node, zk_node>
    map<int, CDownServiceMgr* > m_down_service_list;
};

#endif

discovery.cpp

#include "discovery.h"
#include "auto_lock.h"

#include <stdlib.h>
#include <sys/prctl.h>
#include <unistd.h>
#include <pthread.h>

CDiscovery* CDiscovery::m_pins = nullptr;
pthread_mutex_t CDiscovery::m_mutex;

CDiscovery::CDiscovery()
    : m_is_running(false)
    , m_down_check_thread_id(0)
{
}

CDiscovery* CDiscovery::GetInstance()
{
    if (m_pins == nullptr)
    {
        CAutoMutexLock auto_lock(m_mutex);
        if (m_pins == nullptr)
        {
            m_pins = new CDiscovery;
        }
    }
    return m_pins;
}

int CDiscovery::Init(const set<string>& down_path_list, const set<int>& down_service_list)
{
    CAutoMutexLock auto_lock(m_mutex);
    for (const auto & zk_path : down_path_list)
    {
        m_down_path_list[zk_path] = new CDownNode;
    }

    for (const auto& module_id : down_service_list)
    {
        m_down_service_list[module_id] = new CDownServiceMgr(module_id);
    }

    return 0;
}

int CDiscovery::StartCheck()
{
    if (0 == m_down_check_thread_id)
    {
        m_is_running = true;
        if (0 != pthread_create(&m_down_check_thread_id, nullptr, CDiscovery::DiscoveryCheckThread, nullptr))
        {
            printf("CDiscovery::StartCheck create discovery check thread fail.");
            return -1;
        }
        printf("CDiscovery::StartCheck create discovery check thread succ.");
    }
    return 0;
}

int CDiscovery::Stop()
{
    m_is_running = false;
}

void CDiscovery::OnZkHandleResetFunc()
{
    CDiscovery::GetInstance()->OnZkHandleReset();
}

void* CDiscovery::DiscoveryCheckThread(void* param)
{
    prctl(PR_SET_NAME, "zk_discovery_check");

    CZkHandle::GetInstance()->AddResetHandleFn("discovery", CDiscovery::OnZkHandleResetFunc);

    while (true == CDiscovery::GetInstance()->IsRunning())
    {
        CDiscovery::GetInstance()->DiscoveryCheck();
        usleep(kZkDiscoveryIntervalTime);
    }
    return nullptr;
}

int CDiscovery::DiscoveryCheck()
{
    DownPathCheck();
    InvalidNodeCheck();

#ifdef _DEBUG_
    DebugPrintAllNode();
#endif
}

int CDiscovery::DownPathCheck()
{
    printf("%s =======================================================
", __func__);
    CAutoMutexLock auto_lock(m_mutex);
    for (const auto& down_path : m_down_path_list)
    {
        CDownNode* down_node = down_path.second;
        if (down_node->m_full_node)
        {
            continue;
        }
        set<string> node_list;
        if (ZOK == CZkHandle::GetInstance()->ZkWgetChildren(down_path.first, CDiscovery::ZkPathWatcher, node_list))
        {
            for (auto node_path : node_list)
            {
                down_node->m_invalid_node_path_list.insert(down_path.first + '/' + node_path);
            }
            for (const auto& node : down_node->m_node_list)
            {
                down_node->m_invalid_node_path_list.insert(node.first);
            }

            down_node->m_full_node = true;
        }
    }
    return 0;
}

int CDiscovery::InvalidNodeCheck()
{
    printf("%s =======================================================
", __func__);
    CAutoMutexLock auto_lock(m_mutex);
    for (const auto& down_path : m_down_path_list)
    {
        CDownNode* down_node = down_path.second;
        for (auto it_node_path = down_node->m_invalid_node_path_list.begin(); it_node_path != down_node->m_invalid_node_path_list.end();)
        {
            struct Stat stat;
            string zk_node_info;
            int ret_code = CZkHandle::GetInstance()->ZkWGetNodeInfo(*it_node_path, CDiscovery::ZkNodeWatcher, zk_node_info, stat);
            if (ZOK == ret_code)
            {
                CNodeInfo node_info;
                node_info.FromString(zk_node_info);
                down_node->m_node_list[*it_node_path] = node_info;
                it_node_path = down_node->m_invalid_node_path_list.erase(it_node_path);
                m_down_service_list[atoi(node_info.m_module_id.c_str())]->Register(*it_node_path, &node_info);
                m_down_path_2_dir[*it_node_path] = down_path.first;
            }
            else if(ZNONODE == ret_code)
            {
                if (down_node->m_node_list.count(*it_node_path))
                {
                    CNodeInfo& node_info = down_node->m_node_list[*it_node_path];
                    m_down_service_list[atoi(node_info.m_module_id.c_str())]->UnRegister(*it_node_path);
                    down_node->m_node_list.erase(*it_node_path);
                }
                if (m_down_path_2_dir.count(*it_node_path))
                {
                    m_down_path_2_dir.erase(*it_node_path);
                }
                it_node_path = down_node->m_invalid_node_path_list.erase(it_node_path);
            }
            else
            {
                ++it_node_path;
            }
        }
    }
    return 0;
}

int CDiscovery::DebugPrintAllNode()
{
    printf("%s =======================================================
", __func__);
    CAutoMutexLock auto_lock(m_mutex);
    for (const auto& down_path : m_down_path_list)
    {
        printf("%s down_path=%s is_full_node=%d --------------------------------------------
", __func__, down_path.first.c_str(), down_path.second->m_full_node);
        printf("%s node_list: 
", __func__);
        for (auto& down_node : down_path.second->m_node_list)
        {
            printf("%s node=%s 
", __func__, down_node.first.c_str());
            printf("%s info=%s 
", __func__, down_node.second.ToString().c_str());
        }

        printf("%s invalid_node_list: 
", __func__);
        for (const auto& invalid_node : down_path.second->m_invalid_node_path_list)
        {
            printf("%s invalid_node:%s 
", __func__, invalid_node.c_str());
        }
    }
    return 0;
}

bool CDiscovery::IsRunning()
{
    return m_is_running;
}

void CDiscovery::ZkPathWatcher(zhandle_t* zh, int type, int state, const char* path, void* watcherCtx)
{
    if (ZOO_CHILD_EVENT == type)
    {
        CDiscovery::GetInstance()->OnPathChange(path);
    }
}

void CDiscovery::ZkNodeWatcher(zhandle_t* zh, int type, int state, const char* path, void* watcherCtx)
{
    if (ZOO_CHANGED_EVENT == type)
    {
        CDiscovery::GetInstance()->OnNodeChange(path);
    }
    else if (ZOO_DELETED_EVENT == type)
    {
        CDiscovery::GetInstance()->OnNodeChange(path);
    }
}

int CDiscovery::OnPathChange(string path)
{
    printf("%s path=%s  =======================================================
", __func__, path.c_str());
    CAutoMutexLock auto_lock(m_mutex);
    if (m_down_path_list.count(path))
    {
        m_down_path_list[path]->m_full_node = false;
    }
    return 0;
}

int CDiscovery::OnNodeChange(string node)
{
    printf("%s node=%s  =======================================================
", __func__, node.c_str());
    CAutoMutexLock auto_lock(m_mutex);
    string path;
    if (m_down_path_2_dir.count(node))
    {
        path = m_down_path_2_dir[node];
    }
    if (m_down_path_list.count(path))
    {
        m_down_path_list[path]->m_invalid_node_path_list.insert(node);
    }
    return 0;
}

void CDiscovery::OnZkHandleReset()
{
    printf("%s =======================================================
", __func__);
    CAutoMutexLock auto_lock(m_mutex);
    for (const auto& down_path : m_down_path_list)
    {
        down_path.second->m_full_node = false;
    }
}

discovery_test main.cpp

#include "../zk_util/zk_handle.h"
#include "../zk_util/discovery.h"

#include <unistd.h>

//伪分布式部署 host list最好以配置文件形式，此处为测试程序，暂时写死
const char* host_list = "xx.xx.xx.xx:port,xx.xx.xx.xx:port,xx.xx.xx.xx:port";
const int time_out = 3000;
int main()
{
    CZkHandle::GetInstance()->ZkInit(host_list, time_out);

    set<string> down_path_list;
    down_path_list.insert("/zk_test1");
    down_path_list.insert("/zk_test2");

    set<int> down_service_list;
    down_service_list.insert(1);
    down_service_list.insert(2);

    CDiscovery::GetInstance()->Init(down_path_list, down_service_list);
    CDiscovery::GetInstance()->StartCheck();

    sleep(60);

    return 0;
}

Makefile

INC_DIR:= ./ ../zk_util/ /usr/local/include/zookeeper/ /usr/local/include/json/
SRCS:= $(wildcard ./*cpp ../zk_util/*cpp)
OBJS:= $(patsubst %.cpp, %.o, $(SRCS))
LIBS:= -lpthread -lzookeeper_mt -ljsoncpp

CXX:= g++

CXXFLAGS:= -w -g -std=c++11 $(addprefix -I, $(INC_DIR)) $(LIBS) -Wl,-rpath="/usr/local/lib" -D _DEBUG_

EXE:= ../../bin/discovery_test

$(EXE):$(OBJS)
    $(CXX) -o $(EXE) $(OBJS) $(CXXFLAGS)

clean:
    rm -rf $(EXE)
    rm -rf $(OBJS)

执行结果：

只执行discovery_test

ccx@ccx:~/self_test/zookeeper/services_register_and_discovery/bin$ ./discovery_test 
CZkHandle::ZkInit create register check thread succ.
CDiscovery::StartCheck create discovery check thread succ.CZkHandle::ResetZkHandle: connect to zk succ.
DownPathCheck =======================================================
CZkHandle::ZkWgetChildren get children for path=/zk_test1
CZkHandle::ZkInitWatchar: [type=-1] [state=3] [path=] [watcher_ctx=(nil)]
CZkHandle::ZkWgetChildren get children succ. children_num=0
CZkHandle::ZkWgetChildren get children for path=/zk_test2
CZkHandle::ZkWgetChildren get children succ. children_num=0
InvalidNodeCheck =======================================================
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]
DownPathCheck =======================================================
InvalidNodeCheck =======================================================
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]
DownPathCheck =======================================================
InvalidNodeCheck =======================================================
DebugPrintAllNode =======================================================

使用register_test_1.conf 启动多个测试程序后

DownPathCheck =======================================================
InvalidNodeCheck =======================================================
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]
OnPathChange path=/zk_test1  =======================================================
DownPathCheck =======================================================
CZkHandle::ZkWgetChildren get children for path=/zk_test1
CZkHandle::ZkWgetChildren get children succ. children_num=1
CZkHandle::ZkWgetChildren children_idx=0, children_name=register_test_1
InvalidNodeCheck =======================================================
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test1/register_test_1
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test1/register_test_1 succ. buffer=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test1] MODULE_NAME[register_test] MODULE_ID[1] MODULE_IDX[1] 
CZkHandle::ZkWGetNodeInfo: [path=/zk_test1/register_test_1] [czxid=17179873794] [mzxid=17179873794] [version=0] [cversion=0] [child_num=0]
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test1/register_test_1 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test1] MODULE_NAME[register_test] MODULE_ID[1] MODULE_IDX[1]  
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]
DownPathCheck =======================================================
InvalidNodeCheck =======================================================
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test1/register_test_1 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test1] MODULE_NAME[register_test] MODULE_ID[1] MODULE_IDX[1]  
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]

使用register_test_2.conf 启动多个测试程序后

DownPathCheck =======================================================
InvalidNodeCheck =======================================================
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test1/register_test_1 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test1] MODULE_NAME[register_test] MODULE_ID[1] MODULE_IDX[1]  
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]
OnPathChange path=/zk_test2  =======================================================
DownPathCheck =======================================================
CZkHandle::ZkWgetChildren get children for path=/zk_test2
CZkHandle::ZkWgetChildren get children succ. children_num=1
CZkHandle::ZkWgetChildren children_idx=0, children_name=register_test_20000000010
InvalidNodeCheck =======================================================
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test2/register_test_20000000010
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test2/register_test_20000000010 succ. buffer=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2] 
CZkHandle::ZkWGetNodeInfo: [path=/zk_test2/register_test_20000000010] [czxid=17179873868] [mzxid=17179873868] [version=0] [cversion=0] [child_num=0]
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test1/register_test_1 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test1] MODULE_NAME[register_test] MODULE_ID[1] MODULE_IDX[1]  
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test2/register_test_20000000010 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2]  
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]
DownPathCheck =======================================================
InvalidNodeCheck =======================================================
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test1/register_test_1 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test1] MODULE_NAME[register_test] MODULE_ID[1] MODULE_IDX[1]  
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test2/register_test_20000000010 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2]  
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]
OnPathChange path=/zk_test2  =======================================================
DownPathCheck =======================================================
CZkHandle::ZkWgetChildren get children for path=/zk_test2
CZkHandle::ZkWgetChildren get children succ. children_num=2
CZkHandle::ZkWgetChildren children_idx=0, children_name=register_test_20000000010
CZkHandle::ZkWgetChildren children_idx=1, children_name=register_test_20000000011
InvalidNodeCheck =======================================================
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test2/register_test_20000000010
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test2/register_test_20000000010 succ. buffer=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2] 
CZkHandle::ZkWGetNodeInfo: [path=/zk_test2/register_test_20000000010] [czxid=17179873868] [mzxid=17179873868] [version=0] [cversion=0] [child_num=0]
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test2/register_test_20000000011
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test2/register_test_20000000011 succ. buffer=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2] 
CZkHandle::ZkWGetNodeInfo: [path=/zk_test2/register_test_20000000011] [czxid=17179873873] [mzxid=17179873873] [version=0] [cversion=0] [child_num=0]
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test1/register_test_1 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test1] MODULE_NAME[register_test] MODULE_ID[1] MODULE_IDX[1]  
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test2/register_test_20000000010 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2]  
DebugPrintAllNode node=/zk_test2/register_test_20000000011 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2]  
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]

依次停止register_test：

DownPathCheck =======================================================
InvalidNodeCheck =======================================================
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test1/register_test_1 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test1] MODULE_NAME[register_test] MODULE_ID[1] MODULE_IDX[1]  
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test2/register_test_20000000014 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2]  
DebugPrintAllNode node=/zk_test2/register_test_20000000015 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2]  
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]
OnNodeChange node=/zk_test1/register_test_1  =======================================================
OnPathChange path=/zk_test1  =======================================================
DownPathCheck =======================================================
CZkHandle::ZkWgetChildren get children for path=/zk_test1
CZkHandle::ZkWgetChildren get children succ. children_num=0
InvalidNodeCheck =======================================================
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test1/register_test_1
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test1/register_test_1 fail. ret=-101
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test2/register_test_20000000014 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2]  
DebugPrintAllNode node=/zk_test2/register_test_20000000015 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2]  
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]
DownPathCheck =======================================================
InvalidNodeCheck =======================================================
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode node=/zk_test2/register_test_20000000014 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2]  
DebugPrintAllNode node=/zk_test2/register_test_20000000015 
DebugPrintAllNode info=IP[127.0.0.1] PORT[12345] ZK_PATH[/zk_test2] MODULE_NAME[register_test] MODULE_ID[2] MODULE_IDX[2]  
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]
OnNodeChange node=/zk_test2/register_test_20000000015  =======================================================
OnPathChange path=/zk_test2  =======================================================
OnNodeChange node=/zk_test2/register_test_20000000014  =======================================================
DownPathCheck =======================================================
CZkHandle::ZkWgetChildren get children for path=/zk_test2
CZkHandle::ZkWgetChildren get children succ. children_num=0
InvalidNodeCheck =======================================================
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test2/register_test_20000000014
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test2/register_test_20000000014 fail. ret=-101
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test2/register_test_20000000015
CZkHandle::ZkWGetNodeInfo get node info for path=/zk_test2/register_test_20000000015 fail. ret=-101
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]
DownPathCheck =======================================================
InvalidNodeCheck =======================================================
DebugPrintAllNode =======================================================
DebugPrintAllNode down_path=/zk_test1 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
DebugPrintAllNode down_path=/zk_test2 is_full_node=1 --------------------------------------------
DebugPrintAllNode node_list: 
DebugPrintAllNode invalid_node_list: 
CZkHandle::ZkExists: [ret=0]
CZkHandle::ZkExists: [path=/] [czxid=0] [mzxid=0] [version=0] [cversion=291] [child_num=5]