【zookeeper】 同步API示例入门

#include <zookeeper.h>
#include <zookeeper_log.h>
#include <iostream>
#include <string.h>

using namespace std;

const char* host = "127.0.0.1:2181";
const int timeout = 2000;
zhandle_t* zkhandle = NULL;
bool is_connect = false;

void clients_watcher_g(zhandle_t * zh, int type, int state, const char* path, void* watcherCtx) {
    printf("global watcher - type:%d,state:%d\n", type, state);
    if ( type==ZOO_SESSION_EVENT ) {
        if ( state==ZOO_CONNECTED_STATE ) {
            printf("connected to zookeeper service successfully!\n");
            printf("timeout:%d\n", zoo_recv_timeout(zh));
            is_connect = true;
        }
        else if ( state==ZOO_EXPIRED_SESSION_STATE ) {
            printf("zookeeper session expired!\n");
        }
    }
    else {
        printf("other type:%d\n", type);
    }
}

int main(int argc, char* argv[]) 
{
    //Init and connect
    zoo_set_debug_level(ZOO_LOG_LEVEL_WARN);
    if (zkhandle) 
        zookeeper_close(zkhandle);

    zkhandle = zookeeper_init(host, clients_watcher_g, timeout, 0, NULL, 0);
    if (NULL == zkhandle) {
        printf("zookeeper init error\n");
        return 0;
    }

    Stat stat;
    int ret = 0;
       char path[] = "/app_watch";
    //check exist
       ret = zoo_exists(zkhandle, path, 0, &stat);
    printf("[%s] ret=%d msg=%s\n", path, ret, ret==0? "succ" : "error");
       if (ZNONODE == ret) {
        // create
        int ret = zoo_create(zkhandle, path, NULL, -1, &ZOO_OPEN_ACL_UNSAFE, 0, NULL, 0); 
        printf("create [%s] ret=%d\n", path, ret);
    }

    //check exist
    ret = zoo_exists(zkhandle, "/app_invalid", 0, &stat);
    printf("ret=%d msg=%s\n", ret, ret==0? "succ" : "error");
    char buffer[1024];
    int buff_len;

    //get data
    buff_len = sizeof(buffer);
    bzero(buffer, buff_len);
    ret = zoo_get(zkhandle, "/app1/p_1", 0, buffer, &buff_len, &stat);
    printf("ret=%d stat=%d len=%d buffer=%s\n", ret, stat.ctime, buff_len, buffer);

        //set data
    buff_len = sizeof(buffer);
        snprintf(buffer, buff_len, "\"rank\":\"10.101.1.101\"");
    ret = zoo_set(zkhandle, "/app1/p_1", (const char *)buffer, strlen(buffer), stat.version);
    printf("ret=%d\n", ret);

    zookeeper_close(zkhandle);
}

BIN = $(patsubst %.cc,%,$(wildcard *.cc))

PATH_ZK = ../zookeeper-3.4.6/src/c/
INC = -I $(PATH_ZK)/include/ -I $(PATH_ZK)/generated
LIB = $(PATH_ZK)/.libs/libzkmt.a $(PATH_ZK)/.libs/libzookeeper_mt.a $(PATH_ZK)/.libs/libhashtable.a
#LIB = $(PATH_ZK)/.libs/libzkst.a $(PATH_ZK)/.libs/libzookeeper_mt.a $(PATH_ZK)/.libs/libhashtable.a

RED = \\e[1m\\e[31m
RESET = \\e[m
GREEN = \\e[1m\\e[32m

all:$(BIN)

%:%.cc
	@echo -e "Make $(GREEN)$@$(RESET) begin......\c"
	g++ -g -pthread -o $@ $< $(INC) $(LIB)
	@echo -e $(RED)"ok."$(RESET)

clean:
	rm $(BIN) 
	@echo "make clean done."

enum ZOO_ERRORS {
  ZOK = 0, /*!< Everything is OK */

  /** System and server-side errors.
   * This is never thrown by the server, it shouldn't be used other than
   * to indicate a range. Specifically error codes greater than this
   * value, but lesser than {@link #ZAPIERROR}, are system errors. */
  ZSYSTEMERROR = -1,
  ZRUNTIMEINCONSISTENCY = -2, /*!< A runtime inconsistency was found */
  ZDATAINCONSISTENCY = -3, /*!< A data inconsistency was found */
  ZCONNECTIONLOSS = -4, /*!< Connection to the server has been lost */
  ZMARSHALLINGERROR = -5, /*!< Error while marshalling or unmarshalling data */
  ZUNIMPLEMENTED = -6, /*!< Operation is unimplemented */
  ZOPERATIONTIMEOUT = -7, /*!< Operation timeout */
  ZBADARGUMENTS = -8, /*!< Invalid arguments */
  ZINVALIDSTATE = -9, /*!< Invliad zhandle state */

  /** API errors.
   * This is never thrown by the server, it shouldn't be used other than
   * to indicate a range. Specifically error codes greater than this
   * value are API errors (while values less than this indicate a 
   * {@link #ZSYSTEMERROR}).
   */
  ZAPIERROR = -100,
  ZNONODE = -101, /*!< Node does not exist */
  ZNOAUTH = -102, /*!< Not authenticated */
  ZBADVERSION = -103, /*!< Version conflict */
  ZNOCHILDRENFOREPHEMERALS = -108, /*!< Ephemeral nodes may not have children */
  ZNODEEXISTS = -110, /*!< The node already exists */
  ZNOTEMPTY = -111, /*!< The node has children */
  ZSESSIONEXPIRED = -112, /*!< The session has been expired by the server */
  ZINVALIDCALLBACK = -113, /*!< Invalid callback specified */
  ZINVALIDACL = -114, /*!< Invalid ACL specified */
  ZAUTHFAILED = -115, /*!< Client authentication failed */
  ZCLOSING = -116, /*!< ZooKeeper is closing */
  ZNOTHING = -117, /*!< (not error) no server responses to process */
  ZSESSIONMOVED = -118 /*!<session moved to another server, so operation is ignored */ 
};

const int ZOOKEEPER_WRITE = 1 << 0;
const int ZOOKEEPER_READ = 1 << 1;

const int ZOO_EPHEMERAL = 1 << 0;
const int ZOO_SEQUENCE = 1 << 1;

const int ZOO_EXPIRED_SESSION_STATE = EXPIRED_SESSION_STATE_DEF;
const int ZOO_AUTH_FAILED_STATE = AUTH_FAILED_STATE_DEF;
const int ZOO_CONNECTING_STATE = CONNECTING_STATE_DEF;
const int ZOO_ASSOCIATING_STATE = ASSOCIATING_STATE_DEF;
const int ZOO_CONNECTED_STATE = CONNECTED_STATE_DEF;