MySQL में एक कतार के साथ एक साधारण कार्य सर्वर (कोई लॉक समस्या नहीं)

लगभग हर अधिक या कम गतिशील परियोजना में, पृष्ठभूमि में कार्य कतारें (ईमेल भेजना, कैश को अपडेट करना, खोज को फिर से करना, आदि) निष्पादित करने की आवश्यकता होती है। जॉब सर्वर (गियरमैन, आदि) अच्छे हैं, लेकिन अधिकांश सरल कार्यों के लिए वे बेमानी हैं। समय के साथ बढ़ते लोड के साथ MySQL में क्यूज़ का शास्त्रीय कार्यान्वयन (SELECT ... LOCK FOR UPDATE का उपयोग करके) लॉकिंग के साथ समस्याओं को जन्म देता है। इसलिए, जैसा कि आमतौर पर होता है, मुझे पृष्ठभूमि के कार्यों के साथ काम करने के लिए अपनी खुद की "साइकिल" लिखनी पड़ी, जो "बिल्कुल काम करेगा" और बेहद सरल होगी।

आधार: क्रोन, PHP 5.3 (mysqli), MySQL> 5.1 - यह लगभग किसी भी होस्टिंग से चिपकना आसान है।
किसी कार्य को प्राप्त करने (कैप्चर करने) का कार्य परमाणु (एक अद्यतन अनुरोध) है। लॉकिंग और आरसी के साथ कोई समस्या नहीं।
कार्यकर्ताओं और प्राथमिकताओं के समूहों में कार्यों को वितरित करने की संभावना, डेटा की एक सरणी को एक निष्पादन योग्य विधि (फ़ंक्शन) में स्थानांतरित करना।
पूर्ण किए गए कार्यों के प्रसंस्करण के तीन तरीके: रिकॉर्ड को एक अलग तालिका में ले जाएं, रिकॉर्ड हटाएं, रिकॉर्ड छोड़ दें और इसे सफलतापूर्वक संसाधित करें।
अपूर्ण कार्यों को संसाधित करना या किसी त्रुटि के साथ संसाधित किए गए कार्य डेवलपर की अंतरात्मा पर है।
सब कुछ के बारे में सब कुछ के लिए कोड की 400 लाइनें (पूर्ण PHPDOC के साथ)।
सीमाएं: वर्तमान कार्यान्वयन लगातार कनेक्शन के लिए उपयुक्त नहीं है, लेकिन अगर किसी को इसकी आवश्यकता है, तो इसे समाप्त करना आसान है। अगर आप दूसरी भाषा में फिर से लिखना चाहते हैं तो भी :)

कतार के साथ गैर-अवरुद्ध कार्य की संभावना को उनके बाद के चयन के साथ एक अद्यतन अनुरोध में उपयोगकर्ता चर के उपयोग के माध्यम से महसूस किया जाता है। इस तकनीक का एक पूरा लेख समर्पित करना मूर्खतापूर्ण है। अंतिम कार्यान्वयन जो मामले पर लागू किया जा सकता है वह बहुत अच्छा है (हम आपके साथ अभ्यास कर रहे हैं, हम नहीं हैं?)। अन्य सभी मामलों में, यह समूहों और प्राथमिकताओं के साथ एक विशेष रूप से क्लासिक लाइनअप है।

उपयोग उदाहरण (ग्राहक):

$task_server = \DBTaskServer::create('localhost', 'root', '', 'testDB', 'jobs_queue'); $task_server->addTask('mywork', $data); 

mywork एक फ़ंक्शन है जो कार्यकर्ता को उपलब्ध होना चाहिए। $ डेटा का एक सरणी इसे पारित किया जाएगा। स्थिर वर्ग विधियों के लिए कॉल निर्दिष्ट करना भी संभव है।

 $task_server->addTask('MyWork::doWork', $data); 

कार्यकर्ता उदाहरण:

 \DBTaskServer::create('localhost', 'root', '', 'testDB', 'jobs_queue') //  . ->setByCLIAgruments($argv) //     . ->setMode(\DBTaskServer::MODE_MARK_AS_COMPLETED) //   . ->run(); //  . 

पैरामीटर के साथ कंसोल से एक कार्यकर्ता को लॉन्च करना:

 /path/to/script/worker.php [max_tasks_per_lifecycle] [comma_separated_group_ids] 

जैसा कि नाम का अर्थ है, पहला विकल्प बताता है कि काम पूरा करने से पहले कार्यकर्ता कितने काम कर सकता है (जब तक कि निश्चित रूप से उसके लिए उपलब्ध नहीं हैं), दूसरा विकल्प उन कार्यों के समूह_एड मान हैं जिन्हें इस कार्यकर्ता को संसाधित करना चाहिए। यदि कोई समूह निर्दिष्ट नहीं है, तो कार्यकर्ता किसी भी समूह को संसाधित करता है।

उदाहरण के लिए:

 /path/to/script/worker.php 100 3,5,6 

समूह 3, 5 और 6 से 100 कार्य पूरे करें।
यदि कोई कार्य नहीं मिलता है, तो कार्यकर्ता तुरंत अपना काम पूरा करेगा।

कार्यकर्ता को मुकुट में जोड़ें:

 0-59/5 * * * * /path/to/script/worker.php 5 3 >/dev/null 2>&1 

हर 5 मिनट में, group_id = 3 के साथ 5 नौकरियों की प्रक्रिया करें।

संग्रह में क्लाइंट, कार्यकर्ता, सर्वर वर्ग स्वयं (दस्तावेज), टास्क टेबल के साथ एसक्यूएल फ़ाइल के उदाहरण हैं।
यहां डाउनलोड करें (5kB के रूप में कई)।

एक अच्छा कोड है।