रैपिड डेवलपमेंट फ्रेमवर्क को बदलना (भाग 2 CQRS)

पूर्व कहानी

मेरा पिछला लेख इंकोडिंग फ्रेमवर्क का एक परिचय था, जो IML (हमारी प्रमुख विशेषता) के साथ शुरू हुआ था। कंपनी परियोजनाओं में उपयोग की जाने वाली उपयोगिताओं (इस तरह का सामान डेवलपर्स की किसी भी टीम में) से अधिक परियोजना को विकसित करने के लिए IML ने हमें धक्का दिया, लेकिन इसका मतलब यह नहीं है कि अन्य घटकों पर काम नहीं किया जाता है, लेकिन इसके विपरीत बिना किसी कम विस्तार के "पॉलिश" किया जाता है और मैं इसे साबित करने की कोशिश नहीं करूंगा। ।

चांदी की गोली?

इससे पहले, मैं हमेशा एक समर्थक रहा हूं कि प्रत्येक समाधान में इसके पेशेवरों और विपक्ष हैं, लेकिन CQRS, मेरी राय में, एन-लेयर से बेहतर है, और इसमें "मतभेद" या "साइड इफेक्ट" भी नहीं है, जो इसे क्लिप के लिए पहले कारतूस के लिए एक उम्मीदवार बनाता है। लेकिन पहले चीजें पहले।

क्या किसी ने CQRS के बारे में सुना है?

उन लोगों के लिए जो पहले से ही CQRS का उपयोग करते हैं, पहला खंड दिलचस्प नहीं हो सकता है, इसलिए इससे पहले कि आप "बाइक" लेबल डालें, मेरा सुझाव है कि आप अपने आप को हत्या सुविधा अनुभाग से परिचित कराएं, जो आपको अन्यथा मना सकते हैं। जो लोग एन-लेयर आर्किटेक्चर का उपयोग करते हैं, उन्हें CQRS पर स्विच करने पर विचार करना चाहिए, और मेरे प्रस्ताव का समर्थन करने के लिए मैं CQRS के लिए अपना रास्ता बताऊंगा

ओह, कितने सार सुविधाजनक हैं (अतीत से राय)

जब हमने केवल एप्लिकेशन विकसित करना शुरू किया, तो हमने एन-लेयर को सर्वर आर्किटेक्चर के रूप में चुना, जो एप्लिकेशन को कई परतों में विभाजित करता है, जिससे हमें प्रोजेक्ट के विभिन्न हिस्सों को एक-दूसरे से स्वतंत्र रूप से डिजाइन करने की अनुमति मिलती है, लेकिन अंत में हमें निम्नलिखित समस्याएं मिलीं:

• स्रोत कोड की "सूजन", समस्या ज्यादातर टाई परतों जैसे कि मुखौटा परत, संचार परत, आदि के कारण होती है।
• कई परत स्तरों के पीछे विवरण छिपाते हुए।

नोट: N-Layer का विचार एक निश्चित परत के प्रतिस्थापन dll के साथ भी जुड़ा हुआ है, लेकिन यह बेहद कम मांग वाला कार्य IoC के माध्यम से बहुत आसानी से हल हो जाता है।

एन-लेयर में "बुराई" का मुख्य स्रोत अक्सर सेवा की परत होती है, जिसे एक ही वर्ग में समान कार्यों को एकत्रित करके, व्यापार प्रक्रियाओं और एप्लिकेशन लॉजिक के काम के विवरण को छिपाने के लिए डिज़ाइन किया गया है, जो अंततः इसे GOD ऑब्जेक्ट में बदल देता है और समस्याओं की ओर जाता है:

• निकट संबंधी तरीकों का समर्थन और विस्तार करना
• एक बड़ी वस्तु के साथ परीक्षण करना मुश्किल है

यदि आप सूक्ष्मताओं को नहीं देते हैं, तो CQRS में सशर्त रूप से परिवर्तन बड़ी वस्तुओं को छोटे में विभाजित करने में शामिल होगा

public interface IUserService { void Add(string name); void Delete(string id); List<User> Fetch(Criteries criteries); } 

अपघटन के बाद, हम दो कमांड (AddUser, DeleteUser) और क्वेरी (FetchUser) प्राप्त करते हैं, जो कक्षाओं की संख्या बढ़ाता है, लेकिन आपको कक्षा में संबंधित कुछ तरीकों से छुटकारा पाने की अनुमति देता है।
"अब हमें और भी अधिक कक्षाएं लिखने की जरूरत है!" - यह एन-लेयर डेवलपर्स द्वारा पूछा गया पहला सवाल है, लेकिन एक प्रतिवाद के रूप में हम यह जान सकते हैं कि हमें कार्यों की एटमॉसिटी (वस्तुओं के बीच कोई निर्भरता नहीं) मिलती है, और यह बहुत लायक है:

1. VCS में कम संघर्ष (संस्करण नियंत्रण प्रणाली)
2. कक्षा की खोज विधि की तुलना में आसान है
3. अब आपको उपयोगकर्ता सेवा को आंशिक में विभाजित करने की आवश्यकता नहीं है, क्योंकि एक को नेविगेट करना कठिन है))
4. कमांड और क्वेरी से गठित बगट्रैकर पर मुद्दा
5. फुर्तीली के लिए स्प्रिंट कमांड और क्वेरी से बनता है
6. छोटी वस्तुओं का परीक्षण

हमारा कार्यान्वयन

उन अधीर लोगों के लिए जो कोड को तुरंत "महसूस" करना चाहते हैं, आप स्रोत कोड को डाउनलोड कर सकते हैं (गीथहब से इंकोडिंग सीक्यूआरएस + एमवीडी का एक उदाहरण भी है), हम उन्हें एक उदाहरण के रूप में मानेंगे।
ध्यान दें: एक परियोजना शुरू करने के लिए, आपको एक खाली डेटाबेस बनाने और web.config (मुख्य मुख्य) में इसके कनेक्शन को निर्दिष्ट करने की आवश्यकता है

डिस्पैचर

मुख्य तत्व जो एकल लेनदेन (कार्य की इकाई) में संदेश ( कमांड या क्वेरी ) निष्पादित करता है।
नियंत्रक - asp.net mvc (कंसोल, wpf, ओविन और आदि) के सिस्टम में डिस्पैचर का उपयोग करने के लिए, आपको आईओसी से इसकी आवृत्ति प्राप्त करने की आवश्यकता है और फिर दो तरीके उपलब्ध हैं:

• पुश - कमांड निष्पादित करता है
• क्वेरी - एक क्वेरी करता है

 public ActionResult Test() { var dispatcher = IoCFactory.Instance.TryResolve<IDispatcher>(); var id = dispatcher.Query(new GetIdQuery()); dispatcher.Push(new DeleteEntityByIdCommand(id)); return something ActionResult; } 

कार्य की इकाई - यदि आप किसी कमांड के कार्यान्वयन को देखते हैं, तो आप देख सकते हैं कि मुख्य कोड अतिभारित निष्पादन विधि में निहित है, जिसे डिस्पैचर की भागीदारी के बिना बुलाया जा सकता है, लेकिन तब डेटाबेस और लेनदेन का कनेक्शन खुला नहीं होगा।

 new DeactivateEntityCommand().Execute(); // without transaction and connection dispatcher.Push(new DeactivateEntityCommand()); // open transaction and connection 

संदेश

CommandBase और QueryBase संदेश के बच्चे हैं, लेकिन उनका व्यवहार उस अलगाव स्तर के प्रकार में भिन्न होता है जिसके साथ कार्य की इकाई बनाई जाती है

• कमान - ReadCommitted
• प्रश्न - ReadUncommitted (केवल पढ़ें)

नोट: प्रतिबंध गंभीर लग सकता है, लेकिन यदि किसी कारण से आपको क्वेरी में डेटा को हटाने (हटाने, डालने) की आवश्यकता है, तो आपको अपनी स्क्रिप्ट को छोटे कार्यों में विभाजित करके संशोधित करना चाहिए।

संदेश के दो मुख्य उपकरण हैं:
रिपॉजिटरी - डेटाबेस इंटरफ़ेस, सभी CRUD स्क्रिप्ट का समर्थन करता है


इवेंट ब्रोकर - कमांड के बीच संचार, जो आपको कोड के फिर से होने वाले "टुकड़ों" को एकत्र करने की अनुमति देता है और घटनाओं और ग्राहकों को एन्क्रिप्ट करता है।

कार्य: कुछ कार्यों का लेखा-जोखा
समस्या: ऑडिट को बचाने के लिए कोड समान होगा और प्रत्येक कमांड में दोहराया जाना होगा
सर्विस लेयर में समाधान: आप बेस क्लास ServiceWithAuditBase को आवंटित कर सकते हैं, लेकिन ऑडिट की बढ़ती जटिलता को बनाए रखना मुश्किल होगा, और वंशानुक्रम हमेशा जटिलता की ओर जाता है।
सदस्य समाधान
घटना कोड

 public class OnAuditEvent : IEvent { public string Message { get; set; } } 

नोट: ईवेंट को लागू करने वाली स्थिति
सब्सक्राइबर कोड

 public class AuditSubscriber : IEventSubscriber<OnAuditEvent> { readonly IRepository repository; public AuditSubscriber(IRepository repository) { this.repository = repository; } public void Subscribe(OnAuditEvent @event) { this.repository.Save(new Audit { Message = @event.Message }); } public void Dispose() { } } 

नोट: सब्सक्राइबर IoCFactory के माध्यम से बनाया गया है और इसलिए आप ctor (कंस्ट्रक्टर) में इंजेक्ट कर सकते हैं या IoCFactory.Instance.TryResolve () का उपयोग कर सकते हैं
कमांड कोड

 EventBroker.Publish(new OnAuditEvent { Message = "New product {0} by {1}".F(Title, Price) }); 

सवाल

एक कस्टम क्वेरी बनाने के लिए, आपको QueryBase को इनहेरिट करने की आवश्यकता होती है, जहाँ आप अपेक्षित डेटा रिटर्न निर्दिष्ट करते हैं और ExecuteResult विधि को ओवरराइड करते हैं

 public class GetProductsQuery : QueryBase<List<GetProductsQuery.Response>> { public class Response { public string Title { get; set; } public string Price { get; set; } } public string Title { get; set; } public decimal? From { get; set; } public decimal? To { get; set; } protected override List<Response> ExecuteResult() { return Repository.Query(whereSpecification: new ProductByTitleWhere(this.Title) .And(new ProductBetweenPriceWhere(this.From, this.To))) .Select(product => new Response { Title = product.Title, Price = product.Price.ToString("C") }) .ToList(); } } 

हम भेद कर सकते हैं कि एक नेस्टेड क्लास को रिजल्ट के रूप में उपयोग किया जाता है, लेकिन क्यों नहीं ...
डेटाबेस (इकाई) से तुरंत एक वस्तु लौटें - इस विधि में डेटाबेस से जुड़ने के सत्र के दायरे से संबंधित एक समस्या है, एक उदाहरण पर विचार करें।

व्यूमॉडल नेस्टेड क्लास के समान है, लेकिन अन्य क्वेरी में पुन: उपयोग करने की क्षमता के साथ, जो एक अत्यंत दुर्लभ परिदृश्य है।

आदेश

CQRS के लिए कमांड का हमारा पहला कार्यान्वयन निष्पादक (UserCommandHandler) से विवरण (AddUserCommand) के पृथक्करण के साथ था, जो विकास की प्रक्रिया को जटिल बनाता है, इसलिए इन भागों को और जोड़ दिया गया।
नोट: अलग होने का मुख्य कारण SOAP सिस्टम के लिए DTO (डेटा ट्रांसफर ऑब्जेक्ट) मॉडल का समर्थन था, लेकिन asp.net mvc के आगमन के साथ, यह प्रासंगिक नहीं बन गया

एक कस्टम कमांड बनाने के लिए, आपको कमांडबेस को इनहेरिट करना होगा और एक्सक्यूट विधि को ओवरराइड करना होगा

 public class AddProductCommand : CommandBase { public string Title { get; set; } public decimal Price { get; set; } public override void Execute() { var product = new Product { Title = Title, Price = Price } Repository.Save(product); Result = product.Id; } } 

नोट: ऐसे परिदृश्य हैं जहां कमांड को डेटा वापस करना होगा, आप परिणाम को कमांड विधि में रख सकते हैं

हत्या की सुविधा

कम्पोजिट

CQRS छोटे लोगों में जटिल कार्यों को "विभाजित" करने में मदद करता है, लेकिन समग्र निष्पादन लेनदेन के साथ एक समस्या है।
कार्य : ऑब्जेक्ट को 3 चरणों में सहेजना
समाधान : तीन आदेशों में विभाजित (Step1Command, Step2Command, Step3Command)
शर्त : लेन-देन

 public ActionResult Save(Step1Command step1,Step2Command step2,Step3Command step3) { dispatcher.Push(composite => { composite.Quote(step1); composite.Quote(step2); composite.Quote(step3); }); return IncodingResult.Success(); } 

कमांड को एक पैकेज में समूहीकृत करने के अलावा, कम्पोजिट आपको निष्पादन के परिणामों में हेरफेर करने की अनुमति देता है। हम कार्य को जटिल करते हैं और शर्त सेट करते हैं ताकि निष्पादन के बाद Step1 नए तत्व की Id को चरण 2 और 3 में पारित कर दे।

 public ActionResult Save(Step1Command step1,Step2Command step2,Step3Command step3) { dispatcher.Push(composite => { composite.Quote(step1,new MessageExecuteSetting { OnAfter = () => { step2.Id = step1.Result; step3.Id = step1.Result; } }); composite.Quote(step2); composite.Quote(step3);}); } 

हॉट स्वैप कनेक्शन स्ट्रिंग

यदि एप्लिकेशन स्टार्टअप पर कनेक्शन स्ट्रिंग प्राप्त नहीं करता है, लेकिन काम की प्रक्रिया में, उदाहरण के लिए, सिस्टम में प्रवेश करने के बाद, एक तृतीय-पक्ष सेवा वर्तमान सत्र के लिए एक पता जारी करती है, तो आपको पहले निर्दिष्ट पथ को बदलने में सक्षम होना चाहिए।

 dispatcher.Query(query, new MessageExecuteSetting { Connection = new SqlConnection(currentConnectionString) }); 

विरासत प्रणाली

"पुराने is आधार पर लपेटना इंकोडिंग फ्रेमवर्क में कोई समस्या नहीं है। ऐसे उपकरण हैं जो आपको अलग-अलग कॉन्फ़िगरेशन के साथ काम करने के लिए अतिरिक्त बुनियादी ढांचा बनाने से बचने और इस विवरण को ध्यान में रखते हुए कमांड और क्वेरी विकसित करने की अनुमति देते हैं।

 dispatcher.Query(query, new MessageExecuteSetting { DataBaseInstance = "Instance 2" }); 

नोट: प्रत्येक कुंजी का अपना ORM कॉन्फ़िगरेशन है

निष्कर्ष

लेख मुख्य रूप से इनकोडिंग CQRS के कार्यान्वयन की समीक्षा पर केंद्रित है, इसलिए CQRS कार्यप्रणाली की समीक्षा स्वयं संक्षिप्त है, और यह पहले से ही अन्य स्रोतों में अच्छी तरह से वर्णित है। इंकोडिंग CQRS हमारे ढांचे के कुछ हिस्सों में से एक है, लेकिन यह पूरी तरह से आत्मनिर्भर है और इसे अन्य घटकों (IML, MVD, Unit Test) के बिना लागू किया जाता है।

IML के पहले लेख की टिप्पणियों में, वैकल्पिक (OWIN) प्लेटफार्मों पर asp.net mvc का उपयोग करने की संभावना के बारे में सवाल थे, इसलिए मैं तुरंत ध्यान दूंगा कि Incoding CQRS का उपयोग WPF परियोजनाओं में किया गया था, और MML के रूप में, इस महीने एकीकरण पर एक लेख होगा ।

पुनश्च मैं समीक्षा और टिप्पणियों को सुनने के लिए खुश हूं, साथ ही साथ फ्रेमवर्क के काम के बारे में भी सवाल करता हूं। अगले हरित नायक इनकोडिंग एमवीडी जो कॉपी और पेस्ट के खिलाफ लड़ता है, वह कुछ हफ़्ते में होगा)))