通过lms.samples熟悉lms微服务框架的使用详解_其它综合_

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

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

Exenet5.0AlwaysAlwaysAlways

 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 # 使用分号;来区分不同的服务注册中心 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;

 /// 
 /// 账号服务 /// 
 [ServiceRoute] public interface IAccountAppService { /// 
 /// 新增账号 /// 
 /// 账号信息 ///  Task Create(CreateAccountInput input); /// 
 /// 通过账号名称获取账号 /// 
 /// 账号名称 ///  [GetCachingIntercept("Account:Name:{0}")] [HttpGet("{name:string}")] Task GetAccountByName([CacheKey(0)] string name); /// 
 /// 通过Id获取账号信息 /// 
 /// 账号Id ///  [GetCachingIntercept("Account:Id:{0}")] [HttpGet("{id:long}")] Task GetAccountById([CacheKey(0)] long id); /// 
 /// 更新账号信息 /// 
 ///  ///  [UpdateCachingIntercept( "Account:Id:{0}")] Task Update(UpdateAccountInput input); /// 
 /// 删除账号信息 /// 
 /// 账号Id ///  [RemoveCachingIntercept("GetAccountOutput","Account:Id:{0}")] [HttpDelete("{id:long}")] Task Delete([CacheKey(0)]long id); /// 
 /// 订单扣款 /// 
 ///  ///  [Governance(ProhibitExtranet = true)] [RemoveCachingIntercept("GetAccountOutput","Account:Id:{0}")] [Transaction] Task DeductBalance(DeductBalanceInput input); }

 public class AccountAppService : IAccountAppService { private readonly IAccountDomainService _accountDomainService; public AccountAppService(IAccountDomainService accountDomainService) { _accountDomainService = accountDomainService; } public async Task Create(CreateAccountInput input) { var account = input.MapTo(); account = await _accountDomainService.Create(account); return account.MapTo(); } public async Task GetAccountByName(string name) { var account = await _accountDomainService.GetAccountByName(name); return account.MapTo(); } public async Task GetAccountById(long id) { var account = await _accountDomainService.GetAccountById(id); return account.MapTo(); } public async Task Update(UpdateAccountInput input) { var account = await _accountDomainService.Update(input); return account.MapTo(); } public Task Delete(long id) { return _accountDomainService.Delete(id); } [TccTransaction(ConfirmMethod = "DeductBalanceConfirm", CancelMethod = "DeductBalanceCancel")] public async Task 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); } }

 public class AccountDomainService : IAccountDomainService { private readonly IRepository _repository; private readonly IDistributedCache _accountCache; public AccountDomainService(IRepository repository, IDistributedCache accountCache) { _repository = repository; _accountCache = accountCache; } public async Task Create(Account account) { var exsitAccountCount = await _repository.GetCountAsync(p => p.Name == account.Name); if (exsitAccountCount
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                
                

                

                                            
上一篇：vscode通过Remote SSH远程连接及离线配置的方法_其它综合_
                                                                
下一篇：VS2019 自定义项目模板的实现方法_其它综合_