快捷導(dǎo)航

利用Service Fabric承載eShop On Containers的實現(xiàn)方法

更新時間：2018年01月09日 09:33:01 作者：云上的翅膀

下面小編就為大家分享一篇利用Service Fabric承載eShop On Containers的實現(xiàn)方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧

從Pet Shop 到eShop on Container都是Microsoft在技術(shù)演進的路徑上給開發(fā)者展示.Net的開發(fā)能力和架構(gòu)能力的Sample工程，Petshop的時候更多的是展現(xiàn)應(yīng)用的分層架構(gòu)，設(shè)計的抽象與模塊間的通訊。到了eShop on Container更多的關(guān)注在架構(gòu)設(shè)計與微服務(wù)化的，下面我們先來看看eshop on Container的架構(gòu)圖

在上圖，我們可以看到后端服務(wù)分成了

1 Identity microservice(驗證服務(wù))

2 Catalog microservice（商品分類服務(wù)）

3 Ordering microservice（訂單服務(wù)）

4 Basket microservice（購物車服務(wù)）

5 Marketing microservice（市場營銷服務(wù)）

6 Locations microservice（地理位置信息服務(wù)）

在以前的分層架構(gòu)中，通常這些服務(wù)都是以某一模塊來體現(xiàn)的，為什么現(xiàn)在要將他們拆分成了各個服務(wù)呢？當(dāng)我們從業(yè)務(wù)場景上面來看這些服務(wù)時，我們會發(fā)現(xiàn)每個服務(wù)的訪問峰值時間區(qū)間、容量規(guī)劃都是不一樣的，甚至實現(xiàn)這些服務(wù)最方便最簡單的技術(shù)棧都有可能是不一樣的（當(dāng)然強大的.net core無所不能，但是公司內(nèi)不同業(yè)務(wù)線上的技術(shù)儲備不一樣，就有可能選擇不同的技術(shù)實現(xiàn)）。這是因為如果我們都將這些模塊整合到了一個程序或者服務(wù)中的時候，就會碰到在不同時間內(nèi)服務(wù)高峰期擴展系統(tǒng)容量困難，要不就是資源不足，要不就是資源過剩。譬如搶購業(yè)務(wù)開始前大家提前個半小時登錄了系統(tǒng)，這時候系統(tǒng)最忙的是登錄模塊，到了開始搶購時間，系統(tǒng)最忙的是訂單模塊。不采用微服務(wù)架構(gòu)的話，半小時前準備給登錄模塊使用的資源不一定能夠及時的釋放出來給訂單模塊。如果兩個模塊都使用單一程序架構(gòu)的話，很可能出現(xiàn)的情況就是搶購的業(yè)務(wù)把所有資源都占滿了了，連其他正常訪問系統(tǒng)的用戶資源都被占用掉，導(dǎo)致系統(tǒng)崩潰。在講究Dev/Ops的今天，開發(fā)人員和架構(gòu)師需要更多的考慮硬件架構(gòu)層面對程序應(yīng)用帶來的影響。

用Service Fabric來承載eShop on Container微服務(wù)的方法一，通過Service Fabric直接管理Docker

首先我們先到Azure上申請一個Container Registry來承載eShop各個微服務(wù)程序的鏡像(image).創(chuàng)建Azure Docker Registry可以參考官方文檔：https://docs.microsoft.com/zh-cn/azure/container-registry/

現(xiàn)在最新版本Service Fabric已經(jīng)可以直接管理編排Docker了。

1.創(chuàng)建一個類型為Container的Service

2.在servicemanifest.xml中描述清楚image所在路徑

<CodePackage Name="Code" Version="1.0.0">
 <!-- Follow this link for more information about deploying Windows containers to Service Fabric: https://aka.ms/sfguestcontainers -->
 <EntryPoint>
 
  <ContainerHost>
  <ImageName>eshopsample.azurecr.io/catalog:latest</ImageName>  
  </ContainerHost>  
 </EntryPoint>
 <!-- Pass environment variables to your container: --> 
 <EnvironmentVariables>
  <EnvironmentVariable Name="HttpGatewayPort" Value=""/>
 </EnvironmentVariables>
 </CodePackage>

這里非常簡單，指定了image所在位置就好了，如果本身Docker Image里需要很多配置信息譬如：數(shù)據(jù)庫鏈接串、其他服務(wù)的地址等等都可以在EnvironmentVariables里面去配置。

3.配置Registry的訪問賬號密碼,需要在ApplicationManifest.xml上面來配置

<ServiceManifestImport>
 <ServiceManifestRef ServiceManifestName="CatalogService_Pkg" ServiceManifestVersion="1.0.1" />  
 <Policies>
  <ContainerHostPolicies CodePackageRef="Code" Isolation="hyperv">
  <RepositoryCredentials AccountName="youraccount" Password="xxxxxxxxxxxxx" PasswordEncrypted="false"/>
  <PortBinding ContainerPort="80" EndpointRef="CatalogServieEndpoint"/>
  
  </ContainerHostPolicies>
 </Policies>
 </ServiceManifestImport>

整個過程不會太復(fù)雜，只要配置好了Catalog microserivce的ServiceManifest.xm和ApplicationManifest.xml文件之后，我們可以用同樣的方法將其他服務(wù)一一配置完成，然后我們就可以將Service Fabric的配置Publish到Cluster上面了。

Service Fabric會自動根據(jù)配置在Cluster上面Pull Image和將Docker運行起來。非常簡單

用Service Fabric承載eShop on Container微服務(wù)的方法二：用Service Fabric的Runtime運行eShop on Container的微服務(wù)

Service Fabric本身就是個微服務(wù)的開發(fā)框架，現(xiàn)在已經(jīng)直接支持了.net Core 2.0了所以，我們更新了Service Fabric的SDK之后就可以直接創(chuàng)建.net core的服務(wù)了

eShop on Container的代碼都已經(jīng)是一份成型的.net core 2.0的代碼，所以不需要重新編寫服務(wù)。

1.通過nuget添加最新的Service Fabric最新的SDK。

2.修改programe.cs,啟動ServiceFabric Runtime而不是直接啟動Asp.net WebHost

public static void Main(string[] args)
  {
   try
   {
    // ServiceManifest.XML 文件定義一個或多個服務(wù)類型名稱。
    // 注冊服務(wù)會將服務(wù)類型名稱映射到 .NET 類型。
    // 在 Service Fabric 創(chuàng)建此服務(wù)類型的實例時，
    // 會在此主機進程中創(chuàng)建類的實例。
    ServiceRuntime.RegisterServiceAsync("Catalog.API",
     context => new CatalogAPI(context)).GetAwaiter().GetResult();
    ServiceEventSource.Current.ServiceTypeRegistered(Process.GetCurrentProcess().Id, typeof(CatalogAPI).Name);
    // 防止此主機進程終止，以使服務(wù)保持運行。 
    Thread.Sleep(Timeout.Infinite);
   }
   catch (Exception e)
   {
    ServiceEventSource.Current.ServiceHostInitializationFailed(e.ToString());
    throw;
   }
}

3.編寫

CatalogAPI 類用于啟動WebHost

internal sealed class CatalogAPI : StatelessService
 {
  public CatalogAPI(StatelessServiceContext context)
   : base(context)
  { }
  /// <summary>
  /// Optional override to create listeners (like tcp, http) for this service instance.
  /// </summary>
  /// <returns>The collection of listeners.</returns>
  protected override IEnumerable<ServiceInstanceListener> CreateServiceInstanceListeners()
  {
   return new ServiceInstanceListener[]
   {
    new ServiceInstanceListener(serviceContext =>
     new KestrelCommunicationListener(serviceContext, "ServiceEndpoint", (url, listener) =>
     {
      ServiceEventSource.Current.ServiceMessage(serviceContext, $"Starting WebListener on {url}");
            return new WebHostBuilder()
           .UseKestrel()
         .ConfigureServices(
          services => services
           .AddSingleton<StatelessServiceContext>(serviceContext))
         .UseContentRoot(Directory.GetCurrentDirectory())
         .ConfigureAppConfiguration((builderContext, config) =>
         {
          IHostingEnvironment env = builderContext.HostingEnvironment;
          config.AddJsonFile("settings.json", optional: false, reloadOnChange: true)
           .AddJsonFile($"appsettings.{env.EnvironmentName}.json", optional: true, reloadOnChange: true);
          
         })
         .UseStartup<Startup>()
         .UseServiceFabricIntegration(listener, ServiceFabricIntegrationOptions.None)
         .UseUrls(url)
         .UseWebRoot("Pics")
         .Build();     
     }))
   };
  }
 }

4.編寫serviceManifest.xml描述服務(wù)端口等信息

<?xml version="1.0" encoding="utf-8"?>
<ServiceManifest Name="Catalog.APIPkg"
     Version="1.0.3"
     xmlns="http://schemas.microsoft.com/2011/01/fabric"
     xmlns:xsd="http://www.w3.org/2001/XMLSchema"
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
 <ServiceTypes>
  <StatelessServiceType ServiceTypeName="Catalog.API" />
 </ServiceTypes>
 <!-- Code package is your service executable. -->
 <CodePackage Name="Code" Version="1.0.3">
 <EntryPoint>
  <ExeHost>
  <Program>Catalog.API.exe</Program>
  <WorkingFolder>CodePackage</WorkingFolder>
  </ExeHost>
 </EntryPoint>
 <EnvironmentVariables>
  <EnvironmentVariable Name="ASPNETCORE_ENVIRONMENT" Value="Development"/>
 </EnvironmentVariables>
 </CodePackage>

 <ConfigPackage Name="Config" Version="1.0.1" />
 <Resources>
 
 <Endpoints> 
 
  <Endpoint Protocol="http" Name="ServiceEndpoint" Type="Input" Port="5101" />
 </Endpoints>
 </Resources>
</ServiceManifest>

5.修改AppcationManifest.xml增加幾個服務(wù)的描述信息

添加ServiceImport節(jié)

<ServiceManifestImport>
 <ServiceManifestRef ServiceManifestName="Catalog.APIPkg" ServiceManifestVersion="1.0.3" />
 <ConfigOverrides />
 </ServiceManifestImport>

在DefaultService中描述Service

<Service Name="Catalog.API" ServiceDnsName="catalog.fabric.api">
  <StatelessService ServiceTypeName="Catalog.API" InstanceCount="[Catalog.API_InstanceCount]">
  <SingletonPartition />
  </StatelessService>
 </Service>

這樣我們就可以將Catalog這個服務(wù)改造成可以通過Service Fabric來管理的微服務(wù)了。通過Publish，我們可看到幾個服務(wù)都已經(jīng)在Service Fabric下面接受管理和編排了。