图文精华

About云-梭伦科技»专题 › 技术学习(版主发帖区) › 大数据学习 › ZooKeeper › 推荐型› Zookeeper场景实践：命名服务
分享

Zookeeper场景实践：命名服务

howtodown 2015-3-9 11:36:41 发表于 推荐型 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 2 74545
About云VIP帮助找工作和提升
本帖最后由 howtodown 于 2015-3-9 11:38 编辑
问题导读

1.什么是命名服务？
2.命名服务如何发布？
3.服务消费者启动包含哪些操作?






命名服务

是指通过指定的名字来获取资源或者服务的地址，提供者的信息。利用Zookeeper很容易创建一个全局的路径，而这个路径就可以作为一个名字，它可以指向集群中的集群，提供的服务的地址，远程对象等。简单来说使用Zookeeper做命名服务就是用路径作为名字，路径上的数据就是其名字指向的实体。
阿里巴巴集团开源的分布式服务框架Dubbo中使用ZooKeeper来作为其命名服务，维护全局的服务地址列表。在Dubbo实现中：
服务提供者在启动的时候，向ZK上的指定节点/dubbo/${serviceName}/providers目录下写入自己的URL地址，这个操作就完成了服务的发布。
服务消费者启动的时候，订阅/dubbo/{serviceName}/providers目录下的提供者URL地址， 并向/dubbo/{serviceName} /consumers目录下写入自己的URL地址。
注意，所有向ZK上注册的地址都是临时节点，这样就能够保证服务提供者和消费者能够自动感应资源的变化。
另外，Dubbo还有针对服务粒度的监控，方法是订阅/dubbo/{serviceName}目录下所有提供者和消费者的信息。

场景实践
上面的介绍已经满详细，实际实现起来也比较容易。下面讲讲模拟程序的主要特点。模拟程序有3个参数
  • -m 程序运行的方式，指定是服务提供者provider还是服务消费者consumer,或者是服务监控者monitor
  • -n 表示服务名称
  • -s 表示Zookeeper的服务地址IP:PORT
    运行命令如下：
    服务提供者：
    >nameservice -m provider -n query_bill -s172.17.0.36:2181
    服务消费者：
    >nameservice -m consumer -n query_bill -s172.17.0.36:2181
    服务监控者：
    >nameservice -m monitor -n query_bill -s172.17.0.36:2181
第一条命令是启动一个服务提供进程,它提供了一个名为query_bill的服务，程序首次运行时会创建
/NameService,/NameService/query_bill,/NameService/query_bill/provider,/NameService/query_bill/consumer/等几个路径。然后在服务提供进程在/NameService/query_bill/provider下创建临时序列节点.
第二条命令是启动一个服务消费进程,它在/NameService/query_bill/consumer/下创建临时序列节点，并watch/NameService/query_bill/provider的子节点变化事件，及时更新provider列表。
第三条命令是启动一个服务监控进程，它watch  /NameService/query_bill/provider,/NameService/query_bill/consumer/两个路径的子节点变化，及时更新provider列表和comsumer列表。
完整的代码如下：
  1. #include<stdio.h>  

  2. #include<string.h>  

  3. #include<unistd.h>

  4. #include <netinet/in.h>

  5. #include <netdb.h>

  6. #include <arpa/inet.h>

  7. #include"zookeeper.h"  

  8. #include"zookeeper_log.h"  

  9. 

  10. enum MODE{PROVIDER_MODE,CONSUMER_MODE,MONITOR_MODE} g_mode;

  11. char g_host[512]= "172.17.0.36:2181";  

  12. char g_service[512]={ 0 };

  13. char g_path[512]="/NameService";

  14. 

  15. //watch function when child list changed

  16. void zktest_watcher_g(zhandle_t* zh, int type, int state, const char* path, void* watcherCtx);

  17. //show all process ip:pid

  18. void show_list(zhandle_t *zkhandle,const char *path);

  19. //if success,the g_mode will become MODE_MONITOR

  20. void choose_mater(zhandle_t *zkhandle,const char *path);

  21. //get localhost ip:pid

  22. void getlocalhost(char *ip_pid,int len);

  23. 

  24. void print_usage();

  25. void get_option(int argc,const char* argv[]);

  26. 

  27. /**********unitl*********************/  

  28. void print_usage()

  29. {

  30.     printf("Usage : [nameservice] [-h] [-m mode] [-n servicename] [-s ip:port] \n");

  31.     printf("        -h Show help\n");

  32.     printf("        -m set mode:provider,consumer,monitor\n");

  33.     printf("        -n set servicename\n");

  34.     printf("        -s server ip:port\n");

  35.     printf("For example:\n");

  36.     printf("    nameservice -m provider -n query_bill -s172.17.0.36:2181 \n");

  37.     printf("    nameservice -m consumer -n query_bill -s172.17.0.36:2181 \n");

  38.     printf("    nameservice -m monitor  -n query_bill -s172.17.0.36:2181 \n");

  39. }

  40. 

  41. void get_option(int argc,const char* argv[])

  42. {

  43.     extern char    *optarg;

  44.     int            optch;

  45.     int            dem = 1;

  46.     const char    optstring[] = "hm:n:s:";

  47. 

  48. 

  49.     while((optch = getopt(argc , (char * const *)argv , optstring)) != -1 )

  50.     {

  51.         switch( optch )

  52.         {

  53.         case 'h':

  54.             print_usage();

  55.             exit(-1);

  56.         case '?':

  57.             print_usage();

  58.             printf("unknown parameter: %c\n", optopt);

  59.             exit(-1);

  60.         case ':':

  61.             print_usage();

  62.             printf("need parameter: %c\n", optopt);

  63.             exit(-1);

  64.         case 'm':

  65.             if (strcasecmp(optarg,"provider") == 0){

  66.                 g_mode = PROVIDER_MODE;

  67.             }else if (strcasecmp(optarg,"consumer") == 0){

  68.                 g_mode = CONSUMER_MODE;

  69.             }else{

  70.                 g_mode = MONITOR_MODE;

  71.             }

  72.             break;

  73.         case 'n':

  74.             strncpy(g_service,optarg,sizeof(g_service));

  75.             break;

  76.         case 's':

  77.             strncpy(g_host,optarg,sizeof(g_host));

  78.             break;

  79.         default:

  80.             break;

  81.         }

  82.     }

  83. } 

  84. void zktest_watcher_g(zhandle_t* zh, int type, int state, const char* path, void* watcherCtx)  

  85. {  

  86. /*  

  87.     printf("watcher event\n");  

  88.     printf("type: %d\n", type);  

  89.     printf("state: %d\n", state);  

  90.     printf("path: %s\n", path);  

  91.     printf("watcherCtx: %s\n", (char *)watcherCtx);  

  92. */  

  93. 

  94.     if(type == ZOO_CHILD_EVENT &&

  95.        state == ZOO_CONNECTED_STATE &&

  96.        g_mode == CONSUMER_MODE){

  97. 

  98.         printf("providers list changed!\n");

  99.         show_list(zh,path);

  100.     }else if(type == ZOO_CHILD_EVENT &&

  101.              state == ZOO_CONNECTED_STATE &&

  102.              g_mode == MONITOR_MODE){

  103. 

  104.         printf("providers or consumers list changed!\n");

  105. 

  106.         char child_path[512];

  107.         printf("providers:\n");

  108.         sprintf(child_path,"%s/%s/provider",g_path,g_service);

  109.         show_list(zh,child_path);

  110. 

  111.         printf("consumers:\n");

  112.         sprintf(child_path,"%s/%s/consumer",g_path,g_service);

  113.         show_list(zh,child_path);

  114.     }

  115. }  

  116. void getlocalhost(char *ip_pid,int len)

  117. {

  118.     char hostname[64] = {0};

  119.     struct hostent *hent ;

  120. 

  121.     gethostname(hostname,sizeof(hostname));

  122.     hent = gethostbyname(hostname);

  123. 

  124.     char * localhost = inet_ntoa(*((struct in_addr*)(hent->h_addr_list[0])));

  125. 

  126.     snprintf(ip_pid,len,"%s:%d",localhost,getpid());

  127. }

  128. 

  129. void show_list(zhandle_t *zkhandle,const char *path)

  130. {

  131. 

  132.     struct String_vector procs;

  133.     int i = 0;

  134.     char localhost[512]={0};

  135. 

  136.     getlocalhost(localhost,sizeof(localhost));

  137. 

  138.     int ret = zoo_get_children(zkhandle,path,1,&procs);

  139. 

  140.     if(ret != ZOK){

  141.         fprintf(stderr,"failed to get the children of path %s!\n",path);

  142.     }else{

  143.         char child_path[512] ={0};

  144.         char ip_pid[64] = {0};

  145.         int ip_pid_len = sizeof(ip_pid);

  146.         printf("--------------\n");

  147.         printf("ip\tpid\n");

  148.         for(i = 0; i < procs.count; ++i){

  149.             sprintf(child_path,"%s/%s",path,procs.data[i]);

  150.             //printf("%s\n",child_path);

  151.             ret = zoo_get(zkhandle,child_path,0,ip_pid,&ip_pid_len,NULL);

  152.             if(ret != ZOK){

  153.                 fprintf(stderr,"failed to get the data of path %s!\n",child_path);

  154.             }else if(strcmp(ip_pid,localhost)==0){

  155.                 printf("%s(Master)\n",ip_pid);

  156.             }else{

  157.                 printf("%s\n",ip_pid);

  158.             }

  159.         }

  160.     }

  161. 

  162.     for(i = 0; i < procs.count; ++i){

  163.         free(procs.data[i]);

  164.         procs.data[i] = NULL;

  165.     }

  166. }

  167. int create(zhandle_t *zkhandle,const char *path,const char *ctx,int flag)

  168. {

  169.     char path_buffer[512];  

  170.     int bufferlen=sizeof(path_buffer);  

  171. 

  172.     int ret = zoo_exists(zkhandle,path,0,NULL); 

  173.     if(ret != ZOK){

  174.         ret = zoo_create(zkhandle,path,ctx,strlen(ctx),  

  175.                           &ZOO_OPEN_ACL_UNSAFE,flag,  

  176.                           path_buffer,bufferlen);  

  177.         if(ret != ZOK){

  178.             fprintf(stderr,"failed to create the path %s!\n",path);

  179.         }else{

  180.             printf("create path %s successfully!\n",path);

  181.         }

  182.     }

  183. 

  184.     return ZOK;

  185. }

  186. 

  187. int main(int argc, const char *argv[])  

  188. {  

  189.     int timeout = 30000;  

  190.     char path_buffer[512];  

  191.     int bufferlen=sizeof(path_buffer);  

  192.     int ret = 0;

  193.     zoo_set_debug_level(ZOO_LOG_LEVEL_ERROR); //设置日志级别,避免出现一些其他信息  

  194. 

  195.     get_option(argc,argv);

  196. 

  197.     zhandle_t* zkhandle = zookeeper_init(g_host,zktest_watcher_g, timeout, 0, (char *)"NameService Test", 0);  

  198. 

  199.     if (zkhandle ==NULL)  

  200.     {  

  201.         fprintf(stderr, "Error when connecting to zookeeper servers...\n");  

  202.         exit(EXIT_FAILURE);  

  203.     }  

  204. 

  205.     create(zkhandle,g_path,"NameService Test",0);

  206. 

  207.     sprintf(path_buffer,"%s/%s",g_path,g_service);

  208.     create(zkhandle,path_buffer,"NameService Test",0);

  209. 

  210.     sprintf(path_buffer,"%s/%s/provider",g_path,g_service);

  211.     create(zkhandle,path_buffer,"NameService Test",0);

  212. 

  213.     sprintf(path_buffer,"%s/%s/consumer",g_path,g_service);

  214.     create(zkhandle,path_buffer,"NameService Test",0);

  215. 

  216.     if(g_mode == PROVIDER_MODE){

  217. 

  218.         char localhost[512]={0};

  219.         getlocalhost(localhost,sizeof(localhost));

  220. 

  221.         char child_path[512];

  222.         sprintf(child_path,"%s/%s/provider/",g_path,g_service);

  223.         ret = zoo_create(zkhandle,child_path,localhost,strlen(localhost),  

  224.                           &ZOO_OPEN_ACL_UNSAFE,ZOO_SEQUENCE|ZOO_EPHEMERAL,  

  225.                           path_buffer,bufferlen);  

  226.         if(ret != ZOK){

  227.             fprintf(stderr,"failed to create the child_path %s,buffer:%s!\n",child_path,path_buffer);

  228.         }else{

  229.             printf("create child path %s successfully!\n",path_buffer);

  230.         }

  231. 

  232.     }else if (g_mode == CONSUMER_MODE){

  233. 

  234.         char localhost[512]={0};

  235.         getlocalhost(localhost,sizeof(localhost));

  236. 

  237.         char child_path[512];

  238.         sprintf(child_path,"%s/%s/consumer/",g_path,g_service);

  239.         ret = zoo_create(zkhandle,child_path,localhost,strlen(localhost),  

  240.                           &ZOO_OPEN_ACL_UNSAFE,ZOO_SEQUENCE|ZOO_EPHEMERAL,  

  241.                           path_buffer,bufferlen);  

  242.         if(ret != ZOK){

  243.             fprintf(stderr,"failed to create the child_path %s,buffer:%s!\n",child_path,path_buffer);

  244.         }else{

  245.             printf("create child path %s successfully!\n",path_buffer);

  246.         }

  247. 

  248.         sprintf(child_path,"%s/%s/provider",g_path,g_service);

  249.         show_list(zkhandle,child_path);

  250. 

  251.     }else if(g_mode == MONITOR_MODE){

  252.         char child_path[512];

  253.         printf("providers:\n");

  254.         sprintf(child_path,"%s/%s/provider",g_path,g_service);

  255.         show_list(zkhandle,child_path);

  256. 

  257.         printf("consumers:\n");

  258.         sprintf(child_path,"%s/%s/consumer",g_path,g_service);

  259.         show_list(zkhandle,child_path);

  260.     }

  261. 

  262.     getchar();

  263. 

  264.     zookeeper_close(zkhandle); 

  265. 

  266.     return 0;

  267. }
复制代码

相关文章：





本帖被以下淘专辑推荐:

关注公众号，获取大数据、人工智能20套、区块链资源5阶段等资源，随时更新，获取最新技术资源
回复

使用道具 举报

自定义广告语

已有(2)人评论

跳转到指定楼层
正序浏览
ainubis 发表于 2015-3-29 06:43:33

学习了(*^__^*) 嘻嘻……
回复

使用道具 举报

spftoto 发表于 2018-7-17 17:01:37
“”阿里巴巴集团开源的分布式服务框架Dubbo中使用ZooKeeper来作为其命名服务，维护全局的服务地址列表。“”这个可否说的更详细点 究竟是怎么利用统一命名的呀？服务提供者在zookeeper中注册一个节点，然后将自己的URL作为那个节点的数据写进去。然后消费者是怎么访问这个服务的呢？怎么通过zookeeper的这个统一命名空间访问服务的呢？大佬，可否说的更详细点，谢谢了。
回复

使用道具 举报

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

发表新帖
howtodown

版主

关注

  • 666

    主题

  • 1249

    帖子

  • 321

    粉丝

TA的主题
关闭

推荐上一条 /2 下一条

关于我们· 联系我们· 加入我们· 小黑屋· 合作伙伴   

Copyright © 2001-2024 About云-梭伦科技 Powered by Discuz! X3.4 Licensed Discuz Team.

简书 / Smrz 京ICP备2020039040号 Wxb 简书网举报电话：021-34700000