Web Api 基于Zookeeper的服務注冊與發現

Jiavan 發布于2019-08-16 13:44 / 1052人閱讀

摘要：差異基于的服務提供和消費基于的服務注冊和發現的負載均衡是可以調控，只是能調權重，其他需要可控的都需要自己寫插件但是的吞吐量比大很多，可以根據業務選擇用哪種方式。

差異

基于Nginx的服務提供和消費

基于zookeeper的服務注冊和發現

zk的負載均衡是可以調控，nginx只是能調權重，其他需要可控的都需要自己寫插件；但是nginx的吞吐量比zk大很多，可以根據業務選擇用哪種方式。

服務端注冊

1.創建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文件中注冊服務地址到Zookeeper

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

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

加群895244712，免費獲取架構師進階學習資料

ZkHelper核心代碼

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

云服務器 GPU云服務器基于linux的web服務器搭建基于web的即時通訊服務治理與發現基于webrtc的電話回聲消除的研究與實現

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/72251.html

PowerDotNet平臺化軟件架構設計與實現系列（04）：服務治理平臺

摘要：的服務治理平臺發源于早期的個人項目。客戶端發現模式要求客戶端負責查詢注冊中心，獲取服務提供者的列表信息，使用負載均衡算法選擇一個合適的服務提供者，發起接口調用請求。系統和系統之間，少不了數據的互聯互通。隨著微服務的流行，一個系統內的不同應用進行互聯互通也是常態。 PowerDotNet的服務治理平臺發源于早期的個人項目Power.Apix。這個項目借鑒了工作過的公司的服務治理方案，站在...

reclay 2021-11-22 12:08 評論0 收藏0
2021 年最新基于 Spring Cloud 的微服務架構分析

摘要：是一個相對比較新的微服務框架，年才推出的版本雖然時間最短但是相比等框架提供的全套的分布式系統解決方案。提供線程池不同的服務走不同的線程池，實現了不同服務調用的隔離，避免了服務器雪崩的問題。通過互相注冊的方式來進行消息同步和保證高可用。 Spring Cloud 是一個相對比較新的微服務框架，...

cikenerd 2021-11-19 09:40 評論0 收藏0
Dubbo Cloud Native 之路的實踐與思考

摘要：可簡單地認為它是的擴展，負載均衡自然成為不可或缺的特性。是基于開發的服務代理組件，在使用場景中，它與和整合，打造具備服務動態更新和負載均衡能力的服務網關。類似的特性在項目也有體現，它是另一種高性能代理的方案，提供服務發現健康和負載均衡。摘要： Cloud Native 應用架構隨著云技術的發展受到業界特別重視和關注，尤其是 CNCF（Cloud Native Computing Fo...

niceforbear 2019-06-24 18:03 評論0 收藏0
從容器到容器編排

摘要：從容器到容器編排平臺以及周邊生態系統包含很多工具來管理容器的生命周期。終止運行中的容器。發現在由運行于多個主機上的容器組成的分布式部署容器發現至關重要。類似的，當容器崩潰時，編排工具可以啟動替換。從容器到容器編排 Docker平臺以及周邊生態系統包含很多工具來管理容器的生命周期。例如，Docker Command Line Interface(CLI)支持下面的容器活動: 從注冊表...

Hydrogen 2019-06-28 16:25 評論0 收藏0
Dubbo Cloud Native 實踐與思考

摘要：可簡單地認為它是的擴展，負載均衡自然成為不可或缺的特性。類似的特性在項目也有體現，它是另一種高性能代理的方案，提供服務發現健康和負載均衡。 Dubbo Cloud Native 實踐與思考分享簡介 Cloud Native 應用架構隨著云技術的發展受到業界特別重視和關注，尤其是 CNCF（Cloud Native Computing Foundation）項目蓬勃發展之際。Dubbo...

邱勇 2019-06-28 10:58 評論0 收藏0