स्प्रिंग स्टेट मशीन का व्यावहारिक उदाहरण में उपयोग करना

ROSEU प्रोटोकॉल के उदाहरण पर स्प्रिंग स्टेट मशीन का उपयोग करना

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



ROSEU प्रोटोकॉल यहां विस्तार से वर्णित है ।

एक लेख के लिए, हमें केवल दो ईडीआई ग्राहकों के बीच संबंध स्थापित करने के सिद्धांत को जानना होगा। उनमें से प्रत्येक कनेक्शन स्थापित करने के लिए एक निमंत्रण भेजता है। निमंत्रण का प्रकार या तो "अनुरोध" या "ब्रेक" है।

कनेक्शन स्थापित करने के लिए, वर्कफ़्लो में दोनों प्रतिभागियों को "अनुरोध" प्रकार का निमंत्रण भेजना होगा। उसके बाद, कनेक्शन स्थापित माना जाता है।

यदि प्रतिभागियों में से एक "ब्रेक" प्रकार का निमंत्रण भेजता है, तो कनेक्शन काट दिया जाता है।

हमारी प्रणाली में, हम ईडीआई प्रतिभागियों के लिए सात संभावित स्थिति निर्धारित करते हैं।

1. कनेक्शन विफल - NO_CONNECTION
2. हमारे ग्राहक ने रोमिंग में निमंत्रण भेजा है। लेकिन हमने इसे अभी तक वितरित नहीं किया है। यह आवेदन की संस्था की अतुल्यकालिकता और इसके रोमिंग केंद्र को भेजने के द्वारा उचित है। - INVITATION_SAVED
3. कनेक्शन सफलतापूर्वक स्थापित - ARE_CONNECTED
4. प्रतिभागियों में से एक की पहल पर कनेक्शन को समाप्त कर दिया गया - CONNECTION_BROKEN
5. एक बाहरी निमंत्रण आया, हमारे ग्राहक ने पहले कुछ भी नहीं भेजा था - INVITATION_RECEIVED
6. घूमते हुए केंद्र द्वारा स्वीकार किए गए हमारे ग्राहक का निमंत्रण - INVITATION_SEND
7. कनेक्शन त्रुटि - CONNECTION_ERROR

संभावित घटनाएं:

1. हमारे ग्राहक ने "अनुरोध" के लिए एक निमंत्रण भेजा। - OUTCOME_INVITATION
2. हमारे ग्राहक ने एक आमंत्रण "ब्रेक" - OUTCOME_REJECT भेजा
3. एक बाहरी ग्राहक ने "अनुरोध" आमंत्रण भेजा - INCOME_INVITATION
4. बाहरी ग्राहक ने "ब्रेक" आमंत्रण भेजा - INCOME_REJECT
5. रोमिंग सेंटर ने निमंत्रण को सफलतापूर्वक स्वीकार कर लिया - RC_SUCCESS
6. रोमिंग केंद्र ने आमंत्रण स्वीकार नहीं किया - RC_ERROR

स्थिति स्विचिंग तालिका। पहली पंक्ति प्रारंभिक स्थिति है। पहला कॉलम एक ईवेंट है। चौराहे पर - एक नई स्थिति।



ऐसी स्थिति स्विचिंग को स्विच के माध्यम से एन्कोड किया जा सकता है, यदि, यदि-और। लेकिन राज्य मशीन के माध्यम से, मेरी राय में, यह अधिक सुविधाजनक होगा।

तर्क इस प्रकार है - यदि किसी ने डिस्कनेक्ट किया है, तो कोई भी इसे फिर से स्थापित कर सकता है। यदि कनेक्शन स्थापित करते समय कोई त्रुटि हुई, तो इससे अधिक कुछ नहीं किया जा सकता है, समस्या के मैनुअल सुधार की आवश्यकता है।

स्प्रिंग स्टेट मशीन पर विस्तृत प्रलेखन यहाँ से लिया गया था।

हम बिल्डर के माध्यम से कार बनाएंगे

StateMachineBuilder.Builder<ClientsState, ContractorEvent> builder = StateMachineBuilder.builder(); 

अगला, हम सभी संभावित स्थितियों को निर्धारित करते हैं। प्रारंभिक स्थिति ग्राहकों की वर्तमान स्थिति के लिए निर्धारित है।

 builder.configureStates() .withStates() .initial(initialState) .states(EnumSet.allOf(ClientsState.class)); 

हम कार के ऑटोस्टार्ट को कॉन्फ़िगर करते हैं। अन्यथा, आपको मैन्युअल रूप से शुरू करना होगा

 builder.configureConfiguration() .withConfiguration() .autoStartup(true); 

अगला, हम ट्रैन्च लिखेंगे। source - प्रारंभिक स्थिति, लक्ष्य - अंतिम स्थिति, घटना - घटना जिस पर स्थिति स्विचिंग होती है, क्रिया - क्लाइंट स्थिति अपडेट करती है।

 builder.configureTransitions() .withExternal() .source(NO_CONNECTION) .target(INVITATION_RECEIVED) .event(INCOME_INVITATION) .action(updateStateAction) .and() .withExternal() .source(NO_CONNECTION) .target(CONNECTION_BROKEN) .event(INCOME_REJECT) .action(updateStateAction) 

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

 StateMachine<ClientsState, ContractorEvent> sm = builder.build(); Map<String, Object> clients = new HashMap<>(); clients.put("client1", "client11"); clients.put("client2", "client22"); MessageHeaders headers = new MessageHeaders(clients); Message<ContractorEvent> message = new GenericMessage<>(event, headers); sm.sendEvent(message); sm.stop(); 

आगे की कार्रवाई में इस डेटा को निकाला और उपयोग किया जाता है।

 @Service public class UpdateStateAction implements Action<ClientsState, ContractorEvent> { @Override public void execute(StateContext<ClientsState, ContractorEvent> context) { System.out.println("Source state: " + context.getSource()); System.out.println("Target state: " + context.getTarget()); System.out.println("Event: " + context.getEvent()); MessageHeaders headers = context.getMessageHeaders(); System.out.println(headers.get("client1")); System.out.println(headers.get("client2")); } } 

आप स्थिति में बदलाव को रोकने के लिए गार्ड का उपयोग भी कर सकते हैं, लेकिन हमारे मामले में यह आवश्यक नहीं है।

वह मूल रूप से यह है। उदाहरण के लिए स्रोत कोड लिंक से लिया जा सकता है।

लेख में, हमने जांच की कि राज्य संक्रमण तालिका को एन्कोड करने के लिए स्प्रिंग स्टेट मशीन का उपयोग कैसे किया जाए।

यह इसकी सभी क्षमताओं का नहीं है, बल्कि केवल सबसे बुनियादी है। मुझे उम्मीद है कि लेख उपयोगी था और आपको इस रूपरेखा का उपयोग करने के लिए प्रोत्साहित करता है।

यदि आपके पास इसका उपयोग करने का व्यक्तिगत अनुभव है, तो टिप्पणी में आपका स्वागत है।

युपीडी

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

 @Override public void execute(StateContext<StatesEnum, OperationsEnum> context) { try { prepareContext(context); executeInternal(context); } catch (Exception e) { logger.error("  state machine", e); context.getStateMachine().setStateMachineError(e); } }