溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點(diǎn)擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

通過lms.samples熟悉lms微服務(wù)框架的使用解析

發(fā)布時間:2021-04-09 10:11:20 來源:億速云 閱讀:202 作者:啵贊 欄目:開發(fā)技術(shù)

這篇文章主要講解了“通過lms.samples熟悉lms微服務(wù)框架的使用解析”,文中的講解內(nèi)容簡單清晰,易于學(xué)習(xí)與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學(xué)習(xí)“通過lms.samples熟悉lms微服務(wù)框架的使用解析”吧!

lms.samples項(xiàng)目基本介紹

lms.sample項(xiàng)目由三個獨(dú)立的微服務(wù)應(yīng)用模塊組成:account、stock、order和一個網(wǎng)關(guān)項(xiàng)目gateway構(gòu)成。

業(yè)務(wù)應(yīng)用模塊

每個獨(dú)立的微服務(wù)應(yīng)用采用模塊化設(shè)計,主要由如下幾部分組成:

  1. 主機(jī)(Host): 主要用于托管微服務(wù)應(yīng)用本身,主機(jī)通過引用應(yīng)用服務(wù)項(xiàng)目(應(yīng)用接口的實(shí)現(xiàn)),托管微服務(wù)應(yīng)用,通過托管應(yīng)用服務(wù),在主機(jī)啟動的過程中,向服務(wù)注冊中心注冊服務(wù)路由。

  2. 應(yīng)用接口層(Application.Contracts): 用于定義應(yīng)用服務(wù)接口,通過應(yīng)用接口,該微服務(wù)模塊與其他微服務(wù)模塊或是網(wǎng)關(guān)進(jìn)行rpc通信的能力。在該項(xiàng)目中,除了定義應(yīng)用服務(wù)接口之前,一般還定義與該應(yīng)用接口相關(guān)的DTO對象。應(yīng)用接口除了被該微服務(wù)應(yīng)用項(xiàng)目引用,并實(shí)現(xiàn)應(yīng)用服務(wù)之前,還可以被網(wǎng)關(guān)或是其他微服務(wù)模塊引用。網(wǎng)關(guān)或是其他微服務(wù)項(xiàng)目通過應(yīng)用接口生成的代理與該微服務(wù)模塊通過rpc進(jìn)行通信。

  3. 應(yīng)用服務(wù)層(Application): 應(yīng)用服務(wù)是該微服務(wù)定義的應(yīng)用接口的實(shí)現(xiàn)。應(yīng)用服務(wù)與DDD傳統(tǒng)分層架構(gòu)的應(yīng)用層的概念一致。主要負(fù)責(zé)外部通信與領(lǐng)域?qū)又g的協(xié)調(diào)。一般地,應(yīng)用服務(wù)進(jìn)行業(yè)務(wù)流程控制,但是不包含業(yè)務(wù)邏輯的實(shí)現(xiàn)。

  4. 領(lǐng)域?qū)?Domain): 負(fù)責(zé)表達(dá)業(yè)務(wù)概念,業(yè)務(wù)狀態(tài)信息以及業(yè)務(wù)規(guī)則,是該微服務(wù)模塊的業(yè)務(wù)核心。一般地,在該層可以定義聚合根、實(shí)體、領(lǐng)域服務(wù)等對象。

  5. 領(lǐng)域共享層(Domain.Shared): 該層用于定義與領(lǐng)域?qū)ο笙嚓P(guān)的模型、實(shí)體等相關(guān)類型。不包含任何業(yè)務(wù)實(shí)現(xiàn),可以被其他微服務(wù)引用。

  6. 數(shù)據(jù)訪問(DataAccess)層: 該層一般用于封裝數(shù)據(jù)訪問相關(guān)的對象。例如:倉庫對象、 SqlHelper、或是ORM相關(guān)的類型等。在lms.samples中,通過efcore實(shí)現(xiàn)數(shù)據(jù)的讀寫操作。

通過lms.samples熟悉lms微服務(wù)框架的使用解析

服務(wù)聚合與網(wǎng)關(guān)

lms框架不允許服務(wù)外部與微服務(wù)主機(jī)直接通信,應(yīng)用請求必須通過http請求到達(dá)網(wǎng)關(guān),網(wǎng)關(guān)通過lms提供的中間件解析到服務(wù)條目,并通過rpc與集群內(nèi)部的微服務(wù)進(jìn)行通信。所以,如果服務(wù)需要與集群外部進(jìn)行通信,那么,開發(fā)者定義的網(wǎng)關(guān)必須要引用各個微服務(wù)模塊的應(yīng)用接口層;以及必須要使用lms相關(guān)的中間件。

開發(fā)環(huán)境

  1. .net版本: 5.0.101

  2. lms版本: 1.0.0

  3. IDE: (1) visual studio 最新版 (2) Rider(推薦)

主機(jī)與應(yīng)用托管

主機(jī)的創(chuàng)建步驟

通過lms框架創(chuàng)建一個業(yè)務(wù)模塊非常方便,只需要通過如下4個步驟,就可以輕松的創(chuàng)建一個lms應(yīng)用業(yè)務(wù)模塊。

1.創(chuàng)建項(xiàng)目

創(chuàng)建控制臺應(yīng)用(Console Application)項(xiàng)目,并且引用Silky.Lms.NormHost包。

dotnet add package Silky.Lms.NormHost --version 1.0.0

2.應(yīng)用程序入口與主機(jī)構(gòu)建

main方法中,通用.net的主機(jī)Host構(gòu)建并注冊lms微服務(wù)。在注冊lms微服務(wù)時,需要指定lms啟動的依賴模塊。

一般地,如果開發(fā)者不需要額外依賴其他模塊,也無需在應(yīng)用啟動或停止時執(zhí)行方法,那么您可以直接指定NormHostModule模塊。

 public class Program
    {
        public static async Task Main(string[] args)
        {
            await CreateHostBuilder(args).Build().RunAsync();
        }

        private static IHostBuilder CreateHostBuilder(string[] args)
        {
            return Host.CreateDefaultBuilder(args)
                    .RegisterLmsServices<NormHostModule>()
                ;
        }
    }

3.配置文件

lms框架支持yml或是json格式作為配置文件。通過appsettings.yml對lms框架進(jìn)行統(tǒng)一配置,通過appsettings.${Environment}.yml對不同環(huán)境變量下的配置項(xiàng)進(jìn)行設(shè)置。

開發(fā)者如果直接通過項(xiàng)目的方式啟動應(yīng)用,那么可以通過Properties/launchSettings.jsonenvironmentVariables.DOTNET_ENVIRONMENT環(huán)境變量。如果通過docker-compose的方式啟動應(yīng)用,那么可以通過.env設(shè)置DOTNET_ENVIRONMENT環(huán)境變量。

為保證配置文件有效,開發(fā)者需要顯式的將配置文件拷貝到項(xiàng)目生成目錄下。

4.引用應(yīng)用服務(wù)層和數(shù)據(jù)訪問層

一般地,主機(jī)項(xiàng)目需要引用該微服務(wù)模塊的應(yīng)用服務(wù)層和數(shù)據(jù)訪問層。只有主機(jī)引用應(yīng)用服務(wù)層,主機(jī)在啟動時,才會生成服務(wù)條目的路由,并且將服務(wù)路由注冊到服務(wù)注冊中心。

一個典型的主機(jī)項(xiàng)目文件如下所示:

<Project Sdk="Microsoft.NET.Sdk">

    <PropertyGroup>
        <OutputType>Exe</OutputType>
        <TargetFramework>net5.0</TargetFramework>
    </PropertyGroup>

    <ItemGroup>
      <PackageReference Include="Silky.Lms.NormHost" Version="$(LmsVersion)" />
    </ItemGroup>

    <ItemGroup>
      <None Update="appsettings.yml">
        <CopyToOutputDirectory>Always</CopyToOutputDirectory>
      </None>
      <None Update="appsettings.Production.yml">
        <CopyToOutputDirectory>Always</CopyToOutputDirectory>
      </None>
      <None Update="appsettings.Development.yml">
        <CopyToOutputDirectory>Always</CopyToOutputDirectory>
      </None>
    </ItemGroup>

    <ItemGroup>
      <ProjectReference Include="..\Lms.Account.Application\Lms.Account.Application.csproj" />
      <ProjectReference Include="..\Lms.Account.EntityFrameworkCore\Lms.Account.EntityFrameworkCore.csproj" />
    </ItemGroup>
</Project>

配置

一般地,一個微服務(wù)模塊的主機(jī)必須要配置:服務(wù)注冊中心、分布式鎖鏈接、分布式緩存地址、集群rpc通信token、數(shù)據(jù)庫鏈接地址等。

如果使用docker-compose來啟動和調(diào)試應(yīng)用的話,那么,rpc配置節(jié)點(diǎn)下的的host和port可以缺省,因?yàn)樯傻拿總€容器的都有自己的地址和端口號。

如果直接通過項(xiàng)目的方式啟動和調(diào)試應(yīng)用的話,那么,必須要配置rpc節(jié)點(diǎn)下的port,每個微服務(wù)模塊的主機(jī)應(yīng)用有自己的端口號。

lms框架的必要配置如下所示:

rpc:
  host: 0.0.0.0
  rpcPort: 2201
  token: ypjdYOzNd4FwENJiEARMLWwK0v7QUHPW
registrycenter:
  connectionStrings: 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183;127.0.0.1:2184,127.0.0.1:2185,127.0.0.1:2186 # 使用分號;來區(qū)分不同的服務(wù)注冊中心
  registryCenterType: Zookeeper
distributedCache:
  redis:
    isEnabled: true 
    configuration: 127.0.0.1:6379,defaultDatabase=0
lock:
  lockRedisConnection: 127.0.0.1:6379,defaultDatabase=1
connectionStrings:
    default: server=127.0.0.1;port=3306;database=account;uid=root;pwd=qwe!P4ss;

應(yīng)用接口

應(yīng)用接口定義

一般地,在應(yīng)用接口層開發(fā)者需要安裝Silky.Lms.Rpc包。如果該微服務(wù)模塊還涉及到分布式事務(wù),那么還需要安裝Silky.Lms.Transaction.Tcc,當(dāng)然,您也可以選擇在應(yīng)用接口層安裝Silky.Lms.Transaction包,在應(yīng)用服務(wù)層安裝Silky.Lms.Transaction.Tcc包。

  1. 開發(fā)者只需要在應(yīng)用接口通過ServiceRouteAttribute特性對應(yīng)用接口進(jìn)行直接即可。

  2. Lms約定應(yīng)用接口應(yīng)當(dāng)以IXxxAppService命名,這樣,服務(wù)條目生成的路由則會以api/xxx形式生成。當(dāng)然這并不是強(qiáng)制的。

  3. 每個應(yīng)用接口的方法都對應(yīng)著一個服務(wù)條目,服務(wù)條目的Id為: 方法的完全限定名 + 參數(shù)名

  4. 您可以在應(yīng)用接口層對方法的緩存、路由、服務(wù)治理、分布式事務(wù)進(jìn)行相關(guān)配置。該部分內(nèi)容請參考官方文檔

  5. 網(wǎng)關(guān)或是其他模塊的微服務(wù)項(xiàng)目需要引用服務(wù)應(yīng)用接口項(xiàng)目或是通過nuget的方式安裝服務(wù)應(yīng)用接口生成的包。

  6. [Governance(ProhibitExtranet = true)]可以標(biāo)識一個方法禁止與集群外部進(jìn)行通信,通過網(wǎng)關(guān)也不會生成swagger文檔。

  7. 應(yīng)用接口方法生成的WebApi支持restful API風(fēng)格。Lms支持通過方法的約定命名生成對應(yīng)http方法請求的WebApi。您當(dāng)然開發(fā)者也可以通過HttpMethodAttribute特性對某個方法進(jìn)行注解。

一個典型的應(yīng)用接口的定義

/// <summary>
    /// 賬號服務(wù)
    /// </summary>
    [ServiceRoute]
    public interface IAccountAppService
    {
        /// <summary>
        /// 新增賬號
        /// </summary>
        /// <param name="input">賬號信息</param>
        /// <returns></returns>
        Task<GetAccountOutput> Create(CreateAccountInput input);

        /// <summary>
        /// 通過賬號名稱獲取賬號
        /// </summary>
        /// <param name="name">賬號名稱</param>
        /// <returns></returns>
        [GetCachingIntercept("Account:Name:{0}")]
        [HttpGet("{name:string}")]
        Task<GetAccountOutput> GetAccountByName([CacheKey(0)] string name);

        /// <summary>
        /// 通過Id獲取賬號信息
        /// </summary>
        /// <param name="id">賬號Id</param>
        /// <returns></returns>
        [GetCachingIntercept("Account:Id:{0}")]
        [HttpGet("{id:long}")]
        Task<GetAccountOutput> GetAccountById([CacheKey(0)] long id);

        /// <summary>
        /// 更新賬號信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [UpdateCachingIntercept( "Account:Id:{0}")]
        Task<GetAccountOutput> Update(UpdateAccountInput input);

        /// <summary>
        /// 刪除賬號信息
        /// </summary>
        /// <param name="id">賬號Id</param>
        /// <returns></returns>
        [RemoveCachingIntercept("GetAccountOutput","Account:Id:{0}")]
        [HttpDelete("{id:long}")]
        Task Delete([CacheKey(0)]long id);

        /// <summary>
        /// 訂單扣款
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [Governance(ProhibitExtranet = true)]
        [RemoveCachingIntercept("GetAccountOutput","Account:Id:{0}")]
        [Transaction]
        Task<long?> DeductBalance(DeductBalanceInput input);
    }

應(yīng)用服務(wù)--應(yīng)用接口的實(shí)現(xiàn)

  1. 應(yīng)用服務(wù)層只需要引用應(yīng)用服務(wù)接口層以及領(lǐng)域服務(wù)層,并實(shí)現(xiàn)應(yīng)用接口相關(guān)的方法。

  2. 確保該微服務(wù)模塊的主機(jī)引用了該模塊的應(yīng)用服務(wù)層,這樣主機(jī)才能夠托管該應(yīng)用本身。

  3. 應(yīng)用服務(wù)層可以通過引用其他微服務(wù)模塊的應(yīng)用接口層項(xiàng)目(或是安裝nuget包,取決于開發(fā)團(tuán)隊(duì)的項(xiàng)目管理方法),與其他微服務(wù)模塊進(jìn)行rpc通信。

  4. 應(yīng)用服務(wù)層需要依賴領(lǐng)域服務(wù),通過調(diào)用領(lǐng)域服務(wù)的相關(guān)接口,實(shí)現(xiàn)該模塊的核心業(yè)務(wù)邏輯。

  5. DTO到實(shí)體對象或是實(shí)體對DTO對象的映射關(guān)系可以在該層指定映射關(guān)系。

一個典型的應(yīng)用服務(wù)的實(shí)現(xiàn)如下所示:

public class AccountAppService : IAccountAppService
    {
        private readonly IAccountDomainService _accountDomainService;

        public AccountAppService(IAccountDomainService accountDomainService)
        {
            _accountDomainService = accountDomainService;
        }

        public async Task<GetAccountOutput> Create(CreateAccountInput input)
        {
            var account = input.MapTo<Domain.Accounts.Account>();
            account = await _accountDomainService.Create(account);
            return account.MapTo<GetAccountOutput>();
        }

        public async Task<GetAccountOutput> GetAccountByName(string name)
        {
            var account = await _accountDomainService.GetAccountByName(name);
            return account.MapTo<GetAccountOutput>();
        }

        public async Task<GetAccountOutput> GetAccountById(long id)
        {
            var account = await _accountDomainService.GetAccountById(id);
            return account.MapTo<GetAccountOutput>();
        }

        public async Task<GetAccountOutput> Update(UpdateAccountInput input)
        {
            var account = await _accountDomainService.Update(input);
            return account.MapTo<GetAccountOutput>();
        }

        public Task Delete(long id)
        {
            return _accountDomainService.Delete(id);
        }

        [TccTransaction(ConfirmMethod = "DeductBalanceConfirm", CancelMethod = "DeductBalanceCancel")]
        public async Task<long?> DeductBalance(DeductBalanceInput input)
        {
            var account = await _accountDomainService.GetAccountById(input.AccountId);
            if (input.OrderBalance > account.Balance)
            {
                throw new BusinessException("賬號余額不足");
            }
            return await _accountDomainService.DeductBalance(input, TccMethodType.Try);
        }

        public Task DeductBalanceConfirm(DeductBalanceInput input)
        {
            return _accountDomainService.DeductBalance(input, TccMethodType.Confirm);
        }

        public Task DeductBalanceCancel(DeductBalanceInput input)
        {
            return _accountDomainService.DeductBalance(input, TccMethodType.Cancel);
        }
    }

領(lǐng)域?qū)?-微服務(wù)的核心業(yè)務(wù)實(shí)現(xiàn)

  1. 領(lǐng)域?qū)邮窃撐⒎?wù)模塊核心業(yè)務(wù)處理的模塊,一般用于定于聚合根、實(shí)體、領(lǐng)域服務(wù)、倉儲等業(yè)務(wù)對象。

  2. 領(lǐng)域?qū)右迷撐⒎?wù)模塊的應(yīng)用接口層,方便使用dto對象。

  3. 領(lǐng)域?qū)涌梢酝ㄟ^引用其他微服務(wù)模塊的應(yīng)用接口層項(xiàng)目(或是安裝nuget包,取決于開發(fā)團(tuán)隊(duì)的項(xiàng)目管理方法),與其他微服務(wù)模塊進(jìn)行rpc通信。

  4. 領(lǐng)域服務(wù)必須要直接或間接繼承ITransientDependency接口,這樣,該領(lǐng)域服務(wù)才會被注入到ioc容器。

  5. lms.samples 項(xiàng)目使用TanvirArjel.EFCore.GenericRepository包實(shí)現(xiàn)數(shù)據(jù)的讀寫操作。

一個典型的領(lǐng)域服務(wù)的實(shí)現(xiàn)如下所示:

public class AccountDomainService : IAccountDomainService
    {
        private readonly IRepository _repository;
        private readonly IDistributedCache<GetAccountOutput, string> _accountCache;

        public AccountDomainService(IRepository repository,
            IDistributedCache<GetAccountOutput, string> accountCache)
        {
            _repository = repository;
            _accountCache = accountCache;
        }

        public async Task<Account> Create(Account account)
        {
            var exsitAccountCount = await _repository.GetCountAsync<Account>(p => p.Name == account.Name);
            if (exsitAccountCount > 0)
            {
                throw new BusinessException($"已經(jīng)存在{account.Name}名稱的賬號");
            }

            exsitAccountCount = await _repository.GetCountAsync<Account>(p => p.Email == account.Email);
            if (exsitAccountCount > 0)
            {
                throw new BusinessException($"已經(jīng)存在{account.Email}Email的賬號");
            }

            await _repository.InsertAsync<Account>(account);
            return account;
        }

        public async Task<Account> GetAccountByName(string name)
        {
            var accountEntry = _repository.GetQueryable<Account>().FirstOrDefault(p => p.Name == name);
            if (accountEntry == null)
            {
                throw new BusinessException($"不存在名稱為{name}的賬號");
            }

            return accountEntry;
        }

        public async Task<Account> GetAccountById(long id)
        {
            var accountEntry = _repository.GetQueryable<Account>().FirstOrDefault(p => p.Id == id);
            if (accountEntry == null)
            {
                throw new BusinessException($"不存在Id為{id}的賬號");
            }

            return accountEntry;
        }

        public async Task<Account> Update(UpdateAccountInput input)
        {
            var account = await GetAccountById(input.Id);
            if (!account.Email.Equals(input.Email))
            {
                var exsitAccountCount = await _repository.GetCountAsync<Account>(p => p.Email == input.Email);
                if (exsitAccountCount > 0)
                {
                    throw new BusinessException($"系統(tǒng)中已經(jīng)存在Email為{input.Email}的賬號");
                }
            }

            if (!account.Name.Equals(input.Name))
            {
                var exsitAccountCount = await _repository.GetCountAsync<Account>(p => p.Name == input.Name);
                if (exsitAccountCount > 0)
                {
                    throw new BusinessException($"系統(tǒng)中已經(jīng)存在Name為{input.Name}的賬號");
                }
            }

            await _accountCache.RemoveAsync($"Account:Name:{account.Name}");
            account = input.MapTo(account);
            await _repository.UpdateAsync(account);
            return account;
        }

        public async Task Delete(long id)
        {
            var account = await GetAccountById(id);
            await _accountCache.RemoveAsync($"Account:Name:{account.Name}");
            await _repository.DeleteAsync(account);
        }

        public async Task<long?> DeductBalance(DeductBalanceInput input, TccMethodType tccMethodType)
        {
            var account = await GetAccountById(input.AccountId);
            var trans = await _repository.BeginTransactionAsync();
            BalanceRecord balanceRecord = null;
            switch (tccMethodType)
            {
                case TccMethodType.Try:
                    account.Balance -= input.OrderBalance;
                    account.LockBalance += input.OrderBalance;
                    balanceRecord = new BalanceRecord()
                    {
                        OrderBalance = input.OrderBalance,
                        OrderId = input.OrderId,
                        PayStatus = PayStatus.NoPay
                    };
                    await _repository.InsertAsync(balanceRecord);
                    RpcContext.GetContext().SetAttachment("balanceRecordId",balanceRecord.Id);
                    break;
                case TccMethodType.Confirm:
                    account.LockBalance -= input.OrderBalance;
                    var balanceRecordId1 = RpcContext.GetContext().GetAttachment("orderBalanceId")?.To<long>();
                    if (balanceRecordId1.HasValue)
                    {
                        balanceRecord = await _repository.GetByIdAsync<BalanceRecord>(balanceRecordId1.Value);
                        balanceRecord.PayStatus = PayStatus.Payed;
                        await _repository.UpdateAsync(balanceRecord);
                    }
                    break;
                case TccMethodType.Cancel:
                    account.Balance += input.OrderBalance;
                    account.LockBalance -= input.OrderBalance;
                    var balanceRecordId2 = RpcContext.GetContext().GetAttachment("orderBalanceId")?.To<long>();
                    if (balanceRecordId2.HasValue)
                    {
                        balanceRecord = await _repository.GetByIdAsync<BalanceRecord>(balanceRecordId2.Value);
                        balanceRecord.PayStatus = PayStatus.Cancel;
                        await _repository.UpdateAsync(balanceRecord);
                    }
                    break;
            }

           
            await _repository.UpdateAsync(account);
            await trans.CommitAsync();
            await _accountCache.RemoveAsync($"Account:Name:{account.Name}");
            return balanceRecord?.Id;
        }
    }

數(shù)據(jù)訪問(EntityFrameworkCore)--通過efcore實(shí)現(xiàn)數(shù)據(jù)讀寫

  • lms.samples項(xiàng)目使用orm框架efcore進(jìn)行數(shù)據(jù)讀寫。

  • lms提供了IConfigureService,通過繼承該接口即可使用IServiceCollection的實(shí)例指定數(shù)據(jù)上下文對象和注冊倉庫服務(wù)。

public class EfCoreConfigureService : IConfigureService
    {
        public void ConfigureServices(IServiceCollection services, IConfiguration configuration)
        {
            services.AddDbContext<OrderDbContext>(opt =>
                    opt.UseMySql(configuration.GetConnectionString("Default"),
                        ServerVersion.AutoDetect(configuration.GetConnectionString("Default"))))
                .AddGenericRepository<OrderDbContext>(ServiceLifetime.Transient)
                ;
        }

        public int Order { get; } = 1;
    }

3.主機(jī)項(xiàng)目需要顯式的引用該項(xiàng)目,只有這樣,該項(xiàng)目的ConfigureServices才會被調(diào)用。

4.數(shù)據(jù)遷移,請參考

應(yīng)用啟動與調(diào)試

獲取源碼

1.使用git 克隆lms項(xiàng)目源代碼,lms.samples存放在samples目錄下

# github
git clone https://github.com/liuhll/lms.git

# gitee
git clone https://gitee.com/liuhll2/lms.git

必要的前提

  1. 服務(wù)注冊中心zookeeper

  2. 緩存服務(wù)redis

  3. mysql數(shù)據(jù)庫

如果您電腦已經(jīng)安裝了docker以及docker-compose命令,那么您只需要進(jìn)入samples\docker-compose\infrastr目錄下,打開命令行工作,執(zhí)行如下命令就可以自動安裝zookeeperredis、mysql等服務(wù):

docker-compose -f .\docker-compose.mysql.yml -f .\docker-compose.redis.yml -f .\docker-compose.zookeeper.yml up -d

數(shù)據(jù)庫遷移

需要分別進(jìn)入到各個微服務(wù)模塊下的EntityFrameworkCore項(xiàng)目(例如:),執(zhí)行如下命令:

dotnet ef database update

例如: 需要遷移account模塊的數(shù)據(jù)庫如下所示:

通過lms.samples熟悉lms微服務(wù)框架的使用解析

order模塊和stock模塊與account模塊一致,在服務(wù)運(yùn)行前都需要通過數(shù)據(jù)庫遷移命令生成相關(guān)數(shù)據(jù)庫。

  1. 數(shù)據(jù)庫遷移指定數(shù)據(jù)庫連接地址默認(rèn)指定的是appsettings.Development.yml中配置的,您可以通過修改該配置文件中的connectionStrings.default配置項(xiàng)來指定自己的數(shù)據(jù)庫服務(wù)地址。

  2. 如果沒有dotnet ef命令,則需要通過dotnet tool install --global dotnet-ef安裝ef工具,請[參考] (https://docs.microsoft.com/zh-cn/ef/core/get-started/overview/install)

以項(xiàng)目的方式啟動和調(diào)試

使用visual studio作為開發(fā)工具

進(jìn)入到samples目錄下,使用visual studio打開lms.samples.sln解決方案,將項(xiàng)目設(shè)置為多啟動項(xiàng)目,并將網(wǎng)關(guān)和各個模塊的微服務(wù)主機(jī)設(shè)置為啟動項(xiàng)目,如下圖:

通過lms.samples熟悉lms微服務(wù)框架的使用解析

設(shè)置完成后直接啟動即可。

使用rider作為開發(fā)工具進(jìn)入到samples目錄下,使用rider打開lms.samples.sln解決方案,打開各個微服務(wù)模塊下的Properties/launchSettings.json,點(diǎn)擊圖中綠色的箭頭即可啟動項(xiàng)目。

通過lms.samples熟悉lms微服務(wù)框架的使用解析

啟動網(wǎng)關(guān)項(xiàng)目后,可以看到應(yīng)用接口的服務(wù)條目生成的swagger api文檔 http://localhost:5000/swagger。

通過lms.samples熟悉lms微服務(wù)框架的使用解析

默認(rèn)的環(huán)境變量為: Development,如果需要修改環(huán)境變量的話,可以通過Properties/launchSettings.json下的environmentVariables節(jié)點(diǎn)修改相關(guān)環(huán)境變量,請參考在 ASP.NET Core 中使用多個環(huán)境。

數(shù)據(jù)庫連接、服務(wù)注冊中心地址、以及redis緩存地址和分布式鎖連接等配置項(xiàng)可以通過修改appsettings.Development.yml配置項(xiàng)自定義指定。

以docker-compose的方式啟動和調(diào)試

進(jìn)入到samples目錄下,使用visual studio打開lms.samples.dockercompose.sln解決方案,將docker-compose設(shè)置為啟動項(xiàng)目,即可啟動和調(diào)式。

應(yīng)用啟動成功后,打開: http://127.0.0.1/swagger,即可看到swagger api文檔

通過lms.samples熟悉lms微服務(wù)框架的使用解析

以docker-compose的方式啟動和調(diào)試,則指定的環(huán)境變量為:ContainerDev

數(shù)據(jù)庫連接、服務(wù)注冊中心地址、以及redis緩存地址和分布式鎖連接等配置項(xiàng)可以通過修改appsettings.ContainerDev.yml配置項(xiàng)自定義指定,配置的服務(wù)連接地址不允許為: 127.0.0.1或是localhost

測試和調(diào)式

服務(wù)啟動成功后,您可以通過寫入/api/account-post接口和/api/product-post新增賬號和產(chǎn)品,然后通過/api/order-post接口進(jìn)行測試和調(diào)式。

開源地址

github: https://github.com/liuhll/lms

gitee: https://gitee.com/liuhll2/lms


感謝各位的閱讀,以上就是“通過lms.samples熟悉lms微服務(wù)框架的使用解析”的內(nèi)容了,經(jīng)過本文的學(xué)習(xí)后,相信大家對通過lms.samples熟悉lms微服務(wù)框架的使用解析這一問題有了更深刻的體會,具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云,小編將為大家推送更多相關(guān)知識點(diǎn)的文章,歡迎關(guān)注!

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI