Zookeeper实践方案:(4)命名服务

Zookeeper实践方案:(4)命名服务

大家好,又见面了,我是全栈君,今天给大家准备了Idea注册码。

1.基本介绍

命名服务是指通过指定的名字来获取资源或者服务的地址,提供者的信息。利用Zookeeper非常easy创建一个全局的路径,而这个路径就能够作为一个名字。它能够指向集群中的集群。提供的服务的地址,远程对象等。简单来说使用Zookeeper做命名服务就是用路径作为名字,路径上的数据就是其名字指向的实体。

阿里巴巴集团开源的分布式服务框架Dubbo中使用ZooKeeper来作为其命名服务,维护全局的服务地址列表。在Dubbo实现中:

服务提供者在启动的时候,向ZK上的指定节点/dubbo/${serviceName}/providers文件夹下写入自己的URL地址,这个操作就完毕了服务的公布

服务消费者启动的时候。订阅/dubbo/{serviceName}/providers文件夹下的提供者URL地址, 并向/dubbo/{serviceName} /consumers文件夹下写入自己的URL地址。

注意,全部向ZK上注冊的地址都是暂时节点。这样就行保证服务提供者和消费者可以自己主动感应资源的变化。

另外,Dubbo还有针对服务粒度的监控。方法是订阅/dubbo/{serviceName}文件夹下全部提供者和消费者的信息。

场景实践

上面的介绍已经满具体。实际实现起来也比較easy。以下讲讲模拟程序的主要特点。模拟程序有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列表。

完整的代码例如以下:

#include<stdio.h>  #include<string.h>  #include<unistd.h>#include <netinet/in.h>#include <netdb.h>#include <arpa/inet.h>#include"zookeeper.h"  #include"zookeeper_log.h"  enum MODE{PROVIDER_MODE,CONSUMER_MODE,MONITOR_MODE} g_mode;char g_host[512]= "172.17.0.36:2181";  char g_service[512]={ 0 };char g_path[512]="/NameService";//watch function when child list changedvoid zktest_watcher_g(zhandle_t* zh, int type, int state, const char* path, void* watcherCtx);//show all process ip:pidvoid show_list(zhandle_t *zkhandle,const char *path);//if success,the g_mode will become MODE_MONITORvoid choose_mater(zhandle_t *zkhandle,const char *path);//get localhost ip:pidvoid getlocalhost(char *ip_pid,int len);void print_usage();void get_option(int argc,const char* argv[]);/**********unitl*********************/  void print_usage(){    printf("Usage : [nameservice] [-h] [-m mode] [-n servicename] [-s ip:port] \n");    printf("        -h Show help\n");    printf("        -m set mode:provider,consumer,monitor\n");    printf("        -n set servicename\n");    printf("        -s server ip:port\n");    printf("For example:\n");    printf("    nameservice -m provider -n query_bill -s172.17.0.36:2181 \n");    printf("    nameservice -m consumer -n query_bill -s172.17.0.36:2181 \n");    printf("    nameservice -m monitor  -n query_bill -s172.17.0.36:2181 \n");}void get_option(int argc,const char* argv[]){    extern char    *optarg;    int            optch;    int            dem = 1;    const char    optstring[] = "hm:n:s:";    while((optch = getopt(argc , (char * const *)argv , optstring)) != -1 )    {        switch( optch )        {        case 'h':            print_usage();            exit(-1);        case '?':            print_usage();            printf("unknown parameter: %c\n", optopt);            exit(-1);        case ':':            print_usage();            printf("need parameter: %c\n", optopt);            exit(-1);        case 'm':            if (strcasecmp(optarg,"provider") == 0){                g_mode = PROVIDER_MODE;            }else if (strcasecmp(optarg,"consumer") == 0){                g_mode = CONSUMER_MODE;            }else{                g_mode = MONITOR_MODE;            }            break;        case 'n':            strncpy(g_service,optarg,sizeof(g_service));            break;        case 's':            strncpy(g_host,optarg,sizeof(g_host));            break;        default:            break;        }    }} void zktest_watcher_g(zhandle_t* zh, int type, int state, const char* path, void* watcherCtx)  {  /*      printf("watcher event\n");      printf("type: %d\n", type);      printf("state: %d\n", state);      printf("path: %s\n", path);      printf("watcherCtx: %s\n", (char *)watcherCtx);  */      if(type == ZOO_CHILD_EVENT &&       state == ZOO_CONNECTED_STATE &&       g_mode == CONSUMER_MODE){        printf("providers list changed!\n");        show_list(zh,path);    }else if(type == ZOO_CHILD_EVENT &&             state == ZOO_CONNECTED_STATE &&             g_mode == MONITOR_MODE){        printf("providers or consumers list changed!\n");        char child_path[512];        printf("providers:\n");        sprintf(child_path,"%s/%s/provider",g_path,g_service);        show_list(zh,child_path);        printf("consumers:\n");        sprintf(child_path,"%s/%s/consumer",g_path,g_service);        show_list(zh,child_path);    }}  void getlocalhost(char *ip_pid,int len){    char hostname[64] = {0};    struct hostent *hent ;    gethostname(hostname,sizeof(hostname));    hent = gethostbyname(hostname);    char * localhost = inet_ntoa(*((struct in_addr*)(hent->h_addr_list[0])));    snprintf(ip_pid,len,"%s:%d",localhost,getpid());}void show_list(zhandle_t *zkhandle,const char *path){    struct String_vector procs;    int i = 0;    char localhost[512]={0};    getlocalhost(localhost,sizeof(localhost));    int ret = zoo_get_children(zkhandle,path,1,&procs);    if(ret != ZOK){        fprintf(stderr,"failed to get the children of path %s!\n",path);    }else{        char child_path[512] ={0};        char ip_pid[64] = {0};        int ip_pid_len = sizeof(ip_pid);        printf("--------------\n");        printf("ip\tpid\n");        for(i = 0; i < procs.count; ++i){            sprintf(child_path,"%s/%s",path,procs.data[i]);            //printf("%s\n",child_path);            ret = zoo_get(zkhandle,child_path,0,ip_pid,&ip_pid_len,NULL);            if(ret != ZOK){                fprintf(stderr,"failed to get the data of path %s!\n",child_path);            }else if(strcmp(ip_pid,localhost)==0){                printf("%s(Master)\n",ip_pid);            }else{                printf("%s\n",ip_pid);            }        }    }    for(i = 0; i < procs.count; ++i){        free(procs.data[i]);        procs.data[i] = NULL;    }}int create(zhandle_t *zkhandle,const char *path,const char *ctx,int flag){    char path_buffer[512];      int bufferlen=sizeof(path_buffer);      int ret = zoo_exists(zkhandle,path,0,NULL);     if(ret != ZOK){        ret = zoo_create(zkhandle,path,ctx,strlen(ctx),                            &ZOO_OPEN_ACL_UNSAFE,flag,                            path_buffer,bufferlen);          if(ret != ZOK){            fprintf(stderr,"failed to create the path %s!\n",path);        }else{            printf("create path %s successfully!\n",path);        }    }    return ZOK;}int main(int argc, const char *argv[])  {      int timeout = 30000;      char path_buffer[512];      int bufferlen=sizeof(path_buffer);      int ret = 0;    zoo_set_debug_level(ZOO_LOG_LEVEL_ERROR); //设置日志级别,避免出现一些其它信息      get_option(argc,argv);    zhandle_t* zkhandle = zookeeper_init(g_host,zktest_watcher_g, timeout, 0, (char *)"NameService Test", 0);      if (zkhandle ==NULL)      {          fprintf(stderr, "Error when connecting to zookeeper servers...\n");          exit(EXIT_FAILURE);      }      create(zkhandle,g_path,"NameService Test",0);    sprintf(path_buffer,"%s/%s",g_path,g_service);    create(zkhandle,path_buffer,"NameService Test",0);    sprintf(path_buffer,"%s/%s/provider",g_path,g_service);    create(zkhandle,path_buffer,"NameService Test",0);    sprintf(path_buffer,"%s/%s/consumer",g_path,g_service);    create(zkhandle,path_buffer,"NameService Test",0);    if(g_mode == PROVIDER_MODE){        char localhost[512]={0};        getlocalhost(localhost,sizeof(localhost));        char child_path[512];        sprintf(child_path,"%s/%s/provider/",g_path,g_service);        ret = zoo_create(zkhandle,child_path,localhost,strlen(localhost),                            &ZOO_OPEN_ACL_UNSAFE,ZOO_SEQUENCE|ZOO_EPHEMERAL,                            path_buffer,bufferlen);          if(ret != ZOK){            fprintf(stderr,"failed to create the child_path %s,buffer:%s!\n",child_path,path_buffer);        }else{            printf("create child path %s successfully!\n",path_buffer);        }    }else if (g_mode == CONSUMER_MODE){        char localhost[512]={0};        getlocalhost(localhost,sizeof(localhost));        char child_path[512];        sprintf(child_path,"%s/%s/consumer/",g_path,g_service);        ret = zoo_create(zkhandle,child_path,localhost,strlen(localhost),                            &ZOO_OPEN_ACL_UNSAFE,ZOO_SEQUENCE|ZOO_EPHEMERAL,                            path_buffer,bufferlen);          if(ret != ZOK){            fprintf(stderr,"failed to create the child_path %s,buffer:%s!\n",child_path,path_buffer);        }else{            printf("create child path %s successfully!\n",path_buffer);        }        sprintf(child_path,"%s/%s/provider",g_path,g_service);        show_list(zkhandle,child_path);    }else if(g_mode == MONITOR_MODE){        char child_path[512];        printf("providers:\n");        sprintf(child_path,"%s/%s/provider",g_path,g_service);        show_list(zkhandle,child_path);        printf("consumers:\n");        sprintf(child_path,"%s/%s/consumer",g_path,g_service);        show_list(zkhandle,child_path);    }    getchar();    zookeeper_close(zkhandle);     return 0;}

版权声明:本文博客原创文章,博客,未经同意,不得转载。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/117707.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 小红书用户画像分析_抖音用户画像分析及活跃时间点「建议收藏」

    小红书用户画像分析_抖音用户画像分析及活跃时间点「建议收藏」今天小编来和大家分享一下,抖音用户画像的分析和抖音用户的活跃时间点,1、重点的画像,是抖音受众人群高低线及分布率。2、查询数据的技巧,如果是产品的话参考到阿里指数上查看,如果查行业的话,可以在百度上查看行业报告。在看数据的时候,要清楚你要从数据中得到什么,给我们启发是什么?做抖音要了解抖音上都有哪些人群,找准相对应的人群才能达成转化。3、抖音视频的活跃大约时间上午高峰是12:00晚上…

  • uwsgi部署django_django调用python脚本

    uwsgi部署django_django调用python脚本一.收集静态资源1.settings.py#静态资源访问的起始urlSTATIC_URL=’/static/’#指定静态资源所在的目录STATICFILES_DIRS=[os.path.join(BASE_DIR,’static’)]#设置收集静态资源的路径(部署时使用)STATIC_ROOT=’/home/kzzf/project/OfferHelp…

  • 可访问性级别的C# 修饰符

    使用访问修饰符public、protected、internal或private可以为成员指定以下声明的访问级别之一。http://keleyi.com/a/bjad/3ccfqh95.htm

    2021年12月21日
  • scratch编程一款节奏小游戏「建议收藏」

    scratch编程一款节奏小游戏「建议收藏」今天小恐龙来教大家做一款好玩的小游戏:这个游戏本恐龙没有加音乐,因为箭头落下的速度会根据我们的命中率来改变,按中的越多速度就越快,漏的越多速度就越慢,有上下限!首先画出轨道,粗细随意:轨道直接设置成移到(0,0)就可以了,没有别的程序然后是箭头:变量分值和速度是隐藏起来的,我们在玩的时候是看不到的,速度下限是5,上限是10,不然太快了反应不过来!箭头克隆体程序:最后是判定线的程序:如果是觉得没有音乐太单调的话,可以通过创建一个链表来储存音符。再新建一个变量,每按中一个箭头就将

  • 软件测试工程师女生_能进阿里的程序员都很强吗

    软件测试工程师女生_能进阿里的程序员都很强吗简单的先说一下,坐标杭州,14届本科毕业,算上年前在阿里巴巴的面试,一共有面试了有6家公司(因为不想请假,因此只是每个晚上去其他公司面试,所以面试的公司比较少)

    2022年10月14日
  • Ansi,UTF8,Unicode,ASCII编码的差别

    Ansi,UTF8,Unicode,ASCII编码的差别

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号