Akka और अभिनेता मॉडल पर विकास

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

मैं पूर्ण Akka टूलकिट के साथ काम करता हूँ: नोड्स के बीच संस्थाओं को वितरित करने के लिए क्लस्टरिंग और क्लस्टर शार्डिंग, बैक-प्रेशर के साथ सीमित पाइपलाइनों के लिए Akka Streams, CQRS के साथ स्थिरता और इवेंट सोर्सिंग ताकि लिखने और पढ़ने के मॉडल स्वतंत्र रूप से विकसित हो सकें, और विभाजित मस्तिष्क समाधान ताकि नेटवर्क विभाजन डेटा को भ्रष्ट न करें। मैं यह भी ध्यान रखता हूँ कि आप केवल युद्ध में क्या याद रखते हैं: निष्क्रिय अभिनेताओं का पासिवेशन, बिना डाउनटाइम के अपडेट, और आइडेम्पोटेंट हैंडलर्स के साथ कम से कम एक बार डिलीवरी।

यदि आप एक ऐसा सिस्टम चाहते हैं जो समवर्तीता के बारे में ईमानदार हो, न कि इसे लॉक के पीछे छिपाए, तो मुझसे संपर्क करें। मैं आपकी वर्तमान आर्किटेक्चर का विश्लेषण करूंगा या शून्य से शुरू करूंगा, परीक्षण किए गए अभिनेताओं को लिखूंगा, और ऐसा कोड सौंपूंगा जिसे समझा जा सके। सामान्य कार्य:
— नए अभिनेता-आधारित बैकएंड और संदेश प्रोटोकॉल;
— एक अवरुद्ध सेवा को Akka Streams में माइग्रेट करना;
— एक लाइव एप्लिकेशन में क्लस्टर शार्डिंग और इवेंट सोर्सिंग जोड़ना;
— एक प्रोजेक्ट को बचाना जो लोड के तहत डेडलॉक्स और अभिनेताओं को लीक करता है।