ASP.NET वेब एपीआई में समानांतर डेटा ताज़ा

मैं आपको बताना चाहता हूं कि हमने REST सेवा के अनुरोध के दौरान पृष्ठभूमि डेटा अद्यतन कैसे व्यवस्थित किया।

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

कार्य शोधन

सेवा डेटाबेस में, हम उपयोगकर्ताओं के नाम और उपनाम संग्रहीत करते हैं। संसाधन बनाने या संशोधित करने के बारे में जानकारी के लिए ग्राहकों की आवश्यकता होती है।

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

जो लोग ASP.NET में पृष्ठभूमि कार्यों के बारे में अधिक जानना चाहते हैं, मैं आपको इसके बारे में एक अच्छा लेख पढ़ने की सलाह देता हूं।

निर्णय

हमारे पास एक DbRefresher वर्ग है जो RefreshAsync विधि में उपयोगकर्ता डेटा जोड़ता है या बदलता है।

हमारे नियंत्रक अधिकृत विशेषता का उपयोग करते हैं। हमारे वंश को इस श्रेणी में जोड़ें और OnAuthorization विधि को ओवरराइड करें:

public override void OnAuthorization(HttpActionContext actionContext) { base.OnAuthorization(actionContext); if (IsAuthorized(actionContext)) DbRefresher.RefreshAsync(actionContext.RequestContext.Principal) .ContinueWith(t => { LogFactory.For<AuthorizeAndRefreshUserAttribute>() .ErrorException("Error occured", t.Exception); }, TaskContinuationOptions.OnlyOnFaulted); } 

DbRefresher.RefreshAsync एक एसिंक्रोनस विधि है जो एक टास्क ऑब्जेक्ट देता है जो दूसरे थ्रेड में निष्पादित करना जारी रखता है। OnAuthorize पद्धति कार्य पूरा होने की प्रतीक्षा किए बिना तुरंत बाहर निकल जाती है। दुर्घटना की स्थिति में, लॉग में एक त्रुटि संदेश जोड़ा जाएगा।

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

परीक्षण

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

 [TestMethod] public void ConcurrentTest() { const int threadCount = 10; var tasks = new Task[threadCount]; for (int i = 0; i < threadCount; i++) { // DoOperations contains several CRUD operations on resources tasks[i] = Task.Factory.StartNew(DoOperations); } Task.WaitAll(tasks); } 

समस्याओं

यदि नियंत्रक के कुछ एक्शन-तरीकों के संचालन के लिए यह आवश्यक है कि डेटाबेस में स्पष्ट रूप से वर्तमान उपयोगकर्ता का डेटा शामिल है, तो यह दृष्टिकोण उपयुक्त नहीं है। आपको DbRefresher.RefreshAsync पद्धति में एक स्पष्ट कॉल का उपयोग करना होगा।

एक साथ कई अनुरोधों के साथ डेटाबेस में एक नया उपयोगकर्ता जोड़ते समय समस्याएं हो सकती हैं। यदि मौजूदा कुंजी के साथ किसी उपयोगकर्ता को तालिका में जोड़ने का प्रयास किया जाता है, तो आपको प्राथमिक कुंजी उल्लंघन अपवाद को पकड़ना चाहिए और काम करना बंद कर देना चाहिए। तब उपयोगकर्ता डेटा अपडेट करने के सभी कार्य केवल एक थ्रेड द्वारा किए जाएंगे।

निष्कर्ष

यह दृष्टिकोण एक वर्ष से अधिक समय से हमारी एक सेवा कोनफ्रमिट में काम कर रहा है।
यह मुझे सरल और सुरुचिपूर्ण लगता है। समुदाय की राय जानना दिलचस्प होगा।