您好,登錄后才能下訂單哦!
這篇文章將為大家詳細(xì)講解有關(guān)Catalog Service如何解析微軟微服務(wù)架構(gòu),小編覺得挺實(shí)用的,因此分享給大家做個(gè)參考,希望大家閱讀完這篇文章后可以有所收獲。
我們先看下它的目錄結(jié)構(gòu),很標(biāo)準(zhǔn)的webapi目錄:
首先看下Program,跟IdentityService類似,多了一個(gè)UseWebRoot(“Pics”),把pics這個(gè)目錄設(shè)置成了webroot,其他都一樣。
在Startup的構(gòu)造方法中,我們也看到了使用了secret manager tool,但是多了一個(gè)參數(shù),在這里我們看到的是Assembly類型,其實(shí)secret只需要其中的userSecretsId而已。
在ConfigureServices中,我們看到如下代碼:
services.AddMvc(options => { options.Filters.Add(typeof(HttpGlobalExceptionFilter)); }).AddControllersAsServices();
添加了一個(gè)filter,這個(gè)HTtpGlobalExceptionFilter可以在項(xiàng)目中找到,大概的意思就是遇到拋出CatalogDomainException類型的錯(cuò)誤時(shí),返回特定的錯(cuò)誤碼。
AddControllersAsServices這個(gè)擴(kuò)展方法是把項(xiàng)目中的Controller都注冊(cè)到Services中,我們看下源碼:
public static IMvcCoreBuilder AddControllersAsServices(this IMvcCoreBuilder builder) { var feature = new ControllerFeature(); builder.PartManager.PopulateFeature(feature);foreach (var controller in feature.Controllers.Select(c => c.AsType())) { builder.Services.TryAddTransient(controller, controller); } builder.Services.Replace(ServiceDescriptor.Transient<IControllerActivator, ServiceBasedControllerActivator>());return builder; }
中間那段foreach就是,這樣我們?cè)陧?xiàng)目中通過依賴注入方式都能方便的訪問到各個(gè)controller了。
Going down:
services.AddDbContext<CatalogContext>(options => { options.UseSqlServer(Configuration["ConnectionString"], sqlServerOptionsAction: sqlOptions => { sqlOptions.MigrationsAssembly(typeof(Startup).GetTypeInfo().Assembly.GetName().Name); //Configuring Connection Resiliency: sqlOptions.EnableRetryOnFailure(maxRetryCount: 5, maxRetryDelay: TimeSpan.FromSeconds(30), errorNumbersToAdd: null); });// Changing default behavior when client evaluation occurs to throw. // Default in EF Core would be to log a warning when client evaluation is performed.options.ConfigureWarnings(warnings => warnings.Throw(RelationalEventId.QueryClientEvaluationWarning));//Check Client vs. Server evaluation: });
對(duì)DBContext的配置的時(shí)候,這里使用了Connection Resiliency(彈回連接)的方式,其中可以看到使用migration的時(shí)候,它使用了MigrationsAssembly(AssemblyName),這種方式跟我之前講的FluentNhibernate有點(diǎn)類似,EnableRetryOnFailure設(shè)置了這個(gè)Action的失敗嘗試機(jī)制,如果Migration的時(shí)候遇到Failure,就會(huì)自動(dòng)重試,這種方式避免了app與database分離造成的連接偶爾失敗造成的影響。為什么會(huì)有這個(gè)機(jī)制呢?因?yàn)楫?dāng)我們的database在云端的時(shí)候,比如Azure SQL,不可避免的會(huì)出現(xiàn)網(wǎng)絡(luò)連接問題,即使我們把a(bǔ)pp和database放在一個(gè)數(shù)據(jù)中心中,我相信偶爾也會(huì)有這個(gè)問題,我們現(xiàn)在可以通過配置,使其如果遇到失敗就會(huì)重新操作,一定程度避免了網(wǎng)絡(luò)偶爾造成的問題。你也可以設(shè)置一些策略,使其能夠在運(yùn)行命令的時(shí)候能夠進(jìn)行重試EF默認(rèn)情況下只是記錄client evaluation中的warns,我們可以通過ConfigureWarnings使其拋出這個(gè)警告,你也可以配置成忽略。
接下來我們看到如下代碼:
services.Configure<CatalogSettings>(Configuration);
我們可以在eShop的各個(gè)項(xiàng)目中都能找到類似的語(yǔ)句,它會(huì)把一些項(xiàng)目相關(guān)的Settings注冊(cè)到services中,使其成為環(huán)境變量,我們可通過setting.json進(jìn)行配置。除了通過setting.json進(jìn)行配置,我們還能通過Docker run –e 進(jìn)行靈活化配置。
在這里我們的CatalogSetting含有一個(gè)ExternalCatalogBaseUrl屬性,我們?cè)赿ocker run的時(shí)候可以輸入如下命令:
docke run -e "ExternalCatalogBaseUrl=http://localhost:5011/" ....
這樣就能靈活的通過docker命令進(jìn)行配置了,非常方便,我們也可以通過-e對(duì)我們setting.json中的變量進(jìn)行賦值,比如ConnectionString,你可以通過點(diǎn)擊了解更多相關(guān)內(nèi)容。
// Add framework services.services.AddSwaggerGen(); services.ConfigureSwaggerGen(options => { options.DescribeAllEnumsAsStrings(); options.SingleApiVersion(new Swashbuckle.Swagger.Model.Info() { Title = "eShopOnContainers - Catalog HTTP API", Version = "v1", Description = "The Catalog Microservice HTTP API. This is a Data-Driven/CRUD microservice sample", TermsOfService = "Terms Of Service" }); }); services.AddCors(options => { options.AddPolicy("CorsPolicy", builder => builder.AllowAnyOrigin() .AllowAnyMethod() .AllowAnyHeader() .AllowCredentials()); });
上面兩段代碼,分別配置了SwaggerGen和Cors(跨域)策略,SwaggenGen是一個(gè)非常實(shí)用的框架,它能自動(dòng)把我們的api轉(zhuǎn)為web方式呈現(xiàn)在我們眼前,還能進(jìn)行調(diào)試,非常好用。Cors的配置這里用的不好,它允許了所有請(qǐng)求,建議還是按照實(shí)際需求來吧,否則沒有跨域設(shè)置的意義了。
接下來我們看到了一系列的add service的操作,都是關(guān)于EventBus的,稍微看了下,發(fā)現(xiàn)目前只做了log的動(dòng)作,我們看下代碼:
if (raiseProductPriceChangedEvent) // Save and publish integration event if price has changed{//Create Integration Event to be published through the Event Busvar priceChangedEvent = new ProductPriceChangedIntegrationEvent(catalogItem.Id, productToUpdate.Price, oldPrice);// Achieving atomicity between original Catalog database operation and the IntegrationEventLog thanks to a local transactionawait _catalogIntegrationEventService.SaveEventAndCatalogContextChangesAsync(priceChangedEvent);// Publish through the Event Bus and mark the saved event as publishedawait _catalogIntegrationEventService.PublishThroughEventBusAsync(priceChangedEvent); }
上面的代碼意思是在價(jià)格有變動(dòng)的時(shí)候,我們就調(diào)用EventService進(jìn)行保存,同時(shí)對(duì)操作進(jìn)行了記錄。PublishThroughEventBusAsync方法則對(duì)這條記錄的State更改為published。目前來說我不太清楚為何要用這種方式,也不知道為何取名為EventBus,不過我在項(xiàng)目的issue中已經(jīng)提出了這個(gè)問題,希望項(xiàng)目的開發(fā)者們能給我一個(gè)答案。我有查看了Basket.Api,在這個(gè)項(xiàng)目中會(huì)有訂閱行為,具體的等到下一章我們?cè)僮屑?xì)看看。
ok,我們?cè)倏聪翪onfigure方法,下面一段代碼我們可以學(xué)習(xí)下:
var context = (CatalogContext)app .ApplicationServices.GetService(typeof(CatalogContext)); WaitForSqlAvailability(context, loggerFactory);
我們看到在這里它調(diào)用了之前注冊(cè)的CatalogContext,它并沒有通過new進(jìn)行實(shí)例化,而是通過GetService的方式獲取之前的注冊(cè),這樣context所依賴的其他實(shí)例也一并帶進(jìn)來了,非常方便好用。
WaitForSqlAvailability方法是對(duì)數(shù)據(jù)庫(kù)可用進(jìn)行嘗試,因?yàn)楹竺嫠枰M(jìn)行數(shù)據(jù)遷移。
CatalogService包含了2個(gè)Controller,一個(gè)是PicController,一個(gè)是CatalogController,PicController僅僅是根據(jù)ID獲取了圖片,CatalogController展示了用webapi如何做CURD。
如果你要運(yùn)行Catalog.Api,你必須安裝MSSQL和RabbitMQ,這次我把我的系統(tǒng)換成了Win10 Pro,并在電腦上使用Docker安裝了MSSQL-Server-Linux和RabbitMQ。安裝這2個(gè)非常簡(jiǎn)單,僅僅需要輸入幾條命令即可:
docker run --name mssql -e 'ACCEPT_EULA=Y' -e 'SA_PASSWORD=Pass@word' -p 5433:1433 -d microsoft/mssql-server-linux docker run -d --hostname my-rabbit --name rabbitmq -p 8080:15672 -p 5672:5672 rabbitmq:3-management
ok,我們使用docker創(chuàng)建了mssql和rabbitmq,這里注意一下,我把mssql的端口映射到了本機(jī)的5433上,還有rabbitmq的管理頁(yè)面,我映射到了本機(jī)的8080端口,你可以通過http://localhost:8080 進(jìn)行訪問。
上一篇我們說過我們可以通過iisexpress/Kestrel或者docker的形式運(yùn)行因?yàn)闋可娴脚渲?,所以這兩種方式的運(yùn)行有些不同。
一、iisExpress或Kestrel方式下,因?yàn)閯倓偽覀儼裮ssql和rabbitmq的端口都映射到了本機(jī),所以我們只需要在setting.json中把數(shù)據(jù)庫(kù)連接和rabbitmq的地址指向本機(jī)即可,如下:
{ "ConnectionString": "Server=tcp:127.0.0.1,5433;Initial Catalog=Microsoft.eShopOnContainers.Services.CatalogDb;User Id=sa;Password=Pass@word", "ExternalCatalogBaseUrl": "http://localhost:5101", "EventBusConnection": "localhost", "Logging": {"IncludeScopes": false,"LogLevel": { "Default": "Debug", "System": "Information", "Microsoft": "Information"} } }
ok,Ctrl+F5,運(yùn)行一下看看:
當(dāng)看到上面這個(gè)頁(yè)面,說明你的運(yùn)行正常了,你還得測(cè)試下api是否運(yùn)行正常,比如Pic,比如Items。
二、docker中運(yùn)行,參照上一篇的方式,先publish再build image, 不過這里要注意一點(diǎn),因?yàn)槟阒暗腃onnectionString和EventBusConnection都是指向本機(jī)(127.0.0.1)的,所以這里必須改一下,改成主機(jī)的ip地址或者是對(duì)應(yīng)容器的ip也可以,如果您不想更改的話,也可以通過docker -e進(jìn)行設(shè)置,比如:
docker run -p 8899:80 --name catalog -e "EventBusConnection=172.17.0.2" -d catalog:01
我這里的172.17.0.2是我rabbitmq容器的ip地址,你可以通過docker inspect containerId 進(jìn)行查看容器的ip。
如果一切配置都正確的話,你就可以通過瀏覽器http://localhost:8899 進(jìn)行瀏覽了。
當(dāng)然,除了正常瀏覽外,你還需測(cè)試下api是否正常。
在這個(gè)項(xiàng)目中有一些疑惑,希望大家能夠給我答案。
Connection Resiliency,我看了很久,字面意思是彈性連接,但我覺得用彈性好像不太適合,一般來講我們說的彈性都是指架構(gòu)或者系統(tǒng)的伸縮性,我一開始也是從這個(gè)角度去了解,但看了很多文章,覺得它只是讓我們?cè)趩?dòng)的時(shí)候,設(shè)置一些重試策略,在后面調(diào)用中可使用此策略,策略會(huì)根據(jù)你設(shè)置的重試次數(shù)、延遲時(shí)間等去自動(dòng)重試,避免因?yàn)榕紶柕腻e(cuò)誤造成的影響,所以覺得用彈回比較恰當(dāng)。
EventBus,我感覺很奇怪,為什么一定要取這個(gè)名字呢?在Android中,很明確的,它是進(jìn)行訂閱發(fā)布,消息傳遞,可以解耦發(fā)布者和訂閱者,但在Catalog.Api里,變成了記錄操作,沒有看到解耦,也沒有看到訂閱。在我的理解中,應(yīng)該在Startup進(jìn)行訂閱操作,發(fā)布者CatalogController在進(jìn)行update操作的時(shí)候,訂閱者進(jìn)行add log動(dòng)作,但在這個(gè)實(shí)例中,我看到的是同步進(jìn)行了這些操作,所以很不解。
Mssql-server-linux,當(dāng)你用Docker安裝了以后,你卻不能使用visual studio 2017的sql server data tools進(jìn)行查詢(只能進(jìn)行連接),為了查看效果,還需要安裝Microsoft Sql Server Management Studio(必須17版本以后)進(jìn)行查看。
關(guān)于Catalog Service如何解析微軟微服務(wù)架構(gòu)就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò),可以把它分享出去讓更多的人看到。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。