<\/div>\n

Merhaba,<\/p>\n

\u00d6nceki Asp.NET Core + Event Store \u0130le Event Sourcing Uygulamas\u0131(\u00d6rneklendirme)<\/a> ba\u015fl\u0131kl\u0131 yaz\u0131mda bir veri \u00fczerinde yap\u0131lan t\u00fcm i\u015flemleri Event Store tool’u ile kay\u0131t alt\u0131na alm\u0131\u015f ve b\u00f6ylece Event Sourcing’in Write Data Store<\/em> kanad\u0131n\u0131 tamamlam\u0131\u015ft\u0131k. Bu i\u00e7eri\u011fimizde ise ilgili verilere dair sorgulama ihtiya\u00e7lar\u0131na istinaden Event Store tool’undaki event’leri \u015fartl\u0131 sorgulayamad\u0131\u011f\u0131m\u0131zdan\/sorgulayamayaca\u011f\u0131m\u0131zdan dolay\u0131 Event Sourcing’in Read Data Store<\/em> k\u0131sm\u0131yla ilgilenecek ve gelen event’lerin bir b\u00fct\u00fcn\u00fc temsil edecek \u015fekilde sadece read i\u015flemleri i\u00e7in herhangi bir veritaban\u0131na kaydedilmesini ve i\u015flenmesini sa\u011flam\u0131\u015f olaca\u011f\u0131z. Bu veritaban\u0131 relational olabilece\u011fi gibi NoSQL bir yakla\u015f\u0131m\u0131 da benimsemi\u015f herhangi bir teknoloji olabilecektir. Bizler bu i\u00e7eri\u011fimizde MongoDB \u00fczerinden \u00f6rneklendirme yap\u0131yor olaca\u011f\u0131z. Anlayaca\u011f\u0131n\u0131z g\u00fczel ve heyecanl\u0131 bir serinin devam\u0131 niteli\u011finde olacak bu i\u00e7eri\u011fimiz, sizlerde ya\u015fatt\u0131\u011f\u0131 kadar bende de heyecan yaratmakta oldu\u011fu i\u00e7in hi\u00e7 vakit kaybetmeden konuya giri\u015f yapal\u0131m istiyorum…<\/p>\n

Ba\u015flarken<\/h3>\n
$\"Asp.NET$ <\/a>
Yap\u0131lan de\u011fi\u015fiklik neticesinde eklenen Shared katman\u0131…<\/p><\/div>\u0130lk olarak, yukar\u0131da konuyla alakal\u0131 olarak referans etti\u011fim ilgili makalede sunulan mimaride ufakta olsa bir de\u011fi\u015fiklik yaparak ba\u015flamak istiyorum. Bu de\u011fi\u015fiklik, bu i\u00e7eri\u011fimizde uygulayaca\u011f\u0131m\u0131z Read Data Store operasyonunun sorumlulu\u011funu s\u0131radan bir Console uygulamas\u0131na verece\u011fimizden kaynaklanmaktad\u0131r. Bu console uygulamas\u0131, Event Store’a i\u015flenen herhangi bir event durumunda subscribe olunan messaging \u00fczerinden tetiklenecek ve veritaban\u0131nda ilgili data’ya dair create, update yahut delete operasyonlar\u0131n\u0131 ger\u00e7ekle\u015ftirecektir. Haliyle \u00f6nceki yaz\u0131da sunulan Model ve Event Type class’lar\u0131n\u0131n bu console uygulamas\u0131ndan eri\u015filebilir olmas\u0131 gerekecektir. Haliyle mimaride bahsedilen class’lar\u0131 her iki uygulamadan da eri\u015filebilir hale getirebilmek i\u00e7in ‘Shared’ isimli class library’e alm\u0131\u015f ve di\u011fer iki uygulama taraf\u0131ndan referans etmi\u015f bulunmaktay\u0131m. Yap\u0131lan de\u011fi\u015fiklikleri daha net anlayabilmek i\u00e7in i\u00e7eri\u011fimizin sonunda payla\u015fm\u0131\u015f oldu\u011fum projenin son halini indirip fiziksel g\u00f6zlem yapabilirsiniz.<\/p>\n
MongoDB.Driver ve EventStore.ClientAPI K\u00fct\u00fcphanelerinin Y\u00fcklenmesi ve Temel Konfig\u00fcrasyonlar<\/h6>\n
\u0130lk olarak Read Data Store operasyonunu y\u00fcr\u00fctecek olan Console uygulamam\u0131zda MongoDB ve Event Store i\u015flemlerinin y\u00fcr\u00fct\u00fclebilmesi i\u00e7in s\u0131ras\u0131yla MongoDB.Driver<\/a> ve EventStore.Client<\/a> k\u00fct\u00fcphanelerinin y\u00fcklenmesi gerekmektedir.<\/p>\n
Ard\u0131ndan her iki sunucuyla ilgili konfig\u00fcrasyonlar\u0131 a\u015fa\u011f\u0131daki gibi ger\u00e7ekle\u015ftirelim;<\/p>\n
MongoDBConfiguration:<\/p>\n
\r\n static public class MongoDBConfiguration\r\n {\r\n static IMongoDatabase database;\r\n public static void GetDatabase()\r\n {\r\n if (database == null)\r\n {\r\n MongoClient mongoClient = new("mongodb:\/\/localhost:27017");\r\n database = mongoClient.GetDatabase("EventStoreReadDB");\r\n }\r\n }\r\n public static IMongoCollection<T> Collection<T>(string collectionName)\r\n {\r\n GetDatabase();\r\n IMongoCollection<T> collection = database.GetCollection<T>(collectionName);\r\n return collection;\r\n }\r\n }\r\n<\/pre>\n
Yukar\u0131daki kod blo\u011funu incelerseniz e\u011fer ‘GetDatabase’ metodu i\u00e7erisinde veritaban\u0131 yoksa olu\u015fturulmakta ard\u0131ndan ‘Collection’ metodu i\u00e7erisinde ise parametre de\u011ferine uygun collection geriye d\u00f6n\u00fclmektedir.<\/p>\n
EventStoreConfiguration: <\/p>\n
\r\n public static class EventStoreConfiguration\r\n {\r\n public static async Task<IEventStoreConnection> Connect()\r\n {\r\n IEventStoreConnection connection = EventStoreConnection.Create(\r\n connectionString: "ConnectTo=tcp:\/\/localhost:1115;DefaultUserCredentials=admin:changeit;UseSslConnection=true;TargetHost=eventstore.org;ValidateServer=false",\r\n connectionName: "Console_Application",\r\n builder: ConnectionSettings.Create().KeepReconnecting()\r\n );\r\n\r\n await connection.ConnectAsync();\r\n connection.Connected += (object sender, ClientConnectionEventArgs e) => Console.WriteLine("Event Store dinlenmektedir...");\r\n return connection;\r\n }\r\n }\r\n<\/pre>\n
Bu kod blo\u011funda ise Event Store’a ba\u011flant\u0131 sa\u011flam\u0131\u015f olan bir connection yarat\u0131lmaktad\u0131r.<\/p>\n
Read Data Store’a Event’lerin \u0130\u015flenmesi<\/h6>\n
Event Store’a event eklendik\u00e7e Read Data Store veritaban\u0131ndaki(MongoDB) ilgili veriye bu event’leri i\u015fleyebilmek i\u00e7in yukar\u0131da olu\u015fturulmu\u015f olan ‘EventStoreConfiguration’ konfig\u00fcrasyonundaki connection’a a\u015fa\u011f\u0131daki extension metodun yaz\u0131lmas\u0131 \u00e7\u00f6z\u00fcmlerden biri olacakt\u0131r:<\/p>\n
\r\n static public class StreamSubscriber\r\n {\r\n public static async Task UserSubscribe(this IEventStoreConnection connection, IMongoCollection<User> userCollection)\r\n {\r\n await connection.SubscribeToAllAsync(\r\n resolveLinkTos: true,\r\n eventAppeared: async (eventStoreSubscription, resolvedEvent) =>\r\n {\r\n \/\/Return Type class'\u0131 farkl\u0131 bir class library ya da proje de ise bu \u015fekilde metinsel olarak nitelendirilip\r\n \/\/Type.GetType(...)'a verilmelidir.\r\n var returnType = $"{Encoding.UTF8.GetString(resolvedEvent.Event.Metadata)}, Shared, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null";\r\n Type eventType = Type.GetType(returnType);\r\n object @event = JsonSerializer.Deserialize(Encoding.UTF8.GetString(resolvedEvent.Event.Data), eventType);\r\n\r\n User user = null;\r\n UpdateDefinition<User> update = null;\r\n switch (@event)\r\n {\r\n case UserCreated o:\r\n \/\/User'\u0131 veritaban\u0131na ekle\r\n user = new()\r\n {\r\n Id = o.UserId,\r\n Email = o.Email,\r\n EmailApprove = o.EmailApprove,\r\n Name = o.Name,\r\n UserName = o.UserName\r\n };\r\n await userCollection.InsertOneAsync(user);\r\n break;\r\n case UserNameChanged o:\r\n \/\/User'\u0131 veritaban\u0131ndan \u00e7ek ve ad\u0131n\u0131 g\u00fcncelle\r\n update = Builders<User>.Update.Set(u => u.Name, o.NewName);\r\n await userCollection.UpdateOneAsync(f => f.Id == o.UserId, update);\r\n break;\r\n case UserEmailApproved o:\r\n \/\/User'\u0131 veritaban\u0131ndan \u00e7ek ve email'i onayla\r\n update = Builders<User>.Update.Set(u => u.EmailApprove, true);\r\n await userCollection.UpdateOneAsync(f => f.Id == o.UserId, update);\r\n break;\r\n }\r\n\r\n },\r\n subscriptionDropped: (eventStoreSubscription, subscriptionDropReason, exception) => Console.WriteLine($"Ba\u011flant\u0131 kopmu\u015ftur. {subscriptionDropReason}")\r\n );\r\n }\r\n }\r\n<\/pre>\n
Yukar\u0131daki kodun izah\u0131n\u0131 yapmam\u0131z gerekirse e\u011fer ‘UserSubscribe’ metodu i\u00e7erisindeki 5.<\/em><\/strong> sat\u0131rda \u00e7a\u011fr\u0131lan SubscribeToAllAsync<\/code> metodu e\u015fli\u011finde Event Store’da ki t\u00fcm stream’lere subscribe olunmaktad\u0131r. 11<\/em><\/strong> ile 13.<\/em><\/strong> sat\u0131r aral\u0131\u011f\u0131nda o anda JSON olarak eklenen event’in hangi t\u00fcrde(EventType) oldu\u011fu Metadata bilgisinden edinilerek o t\u00fcr bir object’e d\u00f6n\u00fc\u015ft\u00fcr\u00fclme i\u015flemleri ger\u00e7ekle\u015ftirilmektedir.(\u00c7\u00fcnk\u00fc \u00f6nceki makalede bu bilgiyi ilgili event’in Metadata’s\u0131na biz koymu\u015ftuk)<\/span> 17<\/em><\/strong> ile 41.<\/em><\/strong> sat\u0131r aral\u0131\u011f\u0131nda ise ilgili event’in hangi t\u00fcrde oldu\u011fu tespit edilerek gerekli i\u015flemler ger\u00e7ekle\u015ftirilmektedir. Misal; e\u011fer event t\u00fcr\u00fc UserCreated<\/code> ise ‘userCollection’a ekleme i\u015flemi ger\u00e7ekle\u015ftirilmekte, yok e\u011fer UserNameChanged<\/code> ise ilgili data elde edilip ad\u0131 de\u011fi\u015ftirilmekte yahut UserEmailApproved<\/code> ise yine ilgili data elde edilerek bu seferde email onay\u0131 verilmektedir.<\/p>\n
Fark\u0131ndaysan\u0131z e\u011fer, Event Sourcing operasyonunda Write Data Store’a eklenen event her neyse bunun Read Data Store’a yans\u0131mas\u0131 Metadata \u00fczerinden ta\u015f\u0131nan class t\u00fcr\u00fc bilgisiyle sa\u011flanmaktad\u0131r. Bunun i\u00e7in yaz\u0131m\u0131z\u0131n ba\u015f\u0131nda bahsedilen ‘Shared’ isimli katman olu\u015fturularak ilgili class’lar\u0131n her iki data store’u besleyen uygulama taraflar\u0131ndan eri\u015filebilir olmas\u0131 sa\u011flanm\u0131\u015ft\u0131r. Hatta 11.<\/em><\/strong> sat\u0131ra g\u00f6z atarsan\u0131z, farkl\u0131 bir projede ki class’\u0131n object’ini deserialize i\u015flemi ile elde etmek icap etti\u011finde bir tek class’\u0131n fullname de\u011feri yeterli olmamakta ayr\u0131ca yan\u0131na {Class Name}<\/span>, Shared, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null<\/em><\/u> bilgisinin de eklenmesi gerekmektedir. Bu da bu tarz durumlar i\u00e7in ayr\u0131 bir genel k\u00fclt\u00fcr mahiyetinde bilgidir.<\/p>\n
Program.cs’in Yap\u0131land\u0131r\u0131lmas\u0131<\/h6>\nT\u00fcm bu yap\u0131lan konfig\u00fcrasyonlar ve abonelikler neticesinde console uygulamas\u0131ndaki ‘Program.cs’ dosyas\u0131n\u0131n i\u00e7eri\u011fi a\u015fa\u011f\u0131daki gibi olacakt\u0131r.<\/p>\n \r\n class Program\r\n {\r\n static async Task Main(string[] args)\r\n {\r\n IEventStoreConnection connection = await EventStoreConfiguration.Connect();\r\n\r\n IMongoCollection<User> userCollection = MongoDBConfiguration.Collection<User>("users");\r\n\r\n await connection.UserSubscribe(userCollection);\r\n\r\n Console.Read();\r\n }\r\n }\r\n<\/pre>\nTest Edelim<\/h6>\n\u015eimdi yapt\u0131\u011f\u0131m\u0131z bu \u00e7al\u0131\u015fmalar neticesinde event sourcing yap\u0131lanmas\u0131n\u0131 test edelim.<\/p>\n \nTest Ad\u0131m\u0131 1 :<\/em><\/strong> Kullan\u0131c\u0131 ekleme(UserCreated)<\/em> \n\n\n\n\n\nRequest<\/th>\n Read Data Store<\/th>\n<\/tr>\n<\/thead>\n <\/a><\/td>\n <\/a><\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/li>\nTest Ad\u0131m\u0131 2 :<\/em><\/strong> Kullan\u0131c\u0131 ad\u0131n\u0131 de\u011fi\u015ftirme(UserNameChanged)<\/em> \n\n\n\n\n\nRequest<\/th>\n Read Data Store<\/th>\n<\/tr>\n<\/thead>\n <\/a><\/td>\n <\/a><\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/li>\nTest Ad\u0131m\u0131 3 :<\/em><\/strong> Kullan\u0131c\u0131 e-mail’ini onaylama(UserEmailApproved)<\/em> \n\n\n\n\n\nRequest<\/th>\n Read Data Store<\/th>\n<\/tr>\n<\/thead>\n <\/a><\/td>\n <\/a><\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/li>\n<\/ul>\nEvet… G\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere Event Store’da ki t\u00fcm event’lere kar\u015f\u0131l\u0131k ilgili data \u00fczerinde gerekli i\u015flemler ger\u00e7ekle\u015ftirilmi\u015f ve b\u00f6ylece event sourcing pattern’\u0131n\u0131n bizlere sundu\u011fu tasar\u0131m uygulanm\u0131\u015ft\u0131r. Haliyle art\u0131k nihai olarak verilerimiz salt bir de\u011ferden ziyade olaylar zincirinin bir b\u00fct\u00fcn olarak bir araya gelmesiyle daha geni\u015f anlam kazanmakta ve ihtiya\u00e7 do\u011frultusunda bu anlam\u0131 g\u00f6zlemleyebilmek i\u00e7in event store tool’undan ilgili dataya \u00f6zel bir sorgulama ile data’n\u0131n ya\u015fam s\u00fcrecini seyredebilmekteyiz.<\/p>\n<\/a>Mevcut bir datan\u0131n var oldu\u011fu s\u00fcrece ya\u015fad\u0131\u011f\u0131 t\u00fcm etkinlikleri g\u00f6zlemleyebilmenin getirdi\u011fi avantaj\u0131 tadabilmek i\u00e7in bir \u00f6rnek…<\/p><\/div>\n \u0130lgilenenlerin faydalanmas\u0131 dile\u011fiyle… \nSonraki yaz\u0131lar\u0131mda g\u00f6r\u00fc\u015fmek \u00fczere… \n\u0130yi \u00e7al\u0131\u015fmalar…<\/p>\nNot : \u00d6rnek projeyi indirebilmek i\u00e7in buraya<\/a> t\u0131klay\u0131n\u0131z.<\/p>\n","protected":false},"excerpt":{"rendered":" Merhaba, \u00d6nceki Asp.NET Core + Event Store \u0130le Event Sourcing Uygulamas\u0131(\u00d6rneklendirme) ba\u015fl\u0131kl\u0131 yaz\u0131mda bir veri \u00fczerinde yap\u0131lan t\u00fcm i\u015flemleri Event Store tool’u ile kay\u0131t alt\u0131na alm\u0131\u015f ve b\u00f6ylece Event Sourcing’in Write Data Store kanad\u0131n\u0131...<\/p>\n","protected":false},"author":1,"featured_media":21677,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[2739,153,3573],"tags":[4217,4313,4314,4315,4225,2534,2533,4316,4317],"class_list":["post-22040","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-net-core","category-design-pattern","category-microservices","tag-event-sourcing","tag-event-sourcing-mongodb","tag-event-sourcing-read-data-store","tag-event-sourcing-write-data-store","tag-event-store","tag-mongodb","tag-nosql","tag-read-data-store","tag-write-data-store"],"amp_enabled":true,"_links":{"self":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/22040","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/comments?post=22040"}],"version-history":[{"count":44,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/22040\/revisions"}],"predecessor-version":[{"id":22093,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/22040\/revisions\/22093"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media\/21677"}],"wp:attachment":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media?parent=22040"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/categories?post=22040"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/tags?post=22040"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}