एसिंक्रोनस उपयोगकर्ता स्क्रिप्ट को शुद्ध जंग में फ्रेमवर्क और एसएमएस के बिना

नमस्कार, हेब्र!

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

उदाहरण के लिए, हम एक सरल http-bot लिखेंगे जो ब्राउज़र में एक html फॉर्म प्रदर्शित करता है, उपयोगकर्ता से सवाल पूछता है जब तक कि वह जवाब नहीं देता कि वह अच्छा महसूस करता है। कार्यक्रम एक सरल एकल-थ्रेडेड http-server है, हम बस्ट स्क्रिप्ट को रस्ट जनरेटर के रूप में लिखते हैं। आपको याद दिलाता हूं कि जावास्क्रिप्ट जनरेटर दो-तरफ़ा डेटा एक्सचेंज की अनुमति देता है, अर्थात, जनरेटर के अंदर आप प्रश्न पास कर सकते हैं: my_generator.next (my_question);
और इससे प्रतिक्रिया वापस करें: my_response उपज;
जंग में, जनरेटर के अंदर मूल्यों के हस्तांतरण को अभी तक लागू नहीं किया गया है ( फिर से शुरू () फ़ंक्शन में कोई पैरामीटर नहीं है, हालांकि इसे ठीक करने के लिए एक चर्चा है), इसलिए हम एक साझा सेल के माध्यम से डेटा के आदान-प्रदान को व्यवस्थित करते हैं, जिसमें प्राप्त और भेजे गए डेटा के साथ संरचना निहित है। हमारे बॉट की स्क्रिप्ट create_scenario () फ़ंक्शन द्वारा बनाई गई है, जो जनरेटर का एक उदाहरण लौटाता है, अनिवार्य रूप से वह क्लोजर जिसमें पैरामीटर ले जाया जाता है - udata डेटा सेल के लिए एक पॉइंटर। प्रत्येक उपयोगकर्ता सत्र के लिए, हम अपने स्वयं के सेल को डेटा और जनरेटर के अपने उदाहरण के साथ, स्टैक की अपनी स्थिति और स्थानीय चर के मूल्यों के साथ संग्रहीत करते हैं।

#[derive(Default, Clone)] struct UserData { sid: String, msg_in: String, msg_out: String, script: String, } type UserDataCell = Rc<RefCell<UserData>>; struct UserSession { udata: UserDataCell, scenario: Pin<Box<dyn Generator<Yield = (), Return = ()>>>, } type UserSessions = HashMap<String, UserSession>; fn create_scenario(udata: UserDataCell) -> impl Generator<Yield = (), Return = ()> { move || { let uname; let mut umood; udata.borrow_mut().msg_out = format!("Hi, what is you name ?"); yield (); uname = udata.borrow().msg_in.clone(); udata.borrow_mut().msg_out = format!("{}, how are you feeling ?", uname); yield (); 'not_ok: loop { umood = udata.borrow().msg_in.clone(); if umood.to_lowercase() == "ok" { break 'not_ok; } udata.borrow_mut().msg_out = format!("{}, think carefully, maybe you're ok ?", uname); yield (); umood = udata.borrow().msg_in.clone(); if umood.to_lowercase() == "ok" { break 'not_ok; } udata.borrow_mut().msg_out = format!("{}, millions of people are starving, maybe you're ok ?", uname); yield (); } udata.borrow_mut().msg_out = format!("{}, good bye !", uname); return (); } } 

स्क्रिप्ट के प्रत्येक चरण में सरल क्रियाएं होती हैं - सेल की सामग्री के लिए एक लिंक प्राप्त करें, स्थानीय चर में उपयोगकर्ता इनपुट को सहेजें, प्रतिक्रिया पाठ सेट करें और उपज के माध्यम से बाहर पर नियंत्रण दें। जैसा कि कोड से देखा जा सकता है, हमारा जनरेटर एक खाली नलिका () देता है, और सभी डेटा एक आम सेल के माध्यम से एक संदर्भ काउंटर रेफरी <सेल <... >> के माध्यम से प्रेषित होता है। जनरेटर के अंदर, आपको यह सुनिश्चित करने की आवश्यकता है कि उधार की सामग्री का उधार () सेल उपज बिंदु को पार नहीं करता है, अन्यथा जनरेटर के बाहर से डेटा को अपडेट करना असंभव होगा - इसलिए, दुर्भाग्य से, आप एल्गोरिथ्म की शुरुआत में एक बार नहीं लिख सकते हैं udata_mut = udata.borrow_mut () , और। आपको प्रत्येक उपज के बाद एक मूल्य उधार लेना होगा।

हम अपने स्वयं के ईवेंट लूप (सॉकेट से पढ़ना) को लागू करते हैं, और प्रत्येक आने वाले अनुरोध के लिए हम या तो एक नया उपयोगकर्ता सत्र बनाते हैं या मौजूदा को खोजते हैं, इसमें डेटा को अपडेट करते हैं:

 let mut udata: UserData = read_udata(&mut stream); let mut sid = udata.sid.clone(); let session; if sid == "" { //new session sid = rnd.gen::<u64>().to_string(); udata.sid = sid.clone(); let udata_cell = Rc::new(RefCell::new(udata)); sessions.insert( sid.clone(), UserSession { udata: udata_cell.clone(), scenario: Box::pin(create_scenario(udata_cell)), } ); session = sessions.get_mut(&sid).unwrap(); } else { match sessions.get_mut(&sid) { Some(s) => { session = s; session.udata.replace(udata); } None => { println!("unvalid sid: {}", &sid); continue; } } } 

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

 udata = match session.scenario.as_mut().resume() { GeneratorState::Yielded(_) => session.udata.borrow().clone(), GeneratorState::Complete(_) => { let mut ud = sessions.remove(&sid).unwrap().udata.borrow().clone(); ud.script = format!("document.getElementById('form').style.display = 'none'"); ud } }; write_udata(&udata, &mut stream); 

पूर्ण कार्य कोड यहाँ:
github.com/epishman/habr_samples/blob/master/chatbot/main.rs

मैं "सामूहिक फार्म" http पार्सिंग के लिए माफी माँगता हूँ, जो सिरिलिक इनपुट का समर्थन भी नहीं करता है, लेकिन सब कुछ मानक भाषा टूल का उपयोग करके किया जाता है, बिना फ्रेमवर्क, लाइब्रेरी और एसएमएस के। मैं वास्तव में क्लोनिंग स्ट्रिंग्स की तरह नहीं हूं, और उधार_मुट ​​() और क्लोन () के भारी उपयोग के कारण स्क्रिप्ट स्वयं बहुत कॉम्पैक्ट नहीं लगती है। संभवत: अनुभवी रस्तमण इसे (उदाहरण के लिए मैक्रोज़ का उपयोग करके) सरल बनाने में सक्षम होंगे। मुख्य बात यह है कि समस्या को न्यूनतम साधनों द्वारा हल किया जाता है, और मुझे उम्मीद है कि जल्द ही हम एक स्थिर रिलीज में अतुल्यकालिक साधनों का एक पूरा सेट प्राप्त करेंगे।

पुनश्च
संकलन करने के लिए, आपको एक रात के निर्माण की आवश्यकता है:

 rustup default nightly rustup update 

अंग्रेजी स्टैक ओवरफ्लो के साथियों ने मुझे जनरेटर से निपटने में मदद की:
stackoverflow.com/questions/56460206/how-can-i-transfer-some-values-into-a-rust-generator-at-each-step