Web Api 基于Zookeeper的服務(wù)注冊與發(fā)現(xiàn)

Jiavan 發(fā)布于2019-08-16 13:44 / 1061人閱讀

摘要：差異基于的服務(wù)提供和消費基于的服務(wù)注冊和發(fā)現(xiàn)的負(fù)載均衡是可以調(diào)控，只是能調(diào)權(quán)重，其他需要可控的都需要自己寫插件但是的吞吐量比大很多，可以根據(jù)業(yè)務(wù)選擇用哪種方式。

差異

基于Nginx的服務(wù)提供和消費

基于zookeeper的服務(wù)注冊和發(fā)現(xiàn)

zk的負(fù)載均衡是可以調(diào)控，nginx只是能調(diào)權(quán)重，其他需要可控的都需要自己寫插件；但是nginx的吞吐量比zk大很多，可以根據(jù)業(yè)務(wù)選擇用哪種方式。

服務(wù)端注冊

1.創(chuàng)建WEB API 程序，使用NuGet下載ZookeeperNet安裝包

2.WEB API 我只提供了一個測試方法

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

3.WEB API?Global文件中注冊服務(wù)地址到Zookeeper

public class WebApiApplication : System.Web.HttpApplication
    {
       
        protected void Application_Start()
        {
            GlobalConfiguration.Configure(WebApiConfig.Register);
            GlobalConfiguration.Configuration.Formatters.XmlFormatter.SupportedMediaTypes.Clear();
            CreateZkNode();
        }
        /// 
        /// 注冊服務(wù)節(jié)點
        /// 
        private void CreateZkNode()
        {
            ZkHelper zk = new ZkHelper();
 
            string node = AppSettingsHelper.GetStringValue("ServiceNode");
            ///創(chuàng)建節(jié)點
            zk.CreateNode(node, "data");
        }
    }

ZkHelper核心代碼如下

連接ZooKeeper并創(chuàng)建監(jiān)聽

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

創(chuàng)建Zookeeper臨時節(jié)點和永久節(jié)點

if (index == lt.Count - 1)
                {
                    ///葉節(jié)點設(shè)置臨時節(jié)點
                    zk.Create(path, "".GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Ephemeral);
                }
                else
                {
                    ///父節(jié)點設(shè)置永久節(jié)點
                    zk.Create(path, "".GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Persistent);
                }

創(chuàng)建Zookeeper監(jiān)聽類

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);
            }
        }
    }

監(jiān)聽分數(shù)據(jù)變化和節(jié)點變化

4.將web api部署三套

5.利用ZooInspector工具查看Zookeeper節(jié)點信息

此時服務(wù)地址已經(jīng)注冊上去了

如果我們將IIS應(yīng)用程序池停止或者網(wǎng)站停止，響應(yīng)的臨時節(jié)點也會刪掉

具體數(shù)據(jù)一致性可以參考https://www.cnblogs.com/leesf...

客戶端服務(wù)發(fā)現(xiàn)

  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();
        }

加群895244712，免費獲取架構(gòu)師進(jìn)階學(xué)習(xí)資料

ZkHelper核心代碼

public string GetNode(string path)
      {
          string result = string.Empty;
          try
          {
              var stat = zk.Exists(path, true);
              if (stat != null)
              {
                  //取得/root節(jié)點下的子節(jié)點名稱,返回List 
                  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;
      }