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)


相关推荐

  • 控制中的各种函数MATLAB仿真

    控制中的各种函数MATLAB仿真控制系统的MATLAB仿真1MATLAB简介MATLAB是Mathworks公司开发的一种集数值计算、符号计算和图形可视化三大基本功能于一体的功能强大、操作简单的优秀工程计算应用软件。MATLAB不仅可以处理代数问题和数值分析问题,而且还具有强大的图形处理及仿真模拟等功能。从而能够很好的帮助工程师及科学家解决实际的技术问题。MATLAB的含义是矩阵实验室(MatrixL

  • Php面试问题_php面试常问面试题

    Php面试问题_php面试常问面试题1、css的定位有哪些方式?以及用法position在英文中表示“位置”的意思 它主要是用于实现对元素的定位在CSS中定位分为三种:position:fixed         固定定位position:relatvie      相对定位position:absolute      绝对定位position:static      无特殊定位 (默认值)。注意:   在使用定位属…

  • spark shuffle参数调优

    spark shuffle参数调优

    2021年11月27日
  • linux怎么查看版本信息_如何看电脑版本信息

    linux怎么查看版本信息_如何看电脑版本信息Linux下如何查看版本信息,包括位数、版本信息以及CPU内核信息、CPU具体型号等等,整个CPU信息一目了然。1、#uname-a(Linux查看版本当前操作系统内核信息)Linuxl

  • Bilateral Filters(双边滤波算法)原理及实现

    Bilateral Filters(双边滤波算法)原理及实现双边滤波算法原理:双边滤波算法实现:双边滤波算法实例:参考:http://people.csail.mit.edu/sparis/bf/http://blog.csdn.net/fightingforcv/article/details/52723376http://blog.csdn.net/mumu

  • 什么是雪崩效应?雪崩效应常见场景及应对策略

    什么是雪崩效应?雪崩效应常见场景及应对策略一、什么是雪崩效应分布式系统环境下,服务间类似依赖非常常见,一个业务调用通常依赖多个基础服务。如下图,对于同步调用,当会员服务不可用时,订单服务请求线程被阻塞,当有大批量请求调用会员服务时,最终可能导致整个会员服务资源耗尽,无法继续对外提供服务。并且这种不可用可能沿请求调用链向上传递,这种现象被称为雪崩效应。​二、雪崩效应常见场景硬件故障:如剔除坏盘抖动,服务器宕机,网络抖动,机房断电,光纤被挖断等;流量激增:如异常流量,重试加大流量等;缓存穿透:短时间内大量缓存失效时,大

发表回复

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

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