Yii पर अन्य क्लाइंट और सर्वर

परिचय

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

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

स्रोत कोड का एक भाग लेख के शरीर में डाला जाना था, इसलिए यह काफी स्वेच्छा से निकला।

नीचे उतर रहा है

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

सर्वर साइड

तैयार किए गए समाधानों में से एक का उपयोग करना संभव था, उदाहरण के लिए, आराम से, लेकिन मैंने अध्ययन किया और यह समझने की इच्छा थी कि यह कैसे काम करता है या अंदर से काम करना चाहिए। इसलिए, हम अपने बच्चे के कौतुक के आविष्कार में लगे रहेंगे।

कैसे सर्वर साइड खुद को बनाने के लिए आधिकारिक परियोजना विकी में बहुत विस्तृत है । यह निर्णय एक आधार के रूप में लिया गया था।

वाई- रीस्ट -एप्लिकेशन की पहचान का मुख्य जादू urlManager सेटिंग्स में संरक्षित / config / main.php में होता है :

'urlManager' => array( 'urlFormat' => 'path', 'showScriptName' => false, 'rules' => array( // REST patterns array('api/list', 'pattern' => 'api/<model:\w+>', 'verb' => 'GET'), array('api/view', 'pattern' => 'api/<model:\w+>/<id:\d+>', 'verb' => 'GET'), array('api/update', 'pattern' => 'api/<model:\w+>/<id:\d+>', 'verb' => 'PUT'), array('api/delete', 'pattern' => 'api/<model:\w+>/<id:\d+>', 'verb' => 'DELETE'), array('api/create', 'pattern' => 'api/<model:\w+>', 'verb' => 'POST'), // Other rules '<controller:\w+>/<id:\d+>'=>'<controller>/view', '<controller:\w+>/<action:\w+>/<id:\d+>'=>'<controller>/<action>', '<controller:\w+>/<action:\w+>'=>'<controller>/<action>', ), ), 

यह ये नियम हैं जो फॉर्म का अनुरोध प्रेषित करते हैं:

POST api.domain.ru/api/users

में

POST api.domain.ru/api/create?model=users

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

  if (isset($_GET['model'])) $_model = CActiveRecord::model(ucfirst($_GET['model'])); 

अगला, मैं नियंत्रक की पूरी सूची देता हूं, जो मेरे मामले में निकला (मैंने जानबूझकर कक्षा के सहायक तरीकों के कार्यान्वयन को हटा दिया, जो बिना बदलाव के ऊपर दिए गए लिंक से उदाहरण से लिया गया था, इसके अलावा, अध्याय के अंत में पूर्ण स्रोत Yii आवेदन का एक लिंक है):

 <?php class ApiController extends Controller { Const APPLICATION_ID = 'ASCCPE'; private $format = 'json'; public function filters() { return array(); } public function actionList() { if (isset($_GET['model'])) $_model = CActiveRecord::model(ucfirst($_GET['model'])); if (isset($_model)) { $_data = $_model->summary($_GET)->findAll(); if (empty($_data)) $this->_sendResponse(200, sprintf('No items were found for model <b>%s</b>', $_GET['model'])); else { $_rows = array(); foreach ($_data as $_d) $_rows[] = $_d->attributes; $this->_sendResponse(200, CJSON::encode($_rows)); } } else { $this->_sendResponse(501, sprintf( 'Error: Mode <b>list</b> is not implemented for model <b>%s</b>', $_GET['model'])); Yii::app()->end(); } } public function actionView() { if (isset($_GET['model'])) $_model = CActiveRecord::model(ucfirst($_GET['model'])); if (isset($_model)) { $_data = $_model->findByPk($_GET['id']); if (empty($_data)) $this->_sendResponse(200, sprintf('No items were found for model <b>%s</b>', $_GET['model'])); else $this->_sendResponse(200, CJSON::encode($_data)); } else { $this->_sendResponse(501, sprintf( 'Error: Mode <b>list</b> is not implemented for model <b>%s</b>', $_GET['model'])); Yii::app()->end(); } } public function actionCreate() { $post = Yii::app()->request->rawBody; if (isset($_GET['model'])) { $_modelName = ucfirst($_GET['model']); $_model = new $_modelName; } if (isset($_model)) { if (!empty($post)) { $_data = CJSON::decode($post, true); foreach($_data as $var => $value) $_model->$var = $value; if($_model->save()) $this->_sendResponse(200, CJSON::encode($_model)); else { // Errors occurred $msg = "<h1>Error</h1>"; $msg .= sprintf("Couldn't create model <b>%s</b>", $_GET['model']); $msg .= "<ul>"; foreach($_model->errors as $attribute => $attr_errors) { $msg .= "<li>Attribute: $attribute</li>"; $msg .= "<ul>"; foreach($attr_errors as $attr_error) $msg .= "<li>$attr_error</li>"; $msg .= "</ul>"; } $msg .= "</ul>"; $this->_sendResponse(500, $msg); } } } else { $this->_sendResponse(501, sprintf( 'Error: Mode <b>create</b> is not implemented for model <b>%s</b>', $_GET['model'])); Yii::app()->end(); } } public function actionUpdate() { $post = Yii::app()->request->rawBody; if (isset($_GET['model'])) { $_model = CActiveRecord::model(ucfirst($_GET['model']))->findByPk($_GET['id']); $_model->scenario = 'update'; } if (isset($_model)) { if (!empty($post)) { $_data = CJSON::decode($post, true); foreach($_data as $var => $value) $_model->$var = $value; if($_model->save()) { Yii::log('API update -> '.$post, 'info'); $this->_sendResponse(200, CJSON::encode($_model)); } else { // Errors occurred $msg = "<h1>Error</h1>"; $msg .= sprintf("Couldn't update model <b>%s</b>", $_GET['model']); $msg .= "<ul>"; foreach($_model->errors as $attribute => $attr_errors) { $msg .= "<li>Attribute: $attribute</li>"; $msg .= "<ul>"; foreach($attr_errors as $attr_error) $msg .= "<li>$attr_error</li>"; $msg .= "</ul>"; } $msg .= "</ul>"; $this->_sendResponse(500, $msg); } } else Yii::log('POST data is empty'); } else { $this->_sendResponse(501, sprintf( 'Error: Mode <b>update</b> is not implemented for model <b>%s</b>', $_GET['model'])); Yii::app()->end(); } } public function actionDelete() { if (isset($_GET['model'])) $_model = CActiveRecord::model(ucfirst($_GET['model'])); if (isset($_model)) { $_data = $_model->findByPk($_GET['id']); if (!empty($_data)) { $num = $_data->delete(); if($num > 0) $this->_sendResponse(200, $num); //this is the only way to work with backbone else $this->_sendResponse(500, sprintf("Error: Couldn't delete model <b>%s</b> with ID <b>%s</b>.", $_GET['model'], $_GET['id']) ); } else $this->_sendResponse(400, sprintf("Error: Didn't find any model <b>%s</b> with ID <b>%s</b>.", $_GET['model'], $_GET['id'])); } else { $this->_sendResponse(501, sprintf('Error: Mode <b>delete</b> is not implemented for model <b>%s</b>', ucfirst($_GET['model']))); Yii::app()->end(); } } private function _sendResponse($status = 200, $body = '', $content_type = 'text/html') { ... } private function _getStatusCodeMessage($status) { ... } private function _checkAuth() { ... } } 

इस दृष्टिकोण के साथ, उपयुक्त मॉडल तैयार करना आवश्यक है। उदाहरण के लिए, ActiveRecord में निर्मित सरणी चर विशेषताएँ केवल डेटाबेस में तालिका संरचना के आधार पर बनाई गई हैं। यदि चयन में संबंधित तालिकाओं या कम्प्यूटेबल फ़ील्ड्स से फ़ील्ड्स को शामिल करने की आवश्यकता है, तो getAttributes विधियों को ओवरलोड करना आवश्यक है और यदि आवश्यक हो, मॉडल में है । एक उदाहरण के रूप में, getAttributes का मेरा कार्यान्वयन:

  public function getAttributes($names = true) { $_attrs = parent::getAttributes($names); $_attrs['quota_limit'] = $this->limit['bytes_in_avail']; $_attrs['quota_used'] = $this->tally['bytes_in_used']; return $_attrs; } 

यह सही ढंग से काम करने के लिए पेजिंग और सॉर्टिंग के लिए मॉडल में एक नामांकित गुंजाइश सारांश बनाने के लिए भी आवश्यक है। "

  public function summary($_getvars = null) { $_criteria = new CDbCriteria(); if (isset($_getvars['count'])) { $_criteria->limit = $_getvars['count']; if (isset($_getvars['page'])) $_criteria->offset = ($_getvars['page']) * $_getvars['count']; } if (isset($_getvars['sort'])) $_criteria->order = str_replace('.', ' ', $_getvars['sort']); $this->getDbCriteria()->mergeWith($_criteria); return $this; } 

मॉडल का पूरा पाठ:

 <?php /** * This is the model class for table "ftpuser". * * The followings are the available columns in table 'ftpuser': * @property string $id * @property string $userid * @property string $passwd * @property integer $uid * @property integer $gid * @property string $homedir * @property string $shell * @property integer $count * @property string $accessed * @property string $modified */ class Ftpuser extends CActiveRecord { // Additional quota parameters public $quota_limit; public $quota_used; /** * Returns the static model of the specified AR class. * @return ftpuser the static model class */ public static function model($className=__CLASS__) { return parent::model($className); } /** * @return string the associated database table name */ public function tableName() { return 'ftpuser'; } /** * @return array validation rules for model attributes. */ public function rules() { // NOTE: you should only define rules for those attributes that // will receive user inputs. return array( array('uid, gid, count', 'numerical', 'integerOnly' => true), array('userid, passwd, homedir', 'required'), array('userid, passwd', 'length', 'max' => 32), array('homedir', 'length', 'max' => 255), array('shell', 'length', 'max' => 16), array('accessed, modified, quota_limit, quota_used', 'safe'), //array('userid', 'unique'), // The following rule is used by search(). // Please remove those attributes that should not be searched. array('id, userid, passwd, uid, gid, homedir, shell, count, accessed, modified', 'safe', 'on' => 'search'), ); } /** * @return array relational rules. */ public function relations() { // NOTE: you may need to adjust the relation name and the related // class name for the relations automatically generated below. return array( 'limit' => array(self::HAS_ONE, 'FTPQuotaLimits', 'user_id'), 'tally' => array(self::HAS_ONE, 'FTPQuotaTallies', 'user_id'), ); } /** * @return array customized attribute labels (name=>label) */ public function attributeLabels() { return array( 'id' => 'Id', 'userid' => 'Userid', 'passwd' => 'Passwd', 'uid' => 'Uid', 'gid' => 'Gid', 'homedir' => 'Homedir', 'shell' => 'Shell', 'count' => 'Count', 'accessed' => 'Accessed', 'modified' => 'Modified', ); } /** * Retrieves a list of models based on the current search/filter conditions. * @return CActiveDataProvider the data provider that can return the models based on the search/filter conditions. */ public function search() { // Warning: Please modify the following code to remove attributes that // should not be searched. $criteria = new CDbCriteria; $criteria->compare('userid', $this->userid, true); $criteria->compare('homedir', $this->homedir, true); return new CActiveDataProvider('ftpuser', array( 'criteria' => $criteria, )); } public function summary($_getvars = null) { $_criteria = new CDbCriteria(); if (isset($_getvars['count'])) { $_criteria->limit = $_getvars['count']; if (isset($_getvars['page'])) $_criteria->offset = ($_getvars['page']) * $_getvars['count']; } if (isset($_getvars['sort'])) $_criteria->order = str_replace('.', ' ', $_getvars['sort']); $this->getDbCriteria()->mergeWith($_criteria); return $this; } public function getAttributes($names = true) { $_attrs = parent::getAttributes($names); $_attrs['quota_limit'] = $this->limit['bytes_in_avail']; $_attrs['quota_used'] = $this->tally['bytes_in_used']; return $_attrs; } protected function afterFind() { parent::afterFind(); $this->quota_limit = $this->limit['bytes_in_avail']; $this->quota_used = $this->tally['bytes_in_used']; } protected function afterSave() { parent::afterSave(); if ($this->isNewRecord && !empty($this->quota_limit)) { $_quota = new FTPQuotaLimits(); $_quota->user_id = $this->id; $_quota->name = $this->userid; $_quota->bytes_in_avail = $this->quota_limit; $_quota->save(); } } protected function beforeValidate() { if ($this->isNewRecord) { if (empty($this->passwd)) $this->passwd = $this->genPassword(); $this->homedir = Yii::app()->params['baseFTPDir'].$this->userid; } elseif ($this->scenario == 'update') { if (empty($this->quota_limit)) { FTPQuotaLimits::model()->deleteAllByAttributes(array('name' => $this->userid)); FTPQuotaTallies::model()->deleteAllByAttributes(array('name' => $this->userid)); } else { $_quota_limit = FTPQuotaLimits::model()->find('name = :name', array(':name' => $this->userid)); if (isset($_quota_limit)) { $_quota_limit->bytes_in_avail = $this->quota_limit; $_quota_limit->save(); } else { $_quota_limit = new FTPQuotaLimits(); $_quota_limit->name = $this->userid; $_quota_limit->user_id = $this->id; $_quota_limit->bytes_in_avail = $this->quota_limit; $_quota_limit->save(); } } } return parent::beforeValidate(); } protected function beforeDelete() { FTPQuotaLimits::model()->deleteAllByAttributes(array('name' => $this->userid)); FTPQuotaTallies::model()->deleteAllByAttributes(array('name' => $this->userid)); return parent::beforeDelete(); } private function genPassword($len = 6) { $chars = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789'; $count = mb_strlen($chars); for ($i = 0, $result = ''; $i < $len; $i++) { $index = rand(0, $count - 1); $result .= mb_substr($chars, $index, 1); } return $result; } } 

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

सर्वर भाग के साथ, ग्राहक के पास जाएं। रुचि रखने वालों के लिए, मैं यहां Yii सर्वर-साइड एप्लिकेशन का पूर्ण स्रोत कोड पोस्ट करता हूं। मुझे नहीं पता कि यह लिंक कब तक जीवित रहेगा, यदि अधिक व्यावहारिक सुझाव हैं जहां इसे और अधिक भरोसेमंद रूप से रखा जाए - कृपया टिप्पणियों में ध्यान दें।

ग्राहक भाग

मेरी बाइक न लिखने के लिए, एक छोटी सी खोज की गई और एक उत्कृष्ट ActiveResource एक्सटेंशन मिला। लेखक के अनुसार, प्रेरणा का स्रोत रूबी में ActiveResource का रेल पर कार्यान्वयन था। पृष्ठ में संक्षिप्त विवरण है कि कैसे स्थापित करें और कैसे उपयोग करें।

हालाँकि, लगभग तुरंत ही मुझे पता चला कि यह ActiveRecord इंटरफ़ेस के साथ संगत एक घटक है, लेकिन Yii GridView या ListView विजेट में उपयोग के लिए, ActiveDataProvider के साथ संगत घटक की आवश्यकता है। एक त्वरित खोज ने मुझे एक अलग शाखा में किए गए सुधारों के लिए लाया, जिसमें EActiveResourceDataProvider और EActiveResourceQueryCriteria शामिल हैं , साथ ही साथ फोरम थ्रेड में उनकी चर्चा जहां विस्तार के लेखक ने भाग लिया। ESort और EActiveResourceDataProvider के संशोधित संस्करण भी प्रकाशित किए गए थे ।

समाधान के सभी लालित्य के बावजूद, फ़ाइल पूरी नहीं थी। समस्या ग्रिड में खराबी के घटक था। स्रोत के एक त्वरित अध्ययन से पता चला है कि एक्सटेंशन में इस्तेमाल की जाने वाली ऑफसेट वास्तविक ऑफसेट थी, जिसे रिकॉर्ड की संख्या में व्यक्त किया गया था, जबकि ग्रिड व्यू में पेजेशन पेज नंबर का उपयोग करता है। यह पता चला कि प्रति पृष्ठ 10 रिकॉर्ड बनाते समय, जब पृष्ठ 2 पर जा रहे थे, तो हमें पृष्ठ 20 पर फेंक दिया गया था। हम कोड में चढ़ते हैं और इसे संपादित करते हैं। ऐसा करने के लिए, फ़ाइल में संरक्षित / एक्सटेंशन / EActiveResource / EActiveResourceQueryCriteria.php , बिल्डविकैस्ट्रिंग विधि के शरीर में , यह संपादित करें:

 if($this->offset>0) // array_push($parameters, $this->offsetKey.'='.$this->offset); array_push($parameters, $this->offsetKey.'='.$this->offset / $this->limit); 

उसके बाद, यह अधिक अनावश्यक के रूप में EActiveResourcePagination से getOffset विधि के अधिभार को हटाने के लिए आवश्यक है।

इसलिए, REST डेटा स्रोत का उपयोग करके एप्लिकेशन बनाते समय, आपको मैन्युअल रूप से आवश्यक मॉडल बनाने होंगे, बाकी बिना किसी समस्या के GII के माध्यम से बनाए जाएंगे।

अलग-अलग, मैं कई सर्वरों के साथ काम को नोट करना चाहता हूं। प्रारंभ में, दूरस्थ REST API का कनेक्शन विन्यास में वर्णित है, इसलिए डिफ़ॉल्ट रूप से हम अपनी साइट पर केवल एक कनेक्शन का उपयोग कर सकते हैं। डेटाबेस तालिका में संग्रहीत होने और ActiveResource घटक द्वारा उपयोग की जाने वाली कनेक्शन जानकारी के लिए, वहां से अतिभारित getConnection विधि के साथ एक वंशज बनाना आवश्यक था (यह एफ़टीपी उपयोगकर्ताओं के साथ मेरा मामला है, सर्वर डेटा को FTPServers मॉडल द्वारा वर्णित तालिका में संग्रहीत किया गया है):

 abstract class EActiveResourceSelect extends EActiveResource { /** * Returns the EactiveResourceConnection used to talk to the service. * @return EActiveResourceConnection The connection component as pecified in the config */ public function getConnection() { $_server_id = Yii::app()->session['ftp_server_id']; $_db_params = array(); if (isset($_server_id)) { $_srv = FTPServers::model()->findByPk($_server_id); if (isset($_srv)) $_db_params = $_srv->attributes; else Yii::log('info', "No FTP server with ID: $_server_id were found"); } else { $_srv = FTPServers::model()->find(); if (isset($_srv)) { $_db_params = $_srv->attributes; Yii::app()->session['ftp_server_id'] = $_srv->id; } else Yii::log("No FTP servers were found", CLogger::LEVEL_INFO); } self::$_connection = new EActiveResourceConnection(); self::$_connection->init(); self::$_connection->site = $_db_params['site']; self::$_connection->acceptType = $_db_params['acceptType']; self::$_connection->contentType = $_db_params['contentType']; if (isset($_db_params['username']) && isset($_db_params['password'])) { self::$_connection->auth = array( 'type' => 'basic', 'username' => $_db_params['username'], 'password' => $_db_params['password'], ); } return self::$_connection; } } 

ग्राहक भाग के आगे विकास सामान्य ActiveRecord का उपयोग करके विकास से बहुत भिन्न नहीं था, जो, मेरी राय में, ActiveResource एक्सटेंशन का मुख्य आकर्षण है।

आशा है कि लेख उपयोगी होगा।