डेमॉन प्रक्रियाओं में डॉक्ट्रिन ODM का उपयोग करने में समस्याएं

मैं अपेक्षाकृत छोटे PHP प्रोजेक्ट में Doctrine ODM का उपयोग करके अपने अनुभव के बारे में बात करना चाहता हूं जिसमें मुख्य कोड आधार डेमॉन प्रक्रियाओं में केंद्रित है। और सामान्य तौर पर, हम कैसे Yct2 को Doctrine ODM उपवास किया। मैं आपको तुरंत चेतावनी देता हूं - कहानी बहुत थकाऊ होगी और सबसे अधिक संभावना केवल उन लोगों के लिए दिलचस्प होगी जो डेमॉन प्रक्रियाओं में डॉक्ट्रिन ODM के साथ काम करते समय पहले से ही समस्याओं का सामना कर चुके हैं।

हम कहाँ फँसेंगे

लगभग 6 साल पहले, उन्होंने मुझे कार्य सौंपा: एक मोनोलिथ Yii1से कोड के एक टुकड़े को एक अलग सेवा में काटने के लिए । तुरंत पूरा किया हुआ काम। फ्रेमवर्क लंबे समय तक नहीं चुना, सिवाय इसके कि Yiiमुझे कुछ भी पता नहीं है, और फिर उन्होंने एक आसन्न रिलीज की घोषणा की Yii2, जो उस समय बहुत ही स्टाइलिश / फैशनेबल / युवा लग रहा था, लेकिन इस ढांचे के पहले संस्करण के ज्ञान ने दूसरे संस्करण में प्रवेश करने के लिए सीमा को कम करने की अनुमति दी। MongoDB भी फैशनेबल था, जिसके साथ हम पहले से परिचित थे और Yii1एक अलग विस्तार के साथ काम किया Yii2था , लेकिन इसे बॉक्स से बाहर का समर्थन किया गया था।

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

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

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

PHP 7- , . ActiveRecord Yii2 — "" , , phpdoc. MongoDB, - , - {user_id : '12'}

, . - , Yii2 . , , , , , .

, , MongoDB.
Symfony Doctrine ORM, Doctrine ODM — ORM MongoDB.

Yii2 Symfony , , :
- — , , .
- — ActiveRecord " " Yii2

, ActiveRecord Doctrine ODM, . , ORM .

. Doctrine DocumentManager ( EntityManager Doctrine ORM). " ".

Dependency Injection Container Yii2 , .

Yii2 DataProvider'a. -, CRUD- . " " . , Yii2. , , — , .

, Doctrine UnitOfWork , .

, : DI- , . - , Symfony .

, :

while (!$this->isShuttingDown()) {
    //  Task,  ,     
    //  MANAGED    ,
    //     
    $task = $this->taskProvider->getNextTask();
    try {
        //   -  , ,  
        $this->someService->runTask($task);
    } catch (SomeException $e) {
        //    :       
        //     MANAGED,      
        //       -     
        $this->switchTaskToError($task, $e);
    }
}

, - dirty ( flush() ), , , .

— clear() "" . , , . clear() , , , $this->someService->runTask($task);

, ( , — ), . . , , . , , . .

:

while (!$this->isShuttingDown()) {
    //  ,  , 
    //   -  ,   
    //    detached,      , 
    //      
    $task = $this->taskProvider->getNextTask();
    try {
        //   -     
        $this->someService->runTask($task);
    } catch (SomeException $e) {
        //    ,  -   
        $this->switchTaskToError($task, $e);
    }
}

taskProvider someService , .

merge. runTask() :

public function runTask(Task $task) {
    $dm = $thic->dmFactory->createDocumentManager();
    $task = $dm->merge($task);
    ....
    $task->setStatus(Task::STATUS_OK);
    $dm->flush();
}

switchTaskToError() :

public function switchTaskToError(Task $task, Throwable $) {
    $dm = $this->dmFactory->createDocumentManager();
    $task = $dm->merge($task);
    $task->setStatus(Task::STATUS_ERROR);
    $task->setError($e->getMessage());
    $dm->flush();
}

, $dm .

, , - . , :

$tasks = $this->taskProvider->getProblemTasks();
$dm = $thic->dmFactory->createDocumentManager();
foreach ($tasks as $task) {
     $task = $dm->merge($task);
     $task->setState(..);
}
$dm->flush();

getProblemTasks , , "" , Task merge(). , merge() — .. , .

, , :

$dm = $thic->dmFactory->createDocumentManager();
$tasks = $this->taskProvider->getProblemTasks($dm);
foreach ($tasks as $task) {
     $task->setState(..);
}
$dm->flush();

.

JPA

, Doctrine JPA: , UnitOfWork, (managed, detached ..). JPA , , . , — . (Spring Framework ). JPA , , .

, , . - , , - (? ), ( ). , , .

, hibernate Doctrine.

Doctrine ODM

" doctrine" , - http , , , .

, . , . . , :

$session = $this->sessionManager->createNewSession();
try {
    $dm= $session->getDocumentManager();
    $tasks = $this->taskProvider->getProblemTasks();
    foreach ($tasks as $task) {
        $task->setState(..);
    }
    $dm->flush();
} finally {
    $this->sessionManager->close($session);
}

getProblemTasks

public function getProblemTasks(): array
{
    $repo = $this->sessionManager
                      ->getCurrentSession()
                      ->getDocumentManager()
                      ->getRepository(Task::class);

    return $repo->findBy(['status' => Task::STATUS_ERROR]);
}

, , , , .

:

public function switchTaskToError(Task $task, Throwable $) {
    //   ,  ,    
    $session $this->sessionManager->createNewSession();
    $dm = $session->getDocumentManager();
    try {
        $task = $dm->merge($task);
        $task->setStatus(Task::STATUS_ERROR);
        $task->setError($e->getMessage());
        $dm->flush();
    finally {
        $this->sessionManager->close($session);
    }
}

, , , wrap, , .

, 3 SessionManager

createNewSession — , "" .
getCurrentSession — .
close —

, ( php-ds).

:
createNewSession — , .
getCurrentSession — , , .
close — .

, , , .

wrap, , :

public function switchTaskToError(Task $task, Throwable $) {
    $this->sessionManager->wrapBySession(function(DocumentManager $dm) use ($task, $e) {
        $task = $dm->merge($task);
        $task->setStatus(Task::STATUS_ERROR);
        $task->setError($e->getMessage());
        $dm->flush();
    });
}

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