Web Api 基于Zookeeper的服务注册与发现

差别

基于Nginx的服务提供和消费

　
　

基于zookeeper的服务注册和发现

　　

zk的负载均衡是能够调控，nginx只是能调权重，其余须要可控的都须要本身写插件；可是nginx的吞吐量比zk大不少，能够根据业务选择用哪一种方式。

服务端注册

1.建立WEB API 程序，使用NuGet下载ZookeeperNet安装包

　　　　

　　　　

 

2.WEB API 我只提供了一个测试方法

public class DataIndexController : ApiController
    {
        [HttpGet]
        public List<string> GetList()
        {
            List<string> result = new List<string>();
            result.Add("111");
            result.Add("222");
            return result;
        }
    }

3.WEB API Global文件中注册服务地址到Zookeeper

public class WebApiApplication : System.Web.HttpApplication
    {
       
        protected void Application_Start()
        {
            GlobalConfiguration.Configure(WebApiConfig.Register);
            GlobalConfiguration.Configuration.Formatters.XmlFormatter.SupportedMediaTypes.Clear();
            CreateZkNode();
        }
        /// <summary>
        /// 注册服务节点
        /// </summary>
        private void CreateZkNode()
        {
            ZkHelper zk = new ZkHelper();
 
            string node = AppSettingsHelper.GetStringValue("ServiceNode");
            ///建立节点
            zk.CreateNode(node, "data");
        }
    }

<add key="ServiceNode" value="/mysteel/dataindex/localhost:8550" />
    <add key="ZkConnect" value="192.168.20.90:4181" />

ZkHelper核心代码以下

链接ZooKeeper并建立监听

zk = new ZooKeeper(ZkConnectString, new TimeSpan(0, 0, 0, CONST_TIMEOUT), new Watcher());

建立Zookeeper临时节点和永久节点

if (index == lt.Count - 1)
                {
                    ///叶节点设置临时节点
                    zk.Create(path, "".GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Ephemeral);
                }
                else
                {
                    ///父节点设置永久节点
                    zk.Create(path, "".GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Persistent);
                }

建立Zookeeper监听类

public class Watcher : IWatcher
    {
        public void Process(WatchedEvent @event)
        {
            if (@event.Type == EventType.NodeDataChanged)
            {
                Console.WriteLine(@event.Path);
            }
            if (@event.Type == EventType.NodeChildrenChanged)
            {
                Console.WriteLine(@event.Path);
            }
        }
    }

监听分 数据变化和节点变化

 

4.将web api部署三套

5.利用ZooInspector工具查看Zookeeper节点信息

此时服务地址已经注册上去了

若是咱们将IIS应用程序池中止或者网站中止，响应的临时节点也会删掉

具体数据一致性能够参考https://www.cnblogs.com/leesf...

客户端服务发现

static void Main(string[] args)
        {
            string result = string.Empty;
            string strService = ZKService.Instanc.GetNode(ZKService.zkNode);
            if (!string.IsNullOrEmpty(strService))
            {
                result = WebHelper.Get(string.Format("http://{0}//api/dataindex/getlist", strService));
            }
            System.Console.WriteLine(result);
            System.Console.Read();
        }

<add key="zkNode" value="/mysteel/dataindex" />
    <add key="ZkConnect" value="192.168.20.90:4181" />

加群895244712，免费获取架构师进阶学习资料

ZkHelper核心代码

public string GetNode(string path)
      {
          string result = string.Empty;
          try
          {
              var stat = zk.Exists(path, true);
              if (stat != null)
              {
                  //取得/root节点下的子节点名称,返回List<String> 
                  var childData = zk.GetChildren(path, true).OrderBy(l => l).ToList();
 
                  if (childData.Count > 0)
                  {
                      Random random = new Random();
                      int index = random.Next(0, childData.Count);
                      result = childData[index];
                  }
              }
          }
          catch (Exception e)
          {
              throw e;
          }
 
          return result;
      }