Axonframework 3 में इवेंट स्नैपशॉट, प्रदर्शन में सुधार

Axonframework ढांचा अवलोकन

Axonframework एक ढांचा है जो कई डिजाइन सिद्धांतों और पैटर्न को लागू करता है जैसे:

CQRS - डेटा पढ़ने और लिखने के अनुरोधों के प्रसंस्करण को अलग करता है
ईवेंट सोर्सिंग तब होता है जब किसी एप्लिकेशन की स्थिति को ईवेंट की श्रृंखला के रूप में संग्रहीत किया जाता है।
DDD एग्रीगेट - एक डोमेन ऑब्जेक्ट जो राज्य को स्टोर करता है

घटनाओं की श्रृंखला के रूप में एक आवेदन की अंतिम स्थिति को संग्रहीत करने की कमियों में से एक संग्रहीत और संसाधित घटनाओं की संख्या है। सौभाग्य से, Axonframework आपको एक स्नैपशॉट इवेंट बनाने की अनुमति देता है, जिसमें कई घटनाओं (डोमेन इवेंट) का परिणाम होता है।

घटना स्नैपशॉट

स्नैपशॉट ईवेंट - ये कई ईवेंट (डोमेन ईवेंट) के परिणामी मान हैं। यह आपको एग्रीगेट की स्थिति को जल्दी से फिर से बनाने की अनुमति देता है। यह समझना महत्वपूर्ण है कि एक स्नैपशॉट एक विशिष्ट पहचानकर्ता के साथ विशिष्ट इकाई के लिए उपयोग की जाने वाली घटनाओं से बनाया गया है।

उदाहरण के लिए ( छवि 1 ), हम हर दो घटनाओं के लिए एक स्नैपशॉट बनाने के लिए कॉन्फ़िगरेशन सेट करते हैं (थ्रेशोल्ड = 2 - उदाहरण के प्रयोजनों के लिए)। इस स्थिति में, जब दो ईवेंट यूनिट की स्थिति को बदलते हैं, तो पिछले दो ईवेंट के परिणामी मानों के साथ एक चित्र बनाया जाएगा।


चित्र 1. दो घटनाओं का एक स्नैपशॉट। (दहलीज = २)

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


अंजीर। 2 एक तस्वीर में घटनाओं की श्रृंखला का परिणाम (दहलीज = 2)

उत्पादकता

एक तरफ, जब किसी एप्लिकेशन में घटनाओं की एक लंबी श्रृंखला जमा होती है, तो यूनिट की स्थिति को फिर से बनाने के लिए बड़ी संख्या में घटनाओं को पढ़ने और संसाधित करने में समय लगता है। दूसरी ओर, यदि आप एक स्नैपशॉट बनाते हैं, तो यूनिट की स्थिति को जल्दी से फिर से बनाया जाएगा, लेकिन स्नैपशॉट बनाने में समय लगेगा। इन दो स्थितियों के बीच संतुलन होना चाहिए।


अंजीर। 3 स्नैपशॉट लेने के बिना प्रदर्शन


चित्र 4 स्नैपशॉट के साथ प्रदर्शन (दहलीज = 3)

डिफ़ॉल्ट रूप से, एक स्नैपशॉट थ्रेड में बनाया जाता है जिसे शिड्यूलसैपशॉट () विधि कहा जाता है। मुकाबला वातावरण के लिए यह सेटिंग अनुशंसित नहीं है (चित्र 4 / प्रविष्टि देखें)।

नीचे ThreadPoolExecutor (...) का उपयोग करके कोड का एक उदाहरण है जो स्नैपशॉट बनाने के लिए एक अलग थ्रेड प्रदान करेगा। इस स्थिति में, हमारा ग्राहक एप्लिकेशन में मंदी और स्नैपशॉट बनाने के लिए आवंटित समय पर ध्यान नहीं देगा।

कोड

स्नैपशॉट के निर्माण को सक्रिय करने के लिए, आपको एप्लिकेशन कोड में छोटे बदलाव करने होंगे। समग्र एनोटेशन उस रिपॉजिटरी के नाम को इंगित करता है जिसका उपयोग कॉन्फ़िगरेशन क्लास के कोड में किया जाता है। कॉन्फ़िगरेशन क्लास में, स्नैपशॉट बनाने के लिए दहलीज, स्नैपशॉट बनाने के लिए विधि, रिपॉजिटरी, आदि इंगित किए जाते हैं।

AxonConfig.java

@Autowired private EventStore eventStore; @Bean public SpringAggregateSnapshotterFactoryBean springAggregateSnapshotterFactoryBean() { return new SpringAggregateSnapshotterFactoryBean(); } @Bean public SpringAggregateSnapshotter snapshotter(ParameterResolverFactory parameterResolverFactory, EventStore eventStore, TransactionManager transactionManager) { Executor executor = Executors.newFixedThreadPool(10); return new SpringAggregateSnapshotter(eventStore, parameterResolverFactory, executor, transactionManager); } @Bean("reservationRepository") public EventSourcingRepository<Reservation> reservationRepository(Snapshotter snapshotter, ParameterResolverFactory parameterResolverFactory) { return new EventSourcingRepository<Reservation>(reservationAggregateFactory(), eventStore, parameterResolverFactory, new EventCountSnapshotTriggerDefinition(snapshotter, 50)); } @Bean(name = "reservationAggregateFactory") public AggregateFactory<Reservation> reservationAggregateFactory() { SpringPrototypeAggregateFactory<Reservation> aggregateFactory = new SpringPrototypeAggregateFactory<>(); aggregateFactory.setPrototypeBeanName("reservation"); return aggregateFactory; } 

Reservation.java

 @Aggregate(repository = "reservationRepository") public class Reservation { //… } 

यह ध्यान देने योग्य है कि Google समूह चर्चा धागे में उपयोगी कोड उदाहरण और चर्चाएँ हैं।

स्नैपशॉट के लिए थ्रेशोल्ड का चयन करें

5.1। सैद्धांतिक तरीका

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

5.2। व्यावहारिक तरीका

हम डेटाबेस से डेटा का विश्लेषण करते हैं, और हम मानते हैं कि डेटाबेस का उपयोग MongoDB द्वारा किया जाता है और यह डॉकटर कंटेनर के अंदर काम करता है।

 > docker exec -it <container-id> mongo > show dbs admin 0.000GB axonframework 0.000GB local 0.000GB > use axonframework switched to db axonframework > show collections domainevents sagas snapshotevents > db.domainevents.findOne() { “_id” : ObjectId(“5bb1dc8d4446d63bcc765feb”), “aggregateIdentifier” : “b1e320d5–58aa-4b9b-a667-aa724900592f”, “type” : “Reservation”, “sequenceNumber” : NumberLong(0), “serializedPayload” : “<com.example.ReservationStarted><reservationIdentifier>b1e320d5–58aa-4b9b-a667-aa724900592f</reservationIdentifier><duration resolves-to=\”java.time.Ser\”><byte>1</byte><long>2400</long><int>0</int></duration></com.example.ReservationStarted>”, “timestamp” : “2018–10–01T08:36:29.434Z”, “payloadType” : “com.example.ReservationStarted”, “payloadRevision” : null, “serializedMetaData” : “<meta-data><entry><string>traceId</string><string>b090b86a-ec89–484b-ae9f-e4fa0f9bcd39</string></entry><entry><string>correlationId</string><string>b090b86a-ec89–484b-ae9f-e4fa0f9bcd39</string></entry></meta-data>”, “eventIdentifier” : “f324f021–50b4–4e91–84d0-f8c4425f3eb9” } 

प्रत्येक संग्रहीत घटना में एक समुच्चयबोधक क्षेत्र होता है, जिसके द्वारा हम प्रत्येक समूह के लिए एक सरल क्वेरी के साथ लागू घटनाओं की संख्या की गणना करते हैं:

 db.domainevents.aggregate([ {$group: {_id: "$aggregateIdentifier", count: {$sum: 1} } }, {$sort : {count : -1} } ]); { "_id" : "0d84afd1-f199-45c8-b50e-7d9ebfa4c8fb", "count" : 136 } { "_id" : "49de7c32-38ea-435a-b837-ccdb61ec0baa", "count" : 136 } { "_id" : "12957b0b-af05-47c4-a3d8-968b75cf9ffb", "count" : 136 } { "_id" : "97a24559-ee3a-43e7-a6be-1eb6840b662a", "count" : 132 } { "_id" : "b6aeb1af-0620-4b02-8de3-c2446c2f7d83", "count" : 132 } { "_id" : "b385aaf4-3338-489f-8d1b-4600d5e088b9", "count" : 132 } { "_id" : "5970327f-9551-4945-94e9-3844c0cd3543", "count" : 132 } ... { "_id" : "0182239h-3948-3334-98t5-9643j4ld8346", "count" : 1 } 

स्नैपशॉट बनाने के लिए सीमा को औसत से नीचे चुना जा सकता है ताकि स्नैपशॉट को कुशलता से बनाया जा सके। इस मामले में, 50 का मान ठीक है।

स्नैपशॉट सक्रियण की जाँच करना

 > mongo > show dbs admin 0.000GB axonframework 0.000GB local 0.000GB > use axonframework > show collections domainevents sagas snapshotevents > db.domainevents.count() 515 > db.snapshotevents.count() 7 

यदि स्नैपशॉटोटेंट्स संग्रह खाली नहीं है और इसमें स्नैपशॉट हैं, तो स्नैपशॉट निर्माण सफलतापूर्वक सक्रिय हो गया है।

अन्य स्नैपशॉट विकल्प

दस्तावेज़ में स्नैपशॉट निर्माण को सक्रिय करने के तरीके पर अन्य विविधताओं का उल्लेख है, उदाहरण के लिए:

• अंतिम स्नैपशॉट के बाद से उत्पन्न घटनाओं की संख्या सीमा से अधिक है
• यूनिट इनिशियलाइज़ेशन टाइम आउट हो गया
• समय में देरी, आदि। आदि