ZF + मेमकाटेड का उपयोग करते समय कैशिंग और टैग

प्रस्तावना

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

समस्या का वर्णन

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



विकास में कार्यों में से एक निम्नलिखित अर्थों में कैश का "स्मार्ट" उपयोग था:

• यदि आवश्यक हो, सभी वस्तुओं और किसी भी मॉडल के लिए वस्तुओं की सूची को कैश किया जा सकता है;
• यदि वस्तु बदलती है (व्यवस्थापक पैनल में संपादित):
  
  1. इसे कैश से निकाला जाना चाहिए, चाहे वह कैसा भी हो (यानी, इस ऑब्जेक्ट के खोज पैरामीटर जो भी हों, कम से कम प्राथमिक कुंजी के लिए, कम से कम किसी अन्य पैरामीटर के सेट के लिए);
  2. इस ऑब्जेक्ट (या इस मॉडल (तालिका) के लिए सभी सूचियों) वाली सभी सूचियों को कैश से हटा दिया जाना चाहिए।
  
  
• इस तरह की कार्यक्षमता नियंत्रकों, अंतिम मॉडल और, भाग में, मैपर्स के लिए (डेटा प्राप्त करते समय कैश का उपयोग करने या न करने के संभावित संकेत को छोड़कर) के लिए पारदर्शी होना चाहिए;
• कैश के साथ इंटरैक्ट करने के लिए इंटरफेस में बदलाव नहीं करना चाहिए।

इस प्रकार, यह पता चलता है कि कैश में डेटाबेस के लिए क्वेरी के परिणामों को सहेजते समय, आपको इसके लिए एक टैग जोड़ने की आवश्यकता होती है, जिसके द्वारा आप यह निर्धारित कर सकते हैं कि कैश में संग्रहीत मूल्य किस वस्तु / सूची / मॉडल का है। हां, और इस टैग को संग्रहीत करने के लिए भी किसी तरह की आवश्यकता है।

एक बार, मेम्केच्ड + मोंगोडीबी बंडल का उपयोग करके कैश से स्मार्ट हटाने के बारे में हब पर एक लेख ने मुझे समस्या को हल करने के लिए कुछ विचार दिए। हालाँकि, सर्वर से MongoDB जोड़ना संभव नहीं था। अब और निकट भविष्य में, अन्य कैशिंग सिस्टम (रेडिस आदि) सर्वर पर प्रदान नहीं किए जाते हैं।

समाधान और कोड

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

class System_ModelMapper { protected $_dbTable; //         protected $_modelName = ''; //  ,       -      public function __construct() { parent::__construct(); if (empty($this->_modelName)) { $parts = explode('_', get_class($this)); $this->_modelName = str_replace('Mapper', '', $parts[2]); } } //      dbtable    /** * @return /Zend_Db_Table_Abstract */ public function getDbTable() { if (null === $this->_dbTable) { $this->setDbTable('Application_Model_DbTable_' . $this->_modelName); } return $this->_dbTable; } public function setDbTable($dbTable) { if (is_string($dbTable)) { $dbTable = new $dbTable(); } if (!$dbTable instanceof Zend_Db_Table_Abstract) { throw new Exception('Invalid table data gateway provided'); } $this->_dbTable = $dbTable; return $this; } /** *       * @param array $params * @return System_Model */ public function getModel($params = array()) { $getInstance = 'Application_Model_' . $this->_modelName; return new $getInstance($params); } … } 

किसी एकल ऑब्जेक्ट को खोजने के लिए आगे कुछ तरीके हैं:

  /** *             * @param array $data   * @return string */ protected function objectCacheId($data) { $fields = array_keys($data); $values = md5(json_encode(array_values($data))); return 'find_' . $this->_modelName . '_' . join('_', $fields) . '_' . $values; } /** *           * @param $object System_Model * @return string */ public function getObjectCacheTag($object) { return 'object_' . $this->_modelName . '_' .$object->get_id(); } /** *       * @param numeric $id  ID * @param mixed $obj ,      * @param bool $cache         * @return bool|System_Model */ public function find($id, $obj = false, $cache = false) { return $this->findByFields(array('id' => $id), $obj, $cache); } /** *      * @param array $data     * @param mixed $obj ,      * @param bool $cache         * @return bool|System_Model */ public function findByFields($data, $obj = false, $cache = false) { //     -    ,        (        ,         (   :) ) if ($cache) { $cacheId = $this->objectCacheId($data); if (Zend_Registry::isRegistered(CACHE_NAME) { /** @var $cache System_Cache_Core */ $cache =& Zend_Registry::get(CACHE_NAME); //      -    if ($cache->test($cacheId)) { return $cache->load($cacheId); } } else { $cache = false; } } //   Zend_Db_Table         $select = $this->getDbTable()->select(); foreach ($data as $field => $value) { $select->where($select->getAdapter()->quoteIdentifier($field) . ' = ?', $value); } $row = $this->getDbTable()->fetchRow($select); if ($row) { if ($obj === false) { $obj = $this->getModel(); } $obj->setOptions($row->toArray()); } else { $obj = false; } //    -     if ($cache) { $cache->save($obj, $cacheId); } return $obj; } 

दिए गए कोड के अनुसार - जैसा कि आप देख सकते हैं, ऑब्जेक्ट खोज विधियों में टैग सिस्टम के बारे में कोई सुराग नहीं है। यह $ कैश ऑब्जेक्ट के स्तर पर काम करेगा।
अगला एक टेबल में ऑब्जेक्ट्स या यहां तक ​​कि सभी ऑब्जेक्ट्स का एक सेट खोजने के लिए कुछ तरीके हैं, पेजिंग और सॉर्टिंग को ध्यान में रखते हुए:

  /** *          ,    * @param array $data   * @param bool|string|array $order   * @param bool|System_Paginator $paginator     * @return string */ protected function listCacheId($data = array(), $order = false, $paginator = false) { $fields = array_keys($data); $values = md5(json_encode(array_values($data))); return sprintf('%s_%s_%s_%s_%s', $this->getListCacheTag(), join('_', $fields), $values, empty($order) ? '' : md5(json_encode($order)), is_object($paginator) ? $paginator->page . '_' . $paginator->limit : '' ); } /** *         * @return string */ public function getListCacheTag() { return 'list_' . $this->_modelName; } /** *        * @param array $data   * @param bool|string|array $order   * @param bool|System_Paginator $paginator     * @param bool|string $cache         */ public function fetchByFields($data = array(), $order = false, $paginator = false, $cache = false) { if ($cache) { $cacheId = $this->listCacheId($data, $order, $paginator); $cache .= 'Cache'; if (Zend_Registry::isRegistered(CACHE_NAME)) { /** @var $cache System_Cache_Core */ $cache =& Zend_Registry::get(CACHE_NAME); if ($cache->test($cacheId)) { return $cache->load($cacheId); } } else { $cache = false; } } //   ,           ,    $select = $this->getDbTable()->select(); $select_paginator = $this->getDbTable()->select(true); foreach ($data as $field => $value) { $s = '='; // value      ('=', 2)  ('<=', 10) if (is_array($value)) { $s = $value[0]; $value = $value[1]; } $select->where($select->getAdapter()->quoteIdentifier($field) . " $s ?", $value); $select_paginator->where($select->getAdapter()->quoteIdentifier($field) . " $s ?", $value); } //    if (!empty($order)) { $select->order($order); } else { $select->order('id ASC'); } //   ,     if (is_object($paginator)) { //        ,    $fetch_count = $this->getDbTable()->fetchRow($select_paginator->columns('count(id) as _c'))->toArray(); $paginator->total = $fetch_count['_c']; //    ,     ,     if ($paginator->page > $paginator->getLastPage()) $paginator->page = $paginator->getLastPage(); //       $select->limitPage($paginator->page, $paginator->limit); } $resultSet = $this->getDbTable()->fetchAll($select); $result = $this->rowsToObj($resultSet); //      -         (        limit) if (is_object($paginator)) { $paginator->inlist = count($result); } if ($cache) { $cache->save($result, $cacheId); } return $result; } /** *         * @param bool|string|array $order   * @param bool|System_Paginator $paginator     * @param bool|string $cache         * @return array|bool */ public function fetchAll($order = false, $paginator = false, $cache = false) { return $this->fetchByFields(array(), $order, $paginator, $cache); } /** *         * @param Zend_Db_Table_Rowset_Abstract $rowset     * @return array|bool */ protected function rowsToObj($rowset) { if (!empty($rowset)) { $entries = array(); foreach ($rowset as $row) { /** @var $entry System_Model */ $entry = $this->getModel($row->toArray()); $entries[$entry->get_id()] = $entry; } return $entries; } return false; } 

दिए गए कोड के अनुसार, यहां यह भी देखा गया है कि नमूना लेने के तरीके स्वयं टैग प्रणाली से सीधे संबंधित नहीं हैं।

अगला, हम कक्षा कोड देते हैं जो कि मानक Zend_Cache_Core से विरासत में मिला है और इसका उपयोग तब किया जाता है जब मेम्केड के साथ काम करने के लिए बूटस्ट्रैप ऑब्जेक्ट को इनिशियलाइज़ करता है। और उसके बाद हम डेटाबेस में ऑब्जेक्ट्स को बचाने, अपडेट करने और हटाने के लिए मैपर और तरीकों पर फिर से लौटेंगे।

 class System_Cache_Core extends Zend_Cache_Core { /** *    save   */ public function save($data, $id = null, $tags = array(), $specificLifetime = false, $priority = 8) { //      $ida = explode('_', $id); //        ,          switch ($ida[0]) { case 'list': //       2   (    ) $tag = join('_', array_splice($ida, 0, 2)); $this->updateTagList($tag, $id); break; case 'find': //   -       if ($data instanceof System_Model) { $tag = $data->get_mapper()->getObjectCacheTag($data); $this->updateTagList($tag, $id); } break; } //           return parent::save($data, $id, $tags, $specificLifetime, $priority); } /** *        * @param string $tag * @param string $cacheId */ public function updateTagList($tag, $cacheId) { //       $list = $this->getListByTag($tag); $list[] = $cacheId; //         $this->saveListByTag($tag, $list); } /** *      * @param string $tag */ protected function getListByTag($tag) { $tagcacheId = '_taglist_' . $tag; $list = array(); if ($this->test($tagcacheId)) { $list = $this->load($tagcacheId); } return $list; } /** *         * @param string $tag * @param array $list */ protected function saveListByTag($tag, $list) { $tagcacheId = '_taglist_' . $tag; $this->save($list, $tagcacheId); } /** *         * @param System_Model $object */ public function removeByObject($object = null) { if ($object instanceof System_Model) { //       $this->removeByTag($object->get_mapper()->getListCacheTag()); //             if ($object->get_id()) { $this->removeByTag($object->get_mapper()->getObjectCacheTag($object)); } } } /** *         * @param string $tag */ public function removeByTag($tag) { //      $list = $this->getListByTag($tag); //      foreach ((array)$list as $cacheId) { $this->remove($cacheId); } //      , ,    $this->saveListByTag($tag, array()); } } 

खैर, यह वस्तुओं को बचाने और हटाने के लिए मैपर विधियों का उल्लेख करने के लिए बना हुआ है:

  /** *     * @param System_Model $object   * @param boolean $isInsert    * @return array|bool|mixed */ public function save($object, $isInsert = false) { $data = $object->toArray(); $find = array('id = ?' => $object->get_id()); if (null === ($id_value = $object->get_id())) { $isInsert = true; unset($data['id']); } if ($isInsert) { $pk = $this->getDbTable()->insert($data); if ($pk) { $object->set_id($pk); } $this->resetCache(); return $pk; } else { //    -       return $this->getDbTable()->update($data, $find) && $this->resetCache($object); } } /** *     * @param $object System_Model * @return array|bool|mixed */ public function insert($object) { return $this->save($object, true); } /** *     * @param $object System_Model   * @return bool */ public function remove($object) { $primary = $this->getDbTable()->get_primary(); $where = array('id = ?' => $object->get_id()); //   -      return ($this->getDbTable()->delete($where) && $this->resetCache($object)); } /** *         * @param System_Model $object * @param array $cacheIds * @return bool */ public function resetCache($object = null, $cacheIds = array()) { //       if (Zend_Registry::isRegistered(CACHE_NAME)) { /** @var $cache System_Cache_Core */ $cache = Zend_Registry::get(CACHE_NAME); if (!empty($object)) { //       $cache->removeByObject($object); } else { //     $cache->removeByTag($this->getListCacheTag()); } foreach ($cacheIds as $cacheId) { $cache->remove($cacheId); } } return true; } } 

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

वैसे, समस्या और छोटी चीजें (जो किए जाने और हल किए जाने की योजना है):

• सभी उपसर्गों ('सूची', 'ऑब्जेक्ट', '_taglist_' आदि) को स्थिरांक में रखें;
• System_Cache_Core के अंदर सूचियों के लिए टैग को $ tag = join ('_', array_splice ($ ida, 0, 2)) के रूप में परिभाषित किया गया है, जो पूरी तरह से अच्छा नहीं है और सीधे मैपर में टैग की परिभाषा के अनुरूप नहीं है। एक जगह (मैपर विधि में) सूची के लिए टैग की परिभाषा का स्थानीयकरण अंतिम मैपर्स को इस विधि को फिर से परिभाषित करने और टैग पीढ़ी एल्गोरिथ्म और स्वयं टैग में पैरामीटर जोड़ने की अनुमति देगा;
• ऑब्जेक्ट के लिए टैग इस ऑब्जेक्ट की प्राथमिक कुंजी के आधार पर बनाया गया है, जो निम्न प्रकार की समस्याओं को जन्म दे सकता है: यदि ऑब्जेक्ट की खोज की जाती है, उदाहरण के लिए, पैरामीटर is_published = 1 है और यह नहीं मिला है (यह प्रकाशित है, लेकिन प्रकाशित नहीं है), तो अनुरोध के लिए कैशिंग कुंजी स्पष्ट है कारणों से, यह इस ऑब्जेक्ट के लिए टैग सूची में नहीं आया, और हम प्रोजेक्ट व्यवस्थापक पैनल में ऑब्जेक्ट को "प्रकाशित" करने के बाद - इस कुंजी के लिए कैश प्रविष्टि को मंजूरी नहीं दी जाएगी और वस्तु फिर से नहीं मिलेगी (और गलत को कैश से लिया जाएगा) TTL इस कैश प्रविष्टि के लिए समाप्त हो जाएगा।

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

पुनश्च सभी आगामी के साथ!