Senaryo<\/h2>\n
Bir e-ticaret sistemi \u00fczerinde \u00e7al\u0131\u015ft\u0131\u011f\u0131m\u0131z\u0131 ve uygulamalar\u0131m\u0131z\u0131 kubernetes<\/em> \u00fczerinde host etti\u011fimizi d\u00fc\u015f\u00fcnelim. Kullan\u0131c\u0131lar ile ilgili i\u015flemlerden sorumlu bir User<\/em>\u00a0API<\/em>‘\u0131m\u0131z var. Yeni bir kullan\u0131c\u0131 sisteme kay\u0131t oldu\u011funda ise, “UserRegisteredEvent<\/em>” ad\u0131nda bir event publish ediliyor. Publish edilen bu event’in subscriber’lar\u0131ndan birisi ise, kullan\u0131c\u0131ya hesab\u0131n\u0131 aktifle\u015ftirebilmesi i\u00e7in e-posta g\u00f6ndermekle sorumlu bir service.<\/p>\n Biz ise asenkron olarak ger\u00e7ekle\u015fen bu kullan\u0131c\u0131 kay\u0131t journey’inin, OpenTracing API<\/em> ve Jaeger<\/em> tracer’\u0131n\u0131 implemente ederek, kubernetes<\/em> \u00fczerinde u\u00e7tan uca izleme i\u015flemini ger\u00e7ekle\u015ftirece\u011fiz.<\/p>\n K\u0131saca sizlere OpenTracing<\/em> ve Jaeger<\/em> hakk\u0131nda bilgi vermek istiyorum. OpenTracing<\/em>, herhangi bir vendor’a ba\u011f\u0131ml\u0131 olmadan uygulamalar\u0131m\u0131za distributed tracing i\u00e7in bir instrumentation ekleyebilmemizi sa\u011flayan bir specification’d\u0131r. T\u0131pk\u0131, OpenAPI<\/em> gibi.<\/p>\n Jaeger<\/em> ise Uber Technologies<\/em> taraf\u0131ndan geli\u015ftirilmi\u015f, OpenTracing<\/em> standart’lar\u0131n\u0131 destekleyen ve microservice mimarimiz \u00fczerinde distributed tracing i\u015flemlerini yapabilmemizi sa\u011flayan harika bir tracer’d\u0131r. Jaeger hakk\u0131nda daha detayl\u0131 bilgiye ise, buradan<\/a><\/em> ula\u015fabilirsiniz.<\/p>\n Jaeger<\/em>‘in kubernetes<\/em> \u00fczerine kurulumu i\u00e7in, \u015furadaki<\/a><\/em> dok\u00fcmanlar\u0131 takip edebilirsiniz. Ben bu makale i\u00e7in, development setup’\u0131n\u0131 uygulad\u0131m.<\/p>\n Jaeger<\/em> genel hatlar\u0131yla, “Agent<\/em>“, “Collector<\/em>” ve “Query<\/em>” den olu\u015fmaktad\u0131r. Agent,<\/em> UDP<\/em> \u00fczerinden kendisine gelen trace verilerini dinleyip, collector’e ileten bir network daemon’\u0131d\u0131r. Trace<\/em> verileri ise “Span<\/em>” olarak adland\u0131r\u0131lmaktad\u0131r. Collector<\/em> ise kendisine iletilen trace verilerini, bir pipeline (validations, indexes, transformations) i\u00e7erisinde i\u015flemektedir. Daha sonra ise se\u00e7ti\u011finiz bir component (Elasticsearch<\/em>, Cassandra ve<\/em>\u00a0Kafka<\/em>) t\u00fcr\u00fcne g\u00f6re store etmektedir.<\/p>\n Query<\/em> ise isminden de anla\u015f\u0131labilece\u011fi \u00fczere, ilgili trace sonu\u00e7lar\u0131n\u0131 sorgulayabilece\u011fimiz bir UI<\/em>.<\/p>\n Kodlamaya ba\u015flamadan \u00f6nce platform i\u00e7in sahip olmam\u0131z gereken baz\u0131 tool’lar:<\/p>\n NOT<\/em><\/strong>: Ana konumuz platformu olu\u015fturmak olmad\u0131\u011f\u0131 i\u00e7in, ben kurulum konular\u0131 \u00fczerinde durmayaca\u011f\u0131m.<\/p><\/blockquote>\n \u0130lk olarak kullan\u0131c\u0131lar\u0131n sisteme kay\u0131t olabilmelerini sa\u011flayacak olan User API<\/em>‘\u0131n\u0131 develop edelim. Bunun i\u00e7in \u00f6ncelikle a\u015fa\u011f\u0131daki gibi bir proje olu\u015ftural\u0131m.<\/p>\n Ard\u0131ndan “User.Common.Contracts<\/em>” isminde bir class library olu\u015ftural\u0131m.<\/p>\n Bu library i\u00e7erisinde uygulamalar\u0131m\u0131z aras\u0131nda share edece\u011fimiz contract’lar\u0131 tan\u0131mlayaca\u011f\u0131z. \u015eimdi yeni bir kullan\u0131c\u0131 sisteme kay\u0131t oldu\u011funda publish edece\u011fimiz event’i, a\u015fa\u011f\u0131daki gibi\u00a0olu\u015ftural\u0131m.<\/p>\n Olu\u015fturma i\u015fleminin ard\u0131ndan, “User.Common.Contracts<\/em>” library’sini, az \u00f6nce olu\u015fturmu\u015f oldu\u011fumuz “User.API<\/em>”\u00a0projesine referans olarak ekleyelim.<\/p>\n \u015eimdi “User.API<\/em>” projesi i\u00e7erisinde “Models<\/em>” isminde bir klas\u00f6r olu\u015ftural\u0131m ve ard\u0131ndan i\u00e7erisine “Requests<\/em>” ve “Responses<\/em>” klas\u00f6rlerini de olu\u015ftural\u0131m.<\/p>\n “Requests<\/em>” klas\u00f6r\u00fc i\u00e7erisine kullan\u0131c\u0131n\u0131n kay\u0131t olurken kullanaca\u011f\u0131 modeli a\u015fa\u011f\u0131daki gibi tan\u0131mlayal\u0131m.<\/p>\n “Responses<\/em>” klas\u00f6r\u00fc i\u00e7erisine ise, internal response wrapper class’\u0131n\u0131 tan\u0131mlayal\u0131m.<\/p>\n \u015eimdi ise “Services<\/em>” isminde bir klas\u00f6r olu\u015ftural\u0131m “User.API<\/em>” projesi i\u00e7erisinde. Ard\u0131ndan i\u00e7erisine a\u015fa\u011f\u0131daki gibi “IUserService<\/em>” isminde bir interface tan\u0131mlayal\u0131m.<\/p>\n Kullan\u0131c\u0131 ile ilgili business logic’leri, bu service arac\u0131l\u0131\u011f\u0131 ile ger\u00e7ekle\u015ftirece\u011fiz.<\/p>\n Bu noktada messaging ile ilgili i\u015flemleri reliable bir \u015fekilde ger\u00e7ekle\u015ftirebilmemiz i\u00e7in projemize NuGet<\/em> \u00fczerinden bir service bus ekleyece\u011fiz. Ben MassTransit<\/em>‘in lightweight bir wrapper’\u0131 olan MetroBus<\/em><\/a>\u00a0library’sini kullanaca\u011f\u0131m.<\/p>\n Ard\u0131ndan distributed tracing i\u015flemlerini ger\u00e7ekle\u015ftirebilmemiz i\u00e7in ise OpenTracing<\/em> ve Jaeger<\/em> package’lar\u0131n\u0131 eklememiz gerekmektedir.<\/p>\n \u015eimdi bir klas\u00f6re daha ihtiyac\u0131m\u0131z var. Ben structured klas\u00f6r yap\u0131lar\u0131n\u0131 seviyorum. Her neyse, “Services<\/em>” klas\u00f6r\u00fc alt\u0131nda, “Implementations<\/em>” ad\u0131nda bir klas\u00f6r olu\u015ftural\u0131m ve i\u00e7erisinde “IUserService<\/em>” interface’ini a\u015fa\u011f\u0131daki gibi implemente edelim.<\/p>\n Service i\u00e7erisinde k\u0131saca neler yapt\u0131k bir bakal\u0131m.<\/p>\n Trace context’inin di\u011fer service’lere otomatik olarak propagate edilmesi Jaeger<\/em> taraf\u0131ndan zaten otomatik olarak sa\u011flan\u0131yor. Yani api-to-api<\/strong> communication’\u0131 oldu\u011funda ve gerekli configuration’\u0131 yapt\u0131\u011f\u0131n\u0131zda, bir request’i u\u00e7tan uca izleyebiliyorsunuz.<\/p>\n Biz bu noktada ise api-to-subscriber<\/strong> olarak event-based bir communication ger\u00e7ekle\u015ftirdi\u011fimiz i\u00e7in, trace context’inin propagation i\u015flemini manuel olarak kendimiz sa\u011flad\u0131k. Trace scope’u i\u00e7erisine bakarsak, “create-user-async<\/em>” isminde bir span olu\u015fturduk. Sonras\u0131nda ise client oldu\u011funa dair bir tag ekledik. Tag’leri kullanarak span’a additional metadata’lar ekleyebilmek m\u00fcmk\u00fcnd\u00fcr. Ard\u0131ndan ise “TextMapInjectAdapter<\/em>” arac\u0131l\u0131\u011f\u0131 ile ilgili trace context’ini dictionary’e inject ettik.<\/p>\n Kullan\u0131c\u0131n\u0131n sisteme kay\u0131t olabilme i\u015flemlerini de tamamlayarak, tracing key’leri ile birlikte “UserRegisteredEvent<\/em>” ini service bus arac\u0131l\u0131\u011f\u0131 ile queue’ya publish ettik. Bu noktadan sonra ilgili event’i her kim consume ederse, tracing key’lerini kulland\u0131\u011f\u0131 s\u00fcrece t\u00fcm ak\u0131\u015f\u0131 g\u00f6zlemleyebilece\u011fiz.<\/p>\n Art\u0131k controller’\u0131 olu\u015fturabiliriz. A\u015fa\u011f\u0131daki gibi “UsersController<\/em>” isminde bir controller olu\u015ftural\u0131m.<\/p>\n Controller i\u00e7erisinde ise, olu\u015fturdu\u011fumuz “IUserService<\/em>” interface’i \u00fczerinden kullan\u0131c\u0131n\u0131n kay\u0131t i\u015flemlerini ger\u00e7ekle\u015ftiriyoruz.<\/p>\n \u015eimdi “Startup<\/em>” class’\u0131n\u0131 a\u00e7al\u0131m ve ilgili service injection i\u015flemlerini a\u015fa\u011f\u0131daki gibi ger\u00e7ekle\u015ftirelim.<\/p>\n Service bus’\u0131, RabbitMQ<\/em> kullanarak initialize ettik ve ard\u0131ndan injection i\u015flemini ger\u00e7ekle\u015ftirdik. Daha sonra ise tracer’\u0131 configure ederek inject ettik. Tracer’\u0131 yap\u0131land\u0131r\u0131rken ben sampling type’\u0131 olarak, “const<\/em>” sampler’\u0131 kulland\u0131m. Di\u011fer se\u00e7ebilece\u011finiz sampling se\u00e7enekleri ise “Probabilistic<\/em>“, “Rate Limiting<\/em>” ve “Remote<\/em>” \u015feklinde. Daha detayl\u0131 sampling bilgilerine ise buradan<\/a><\/em> eri\u015febilirsiniz. Agent host bilgisini de kubernetes<\/em> ortam\u0131n\u0131zdaki node IP<\/em>‘si ile de\u011fi\u015ftirebilirsiniz. E\u011fer agent kurulumunu sidecar<\/strong> olarak ger\u00e7ekle\u015ftirirseniz de, herhangi bir bilgi set etmenize gerek olmayacakt\u0131r. Default bilgilerle eri\u015fim sa\u011flayacakt\u0131r.<\/p>\n API<\/em> art\u0131k haz\u0131r durumda. Senaryomuza tekrar d\u00f6nelim. Kullan\u0131c\u0131 sisteme kay\u0131t olduktan sonra bir event publish edecektik. Daha sonra ise kullan\u0131c\u0131n\u0131n hesab\u0131n\u0131 aktifle\u015ftirebilmesi i\u00e7in o event’e subscribe olmu\u015f bir aktivasyon e-posta’s\u0131 g\u00f6nderen service olu\u015fturacakt\u0131k.<\/p>\n \u015eimdi event’i publish ettik ve art\u0131k kullan\u0131c\u0131ya aktivasyon e-posta’s\u0131n\u0131 g\u00f6nderecek olan service’i kodlamaya ba\u015flayabiliriz.<\/p>\n Bunun i\u00e7in yeni bir .NET Core<\/em> console application’\u0131 olu\u015ftural\u0131m.<\/p>\n Olu\u015fturman\u0131n ard\u0131ndan shared library olan “User.Common.Contracts<\/em>” projesini referans olarak ekleyelim. Daha sonra ise NuGet<\/em> \u00fczerinden MetroBus<\/em>‘\u0131, OpenTracing<\/em>‘i ve Jaeger’<\/em>i projeye a\u015fa\u011f\u0131daki gibi dahil edelim.<\/p>\n Console uygulamas\u0131, deamon olarak \u00e7al\u0131\u015facak bir background service olacak. App startup ve lifetime management’\u0131n\u0131 yapabilmemiz i\u00e7in ise NuGet<\/em> \u00fczerinden “Microsoft.Extensions.Hosting<\/em>” ve “Microsoft.Extensions.DependencyInjection<\/em>” paketlerini de projeye dahil edelim.<\/p>\n API<\/em> taraf\u0131nda hat\u0131rlarsak, tracing key’lerini event i\u00e7erisinde publish ederek trace context’inin propagation i\u015flemini manuel olarak ger\u00e7ekle\u015ftirmi\u015ftik. \u015eimdi ise consumer i\u00e7erisinde span olu\u015fturmak istedi\u011fimiz bir noktada, ayn\u0131 tracing key’lerini context’e extract ederek “TracingExtension<\/em>” class’\u0131 vas\u0131tas\u0131yla ger\u00e7ekle\u015ftirece\u011fiz.<\/p>\n<\/div>\n Bu noktada, daha \u00f6nce API <\/em>i\u00e7erisinden\u00a0publish etti\u011fimiz “UserRegisteredEvent<\/em>” model’ine subscribe i\u015flemini ger\u00e7ekle\u015ftiriyoruz. Ard\u0131ndan “ITracer<\/em>” interface’ini inject ediyoruz.<\/p>\n “Consume<\/em>” method’u i\u00e7erisinde ise, trace context’inin propagation i\u015flemini ger\u00e7ekle\u015ftirebilmemiz i\u00e7in olu\u015fturmu\u015f oldu\u011fumuz “TracingExtension<\/em>” class’\u0131n\u0131 kullanarak bir scope olu\u015fturuyoruz. Propagate edilmi\u015f trace context’li “user-activation-link-sender-consumer<\/em>” scope’u sayesinde, art\u0131k yapt\u0131\u011f\u0131m\u0131z i\u015flemleri api-to-subscriber\u00a0<\/strong>olarak trace edebilece\u011fiz.<\/p>\n<\/div>\n Implementation s\u0131ras\u0131nda yapt\u0131\u011f\u0131m\u0131z tek \u015fey, bus’\u0131 start ve stop etmek.<\/p>\n “Program<\/em>” class’\u0131n\u0131 ise a\u015fa\u011f\u0131daki gibi d\u00fczenleyelim.<\/p>\n<\/div>\n San\u0131r\u0131m yukar\u0131da yapt\u0131klar\u0131m\u0131z yeterince a\u00e7\u0131k ve net. Configuration’\u0131 ve dependency injection’\u0131 configure ederek, service’lerimizi inject ediyoruz. Ayr\u0131ca trace’i ise, “const<\/em>” type’\u0131 ile ve “User.Activation.Consumer<\/em>” ad\u0131yla initialize ediyoruz.<\/p>\n Consumer’\u0131 ise, “user.activation.queue<\/em>” ad\u0131nda bir queue ile register ediyoruz. Bu queue ile “UserRegisteredEvent<\/em>” model’ine subscribe olacakt\u0131r.<\/p>\n Art\u0131k uygulamalar\u0131 deploy etmeye haz\u0131r\u0131z. Ben deployment i\u015flemlerini ger\u00e7ekle\u015ftirebilmek i\u00e7in basit bir Docker<\/em> file ve Helm<\/em> chart haz\u0131rlad\u0131m. Bu chart ile, uygulamalar\u0131 Azure Kubernetes Service<\/em> \u00fczerine deploy edece\u011fim. Siz kendi environment’\u0131n\u0131za g\u00f6re chart’\u0131 de\u011fi\u015ftirebilirsiniz.<\/p>\n Haz\u0131rlam\u0131\u015f oldu\u011fum chart ve docker file’a, buradan<\/a><\/em> eri\u015febilirsiniz.<\/p>\n \u015eimdi test a\u015famas\u0131na ge\u00e7ebiliriz. \u00d6ncelikle sistemde yeni bir kullan\u0131c\u0131 olu\u015fturabilmek i\u00e7in a\u015fa\u011f\u0131da oldu\u011fu gibi “api\/users<\/em>” endpoint’ine bir POST<\/em> request’i g\u00f6nderelim.<\/p>\n Bu request ile kullan\u0131c\u0131 kay\u0131t journey’ini ba\u015flatm\u0131\u015f olduk. Senaryomuzda oldu\u011fu gibi, kullan\u0131c\u0131 kay\u0131t i\u015flemi ger\u00e7ekle\u015ftikten sonra bir event publish edildi.<\/p>\n Event’in publish edilmenin ard\u0131ndan event’e subscribe etmi\u015f oldu\u011fumuz aktivasyon e-posta’s\u0131n\u0131 g\u00f6nderecek olan service (user-activation-consumer) ilgili i\u015flemini ger\u00e7ekle\u015ftirmi\u015ftir.<\/p>\nOpenTracing<\/em> ve Jaeger<\/em> Nedir?<\/h2>\n
![\"\"](\"\/wp-content\/uploads\/2019\/04\/jaeger-logo-1.png\"){kind=logo}
<\/a><\/p>\nkubectl create -f https:\/\/raw.githubusercontent.com\/jaegertracing\/jaeger-kubernetes\/master\/all-in-one\/jaeger-all-in-one-template.yml<\/pre>\n
<\/a><\/p>\nPeki, Haydi Biraz Kodlayal\u0131m!<\/h2>\n
\n
dotnet new webapi -n User.API<\/pre>\n
<\/a><\/p>\ndotnet new classlib -n User.Common.Contracts<\/pre>\n
using System.Collections.Generic;\r\n\r\nnamespace User.Common.Contracts\r\n{\r\n public class UserRegisteredEvent\r\n {\r\n public string Email { get; set; }\r\n public Dictionary<string, string> TracingKeys { get; set; }\r\n }\r\n}<\/pre>\ndotnet add reference ..\/User.Common.Contracts\/User.Common.Contracts.csproj<\/pre>\n
namespace User.API.Models.Requests\r\n{\r\n public class CreateUserRequest\r\n {\r\n public string Username { get; set; }\r\n public string Password { get; set; }\r\n public string Email { get; set; }\r\n }\r\n}<\/pre>\nusing System.Collections.Generic;\r\nusing System.Linq;\r\n\r\nnamespace User.API.Models.Responses\r\n{\r\n public class BaseResponse\r\n {\r\n public BaseResponse()\r\n {\r\n Errors = new List();\r\n }\r\n\r\n public T Data { get; set; }\r\n public List Errors { get; set; }\r\n public bool HasError { get { return Errors.Any(); } }\r\n }\r\n}<\/pre>\nusing System.Threading.Tasks;\r\nusing User.API.Models.Requests;\r\nusing User.API.Models.Responses;\r\n\r\nnamespace User.API.Services\r\n{\r\n public interface IUserService\r\n {\r\n Task CreateUserAsync(CreateUserRequest request);\r\n }\r\n}<\/pre>\n<\/a><\/p>\ndotnet add package MetroBus\r\ndotnet add package MetroBus.Microsoft.Extensions.DependencyInjection<\/pre>\n
dotnet add package OpenTracing.Contrib.NetCore\r\ndotnet add package Jaeger<\/pre>\n
using System;\r\nusing System.Threading.Tasks;\r\nusing User.API.Models.Requests;\r\nusing User.API.Models.Responses;\r\nusing MassTransit;\r\nusing Microsoft.Extensions.Logging;\r\nusing User.Common.Contracts;\r\nusing OpenTracing;\r\nusing OpenTracing.Tag;\r\nusing OpenTracing.Propagation;\r\nusing System.Collections.Generic;\r\n\r\nnamespace User.API.Services.Implementations\r\n{\r\n public class UserService : IUserService\r\n {\r\n private readonly ILogger _logger;\r\n private readonly IBusControl _busControl;\r\n private readonly ITracer _tracer;\r\n\r\n public UserService(ILogger logger, IBusControl busControl, ITracer tracer)\r\n {\r\n _logger = logger;\r\n _busControl = busControl;\r\n _tracer = tracer;\r\n }\r\n\r\n public async Task CreateUserAsync(CreateUserRequest request)\r\n {\r\n BaseResponse createUserResponse = new BaseResponse();\r\n\r\n try\r\n {\r\n using (var scope = _tracer.BuildSpan(\"create-user-async\").StartActive(finishSpanOnDispose: true))\r\n {\r\n var span = scope.Span.SetTag(Tags.SpanKind, Tags.SpanKindClient);\r\n\r\n var dictionary = new Dictionary<string, string>();\r\n _tracer.Inject(span.Context, BuiltinFormats.TextMap, new TextMapInjectAdapter(dictionary));\r\n\r\n \/\/some user create business logics\r\n\r\n createUserResponse.Data = 1; \/\/ User id\r\n\r\n await _busControl.Publish(new UserRegisteredEvent\r\n {\r\n Email = request.Email,\r\n TracingKeys = dictionary\r\n });\r\n }\r\n }\r\n catch (Exception ex)\r\n {\r\n createUserResponse.Errors.Add(ex.Message);\r\n _logger.LogError(ex, ex.Message);\r\n }\r\n\r\n return createUserResponse;\r\n }\r\n }\r\n}<\/pre>\n<\/a><\/p>\nusing Microsoft.AspNetCore.Mvc;\r\nusing User.API.Services;\r\nusing User.API.Models.Requests;\r\nusing User.API.Models.Responses;\r\nusing System.Threading.Tasks;\r\n\r\nnamespace User.API.Controllers\r\n{\r\n [Route(\"api\/users\")]\r\n [ApiController]\r\n public class UsersController : ControllerBase\r\n {\r\n private readonly IUserService _userService;\r\n\r\n public UsersController(IUserService userService)\r\n {\r\n _userService = userService;\r\n }\r\n\r\n [HttpPost]\r\n public async Task Post([FromBody]CreateUserRequest request)\r\n {\r\n BaseResponse createUserResponse = await _userService.CreateUserAsync(request);\r\n\r\n if(!createUserResponse.HasError)\r\n {\r\n return Created(\"users\", createUserResponse.Data);\r\n }\r\n else\r\n {\r\n return BadRequest(createUserResponse.Errors);\r\n }\r\n }\r\n }\r\n}<\/pre>\npublic void ConfigureServices(IServiceCollection services)\r\n{\r\n services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);\r\n\r\n services.AddScoped<IUserService, UserService>();\r\n\r\n string rabbitMqUri = Configuration.GetValue(\"RabbitMqUri\");\r\n string rabbitMqUserName = Configuration.GetValue(\"RabbitMqUserName\");\r\n string rabbitMqPassword = Configuration.GetValue(\"RabbitMqPassword\");\r\n\r\n services.AddSingleton(MetroBusInitializer.Instance.UseRabbitMq(rabbitMqUri, rabbitMqUserName, rabbitMqPassword).Build());\r\n\r\n services.AddOpenTracing();\r\n services.AddSingleton(serviceProvider =>\r\n {\r\n Environment.SetEnvironmentVariable(\"JAEGER_SERVICE_NAME\", \"User.API\");\r\n Environment.SetEnvironmentVariable(\"JAEGER_AGENT_HOST\", \"localhost\");\r\n Environment.SetEnvironmentVariable(\"JAEGER_AGENT_PORT\", \"6831\");\r\n Environment.SetEnvironmentVariable(\"JAEGER_SAMPLER_TYPE\", \"const\");\r\n \r\n var loggerFactory = new LoggerFactory();\r\n\r\n var config = Jaeger.Configuration.FromEnv(loggerFactory);\r\n var tracer = config.GetTracer();\r\n\r\n GlobalTracer.Register(tracer);\r\n\r\n return tracer;\r\n });\r\n\r\n services.AddHealthChecks();\r\n}\r\n\r\npublic void Configure(IApplicationBuilder app, IHostingEnvironment env)\r\n{\r\n \/\/...\r\n \r\n app.UseHealthChecks(\"\/health\");\r\n}<\/pre>\nSubscriber’\u0131n Kodlanmas\u0131<\/h2>\n
dotnet new console -n User.Activation.Consumer<\/pre>\n
dotnet add package MetroBus\r\ndotnet add package MetroBus.Microsoft.Extensions.DependencyInjection\r\ndotnet add package OpenTracing.Contrib.NetCore \r\ndotnet add package Jaeger\r\n<\/pre>\n
dotnet add package Microsoft.Extensions.Hosting\r\ndotnet add package Microsoft.Extensions.DependencyInjection<\/pre>\n
dotnet add package Microsoft.Extensions.Configuration\r\ndotnet add package Microsoft.Extensions.Configuration.Json<\/pre>\n<\/div>\n
using System;\r\nusing System.Collections.Generic;\r\nusing OpenTracing;\r\nusing OpenTracing.Propagation;\r\nusing OpenTracing.Tag;\r\n\r\nnamespace User.Activation.Consumer.Common\r\n{\r\n public static class TracingExtension\r\n {\r\n public static IScope StartServerSpan(ITracer tracer, IDictionary<string, string> headers, string operationName)\r\n {\r\n ISpanBuilder spanBuilder;\r\n try\r\n {\r\n ISpanContext parentSpanCtx = tracer.Extract(BuiltinFormats.TextMap, new TextMapExtractAdapter(headers));\r\n\r\n spanBuilder = tracer.BuildSpan(operationName);\r\n if (parentSpanCtx != null)\r\n {\r\n spanBuilder = spanBuilder.AsChildOf(parentSpanCtx);\r\n }\r\n }\r\n catch (Exception)\r\n {\r\n spanBuilder = tracer.BuildSpan(operationName);\r\n }\r\n\r\n return spanBuilder.WithTag(Tags.SpanKind, Tags.SpanKindConsumer).StartActive(true);\r\n }\r\n }\r\n}<\/pre>\n
\n—> Consumers<\/div>\nusing System.Threading.Tasks;\r\nusing MassTransit;\r\nusing OpenTracing;\r\nusing User.Activation.Consumer.Common;\r\nusing User.Common.Contracts;\r\n\r\nnamespace User.Activation.Consumer.Consumers\r\n{\r\n public class UserActivationConsumer : IConsumer<UserRegisteredEvent>\r\n {\r\n private readonly ITracer _tracer;\r\n\r\n public UserActivationConsumer(ITracer tracer)\r\n {\r\n _tracer = tracer;\r\n }\r\n\r\n public async Task Consume(ConsumeContext<UserRegisteredEvent> context)\r\n {\r\n using (var scope = TracingExtension.StartServerSpan(_tracer, context.Message.TracingKeys, \"user-activation-link-sender-consumer\"))\r\n {\r\n \/\/some user activation link send business logics\r\n\r\n await System.Console.Out.WriteLineAsync($\"Activation link sent for {context.Message.Email}\");\r\n }\r\n }\r\n }\r\n}<\/pre>\nusing System.Threading;\r\nusing System.Threading.Tasks;\r\nusing MassTransit;\r\nusing Microsoft.Extensions.Hosting;\r\n\r\nnamespace User.Activation.Consumer.Services.Implementations\r\n{\r\n public class BusService : IHostedService\r\n {\r\n private readonly IBusControl _busControl;\r\n\r\n public BusService(IBusControl busControl)\r\n {\r\n _busControl = busControl;\r\n }\r\n\r\n public Task StartAsync(CancellationToken cancellationToken)\r\n {\r\n return _busControl.StartAsync(cancellationToken);\r\n }\r\n\r\n public Task StopAsync(CancellationToken cancellationToken)\r\n {\r\n return _busControl.StopAsync(cancellationToken);\r\n }\r\n }\r\n}<\/pre>\nusing System;\r\nusing System.IO;\r\nusing System.Threading.Tasks;\r\nusing Jaeger;\r\nusing Jaeger.Samplers;\r\nusing MassTransit;\r\nusing MetroBus;\r\nusing MetroBus.Microsoft.Extensions.DependencyInjection;\r\nusing Microsoft.Extensions.Configuration;\r\nusing Microsoft.Extensions.DependencyInjection;\r\nusing Microsoft.Extensions.Hosting;\r\nusing Microsoft.Extensions.Logging;\r\nusing OpenTracing;\r\nusing OpenTracing.Util;\r\nusing User.Activation.Consumer.Consumers;\r\nusing User.Activation.Consumer.Services.Implementations;\r\n\r\nnamespace User.Activation.Consumer\r\n{\r\n class Program\r\n {\r\n static async Task Main(string[] args)\r\n {\r\n var host = new HostBuilder()\r\n .ConfigureAppConfiguration((hostingContext, config) =>\r\n {\r\n config.SetBasePath(basePath: Directory.GetCurrentDirectory());\r\n config.AddJsonFile(\"appsettings.json\", optional : true);\r\n })\r\n .ConfigureServices((hostContext, services) =>\r\n {\r\n \/\/Init tracer\r\n services.AddSingleton<ITracer>(t => InitTracer());\r\n\r\n string rabbitMqUri = hostContext.Configuration.GetValue<string>(\"RabbitMqUri\");\r\n string rabbitMqUserName = hostContext.Configuration.GetValue<string>(\"RabbitMqUserName\");\r\n string rabbitMqPassword = hostContext.Configuration.GetValue<string>(\"RabbitMqPassword\");\r\n\r\n services.AddMetroBus(x =>\r\n {\r\n x.AddConsumer<UserActivationConsumer>();\r\n });\r\n\r\n services.AddSingleton<IBusControl>(provider => MetroBusInitializer.Instance\r\n .UseRabbitMq(rabbitMqUri, rabbitMqUserName, rabbitMqPassword)\r\n .RegisterConsumer<UserActivationConsumer>(\"user.activation.queue\", provider)\r\n .Build());\r\n\r\n services.AddHostedService<BusService>();\r\n });\r\n\r\n await host.RunConsoleAsync();\r\n }\r\n\r\n private static ITracer InitTracer()\r\n {\r\n Environment.SetEnvironmentVariable(\"JAEGER_SERVICE_NAME\", \"User.Activation.Consumer\");\r\n Environment.SetEnvironmentVariable(\"JAEGER_AGENT_HOST\", \"localhost\");\r\n Environment.SetEnvironmentVariable(\"JAEGER_AGENT_PORT\", \"6831\");\r\n Environment.SetEnvironmentVariable(\"JAEGER_SAMPLER_TYPE\", \"const\");\r\n\r\n var loggerFactory = new LoggerFactory();\r\n\r\n var config = Jaeger.Configuration.FromEnv(loggerFactory);\r\n var tracer = config.GetTracer();\r\n\r\n GlobalTracer.Register(tracer);\r\n\r\n return tracer;\r\n }\r\n }\r\n}<\/pre>\nDeployment<\/h2>\n
Test<\/h2>\n
<\/a><\/p>\n<\/a><\/p>\n