(1)解压为zookeepertar -xf -C /home/myuser/zookeeper/ 复制zookeeper文件夹3份,分别重名名为zookeeperA,zookeeperB,zookeeperC。 并且创建数据快照以及日志存放文件夹,命名为zooA,zooB,zooC。 (2)编辑对应的zookeeper配置文件,复制...
#include
#include
#include string.h>
#include
#include
#include
#define true 1static const char* state2string(int state)
{
if (state == 0)return "closed_state";
if (state == zoo_connecting_state)return "connecting_state";
if (state == zoo_associating_state)return "associating_state";
if (state == zoo_connected_state)return "connected_state";
if (state == zoo_expired_session_state)return "expired_session_state";
if (state == zoo_auth_failed_state)return "auth_failed_state";
return "invalid_state";
}
static const char* type2string(int state)
{if (state == zoo_created_event)return "created_event";
if (state == zoo_deleted_event)return "deleted_event";
if (state == zoo_changed_event)return "changed_event";
if (state == zoo_child_event)return "child_event";
if (state == zoo_session_event)return "session_event";
if (state == zoo_notwatching_event)return "notwatching_event";return "unknown_event_type";
}
void zktest_dump_stat(const struct stat *stat)
{char tctimes[40];char tmtimes[40];
time_t tctime;
time_t tmtime;if (!stat)
{
fprintf(stderr,"null\n");
return;
}
tctime = stat->ctime/1000;
tmtime = stat->mtime/1000;
ctime_r(&tmtime, tmtimes);
ctime_r(&tctime, tctimes);
fprintf(stderr, "\tctime = %s\tczxid=%llx\n""\tmtime=%s\t***id=%llx\n""\tversion=%x\taversion=%x\n""\tephemeralowner = %llx\n",
tctimes, stat->czxid,
tmtimes, stat->***id,
(unsigned int)stat->version, (unsigned int)stat->aversion,
stat->ephemeralowner);
}
void zktest_data_completion(int rc, const char *value, int value_len, const struct stat *stat, const void *data)
{
fprintf(stderr, "in data completion [%s]: rc = %d\n", value, rc);
zktest_dump_stat(stat);
}
/*process a list of string and stat*/void zktest_strings_stat_completion(int rc, const struct string_vector *strings, const struct stat *stat, const void *data)
{int i=0;
fprintf(stderr, "in strings state completion [%s]: rc = %d, string count %d\n", (char *)data, rc, strings ->count);for (i=0; icount; i++) {
printf("%d: %s\n", i, strings->data[i]);
}
deallocate_string_vector(strings);
zktest_dump_stat(stat);
}void zktest_string_completion(int rc, const char *name, const void *data)
{
fprintf(stderr, "in string completion [%s]: rc = %d\n", (char*)(data==0?"null":data), rc);
if (!rc)
{
fprintf(stderr, "\tname = %s\n", name);
}
}void zktest_stat_completion(int rc, const struct stat *stat, const void *data)
{if (rc == znonode)
{
printf("node not exists\n");
}
fprintf(stderr, "in state completion rc = %d data=%s stat:\n", rc, (char *)data);
zktest_dump_stat(stat);
}
Hadoop|
Apache Pig|
Apache Kafka|
Apache Storm|
Impala|
Zookeeper|
SAS|
TensorFlow|
人工智能基础|
Apache Kylin|
Openstack|
Flink|
MapReduce|
大数据|
云计算|
用户登录
还没有账号?立即注册
用户注册
投稿取消
文章分类: |
|
还能输入300字
上传中....