अलावर साइट्स पर ताले लगाना

परिचय

आज हम ताले के बारे में बात करेंगे और हमारे कार्यान्वयन को दिखाएंगे। प्रत्येक डेवलपर्स को बार-बार एक समस्या का सामना करना पड़ता है जब किसी संसाधन के एकल-थ्रेडेड उपयोग को सुनिश्चित करना आवश्यक होता है।

अक्सर, इस तरह के लॉक को सुनिश्चित करने के लिए, एक योजना का उपयोग एक विशेष फ़ाइल के निर्माण के साथ किया जाता है, जिसकी उपस्थिति एक संसाधन के रोजगार के तथ्य को निर्धारित करती है।

यह दृष्टिकोण लागू करने के लिए काफी सरल है, लेकिन इसके कई नुकसान हैं। कमियों के बीच पहचाना जा सकता है:

• बड़ी संख्या में धागे के साथ अवरुद्ध होने की 100% गारंटी की कमी;
• एक सर्वर के भीतर काम करता है अवरुद्ध;
• और सबसे अप्रिय बात यह है कि यदि किसी कारण से लॉक सेट करने वाली प्रक्रिया ने इसे नहीं हटाया है, तो बाकी प्रक्रियाएं इस संसाधन तक मैन्युअल रूप से या किसी अन्य तरीके से इस लॉक तक पहुंचने में सक्षम नहीं होंगी।

मुझे कब ताले की आवश्यकता है?

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

इसे स्वयं कैसे करें?

सही तालों को लागू करने के लिए, आपको परमाणुता और लेन-देन के सिद्धांतों को समझने की आवश्यकता है। हम इस लेख में उनका वर्णन नहीं करेंगे, क्योंकि इन विषयों पर इंटरनेट पर पहले से ही बहुत सारी जानकारी मौजूद है।

कार्यान्वयन के दौरान, हमने तालों के साथ काम करते समय बुनियादी कार्यों का निर्धारण किया:

• एक निश्चित समय के लिए ताला लगाएं
• निर्दिष्ट समय के बाद अनलॉक करें
• लॉक का विस्तार करें
• जब लॉक को इंटरसेप्ट किया गया था, तो केस का काम करें

वास्तव में, यह बहुत महत्वपूर्ण नहीं है कि लॉक प्रोवाइडर के रूप में क्या उपयोग किया जाएगा, यह फाइल, mysql, memcache, या आपके लिए सुविधाजनक कोई भी अन्य उपकरण हो सकता है।

रेडिस हमारे करीब था, इसलिए हमने अपने लॉक तंत्र को लागू किया, जिसमें ऊपर सूचीबद्ध कमियां नहीं हैं, रेडिस पर।

हमारे साथ ताले कैसे बने हैं

आज हम आपके लिए "जैसा है" लगभग हर लाइन पर अतिरिक्त टिप्पणियों के साथ कार्यान्वयन और उपयोग का एक उदाहरण पेश करते हैं।

हमारे कार्यान्वयन का उपयोग Yii फ्रेमवर्क पर एक परियोजना में किया जाता है और Rediska लाइब्रेरी के माध्यम से Redis से कनेक्ट करने के लिए उपयोग किया जाता है। लेकिन Rediska की तरह Yii में टाई छोटी है, इसलिए इस कोड का इस्तेमाल किसी भी PHP प्रोजेक्ट में किया जा सकता है।

तो, चलिए मज़ेदार हिस्से पर आते हैं:

बेस लॉक क्लास

<?php /** *    * */ class Lock { /** *       * * @param string $key * @return string */ static protected function getKey( $key ) { return $key; } /** *  true,       * * @param string $key -   * @param float $timeWait -        * @param float $maxExecuteTime -       * @return bool */ static public function getLock( $key, $timeWait = 0, $maxExecuteTime = 3600 ) { throw new Lock_Exception('Not defined method getLock'); return false; } /** *     - * * @return string */ static protected function getCurrentProcessId() { static $myProcessId = false; if ( $myProcessId === false ) { $uname = posix_uname(); $mypid = getmypid(); $myProcessId = $uname['nodename'] . '_' . $mypid; } return $myProcessId; } /** *   * * @param string $key -   * @param float $delayAfter -          * @return bool */ static public function releaseLock( $key, $delayAfter = 0 ) { throw new Lock_Exception('Not defined method releaseLock'); return false; } /** *     * * @param string $key -   * @param float $timeProlongate -      * @return bool -   false,     */ static public function prolongate( $key, $timeProlongate ) { throw new Lock_Exception('Not defined method prolongate'); return false; } } class Lock_Exception extends Exception { } class Timeout_Lock_Exception extends Lock_Exception { } class LostLock_Timeout_Lock_Exception extends Timeout_Lock_Exception { } 

कक्षा फिर से करना

इस वर्ग में, Redis का उपयोग करके ताले बनाए जाते हैं:

 <?php /** *      Redis * */ class RedisLock extends Lock { /** *    noSQL  * * @param string $key * @return string */ static protected function getKey( $key ) { //   lock@      return 'lock@'.$key; } /** *  true,       * * @param string $key -   * @param float $timeWait -        * @param float $maxExecuteTime -       * @param integer $policy -   : * 0 -     ,      , * 1 -   10,    * @return bool */ static public function getLock( $key, $timeWait = 0, $maxExecuteTime = 3600, $policy = 0 ) { /** * ,     */ $timeStop = microtime(true) + $timeWait; //     Yii    Redis   Rediska $rediska = Yii::app()->rediskaConnection->connect(); while ( true ) { $currentTime = microtime(true); if ( $policy == 0 ) { /** *  ,     */ $expireAt = $rediska->getFromHash( self::getKey($key), 'expireAt' ); /** *  ,     ,     , *         */ if ( $expireAt > $timeStop ) { return false; } /** *     ,     ,    */ elseif ( $expireAt > $currentTime ) { usleep( 1000000 * intval($expireAt - $currentTime) ); $currentTime = microtime(true); } } elseif ( $policy == 1 ) { /** *  ,     */ $expireAt = $rediska->getFromHash( self::getKey($key), 'expireAt' ); while ( $expireAt > $timeStop || $expireAt > $currentTime ) { usleep( 10000 ); /** *  ,     */ $expireAt = $rediska->getFromHash( self::getKey($key), 'expireAt' ); $currentTime = microtime(true); if ( $currentTime >= $timeStop ) { return false; } } } $getLock = false; /** *     *  getConnectionByKeyName    ,      Redis */ $transaction = $rediska->transaction( $rediska->getConnectionByKeyName( self::getKey($key) ) ); $transaction->watch( self::getKey($key) ); $arData = $rediska->getHash( self::getKey($key) ); //     $daddy = isset($arData['daddy']) ? $arData['daddy'] : ''; //     $expireAt = isset($arData['expireAt']) ? $arData['expireAt'] : 0; /** *    ,     ,     *         */ if ( $daddy != self::getCurrentProcessId() && $expireAt < $currentTime ) { $transaction->setToHash( self::getKey($key), array( 'daddy' => self::getCurrentProcessId(), 'expireAt' => $currentTime + $maxExecuteTime ) ); $transaction->expire( self::getKey($key), ceil($currentTime + $maxExecuteTime), true ); try { $transaction->execute(); $getLock = 1; } catch ( Rediska_Transaction_Exception $e ) { /** *     */ $getLock = false; } } else { $getLock = false; $transaction->discard(); } /** *      */ if ( $getLock != 1 ) { // HSETNX $getLock = $rediska->setToHash( self::getKey($key), 'daddy', self::getCurrentProcessId(), false ); } /** *    */ if ( $getLock == 1 ) { /** *  ,     */ $rediska->setToHash(self::getKey($key), 'expireAt', $currentTime + $maxExecuteTime); $rediska->expire(self::getKey($key), ceil($currentTime + $maxExecuteTime), true); return true; } else { /** *       ,       */ if ( $timeStop > $currentTime ) { usleep(20000); } /** *  ,    */ else { return false; } } } } /** *   * * @param string $key -   * @param float $delayAfter -          * @return bool */ static public function releaseLock( $key, $delayAfter = 0 ) { $currentTime = microtime(true); $rediska = Yii::app()->rediskaConnection->connect(); $transaction = $rediska->transaction( $rediska->getConnectionByKeyName( self::getKey($key) ) ); $transaction->watch( self::getKey($key) ); $arData = $rediska->getHash( self::getKey($key) ); if ( is_array($arData) && isset($arData['daddy']) && isset($arData['expireAt']) ) { $daddy = $arData['daddy']; $expireAt = $arData['expireAt']; } else { $daddy = false; $expireAt = 0; } /** *          ,     */ if ( $daddy == self::getCurrentProcessId() ) { $transaction->setToHash(self::getKey($key), 'expireAt', $currentTime + $delayAfter); $transaction->expire(self::getKey($key), ceil($currentTime + $delayAfter), true); $transaction->deleteFromHash( self::getKey($key), 'daddy' ); /** *     */ try { $transaction->execute(); $result = true; } catch (Rediska_Transaction_Exception $e) { $result = false; } } else { $transaction->discard(); $result = false; } //       if ( $expireAt < $currentTime ) { if ( $result ) { /** *  ,     */ throw new Timeout_Lock_Exception('Timeout Lock on release'); } else { /** *       */ throw new LostLock_Timeout_Lock_Exception('Timeout Lock and it was lost before release'); } } return $result; } /** *     * * @param string $key -   * @param float $timeProlongate -      * @return bool -   false,     */ static public function prolongate( $key, $timeProlongate ) { $rediska = Yii::app()->rediskaConnection->connect(); $transaction = $rediska->transaction( $rediska->getConnectionByKeyName( self::getKey($key) ) ); $transaction->watch( self::getKey($key) ); $arData = $rediska->getHash( self::getKey($key) ); $daddy = $arData['daddy']; $expireAt = $arData['expireAt']; $currentTime = microtime(true); $result = false; if ( $daddy == self::getCurrentProcessId() ) { $transaction->setToHash( self::getKey($key), 'expireAt', $currentTime + $timeProlongate ); $transaction->expire(self::getKey($key), ceil($currentTime + $timeProlongate), true); try { $transaction->execute(); $result = true; } catch (Rediska_Transaction_Exception $e) { $result = false; } } else { $transaction->discard(); $result = false; } if ( $expireAt < $currentTime ) { if ( $result ) { throw new Timeout_Lock_Exception('Timeout Lock on prolongate'); } else { throw new LostLock_Timeout_Lock_Exception('Timeout Lock and Lost them on prolongate'); } } return $result; } } 

उदाहरण का उपयोग करें

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

  $lockKey = 'cron-report'; $timeWait = 0; $timeLock = 3600; if ( RedisLock::getLock( $lockKey, $timeWait, $timeLock ) ) { //  ,     ... //          ,     try { RedisLock::releaseLock( $lockKey, 0 ); echo 'Ok'; } catch ( Timeout_Lock_Exception $e ) { //   //     ,      ,             echo 'Timeout_Lock_Exception ' . ( $endTime - $currentTime ); } catch ( LostLock_Timeout_Lock_Exception $e ) { //   //     ,      ,               echo 'LostLock_Timeout_Lock_Exception' . ( $endTime - $currentTime ); } } 

हमें उम्मीद है कि हमारा कार्यान्वयन आपके लिए उपयोगी होगा।

आपके सवालों और टिप्पणियों का इंतजार रहेगा।