Laravel Daemon Queue Memory Leak

Question

Я использую laravel 5.1 и с помощью диспетчера для наблюдения за работой очереди. Драйвер очереди - это база данных.

[program:queue] 
process_name=%(program_name)s_%(process_num)02d 
command=php /var/www/html/artisan queue:work database --sleep=3 --tries=1 --daemon 
autostart=true 
autorestart=true 
user=root 
numprocs=1 
redirect_stderr=true 
stdout_logfile=/var/www/html/storage/logs/supervisord.log 

ОЗУ, используемое Queue Listener, увеличивается после обработки каждой работы и доходит до 150-200 МБ. Все глобальные переменные присваиваются значениям null.

namespace App\Jobs; 
use App\Jobs\Job; 
use App\Compatibility; 
use App\Like; 
use App\Message; 
use Illuminate\Queue\SerializesModels; 
use Illuminate\Queue\InteractsWithQueue; 
use Illuminate\Contracts\Bus\SelfHandling; 
use Illuminate\Contracts\Queue\ShouldQueue; 

class CalculateInteractionLike extends Job implements SelfHandling, ShouldQueue 
{ 
    use InteractsWithQueue, SerializesModels; 
    protected $userAId; 
    protected $userBId; 
    protected $gender; 

    /** 
    * Create a new job instance. 
    * 
    * @return void 
    */ 
    public function __construct($userAId, $userBId, $gender) 
    { 
     $this->userAId = $userAId; 
     $this->userBId = $userBId; 
     $this->gender = $gender; 
    } 

    /** 
    * Execute the job. 
    * 
    * @return void 
    */ 
    public function handle() 
    { 
     echo 'start CalculateInteractionLike '. memory_get_usage() . "\n"; 
     $userArray = array(); 
     Compatibility::where('userAId', $this->userBId)->where('userBId', $this->userAId)->update(['interactionAB'=>0.0001]); 
     $profiles = Compatibility::where('userAId', $this->userBId)->where('interactionAB', '>',0)->orderBy('compatibilityAB', 'desc')->take(4)->get(['compatibilityAB']); 
     $compatible = array(); 
     for($i=0; $i<sizeof($profiles);$i++){ 
      $compatible[] = $profiles[$i]->compatibilityAB; 
     } 
     $std = sizeof($compatible)>1 ? $this->_calculateStd($compatible) : 0; 
     $messagedProfile = Message::where('userBId', $this->userBId)->where('type', '1')->get(['userAId']); 
     for($i=0;$i<sizeof($messagedProfile);$i++){ 
      Compatibility::where('userAId',$this->userBId)->where('userBId', $messagedProfile[$i]->userAId)->update(array('interactionAB' => $std)); 
     } 
     $this->userAId = null; 
     $this->userBId = null; 
     $this->gender = null; 
     $userArray = null; 
     $profiles = null; 
     $compatible = null; 
     $std = null; 
     $messagedProfile = null; 

    } 

    private function _calculateStd($compatible){ 
     return sqrt(array_sum(array_map([$this,"_stdSquare"], $compatible, array_fill(0,count($compatible), (array_sum($compatible)/count($compatible)))))/(count($compatible)-1)); 
    } 

    private static function _stdSquare($x, $mean){ 
     return pow($x - $mean, 2); 
    } 

    public function __destruct(){ 
     $this->cleanup(); 
     echo 'end CalculateInteractionLike '. memory_get_usage() . "\n"; 
    } 

    public function cleanup() { 
     //cleanup everything from attributes 
     foreach (get_class_vars(__CLASS__) as $clsVar => $_) { 
      unset($this->$clsVar); 
     } 
    } 
} 

Если обработано выше, каждый раз, когда происходит некоторое увеличение ОЗУ. Есть идеи ?

Answer 1

Единственное место, где вы не очистка памяти находится внутри для()

 for($i=0;$i<sizeof($messagedProfile);$i++){ 
      Compatibility::where('userAId',$this->userBId)->where('userBId', $messagedProfile[$i]->userAId)->update(array('interactionAB' => $std)); 
     } 

первый, где статический (:: используется), но внутренне объекты, созданные и вы начинаете использовать -> для вызова функций , Вы пытались проверить, есть ли дескрипторы и вручную вызывать сборщик мусора?

for($i=0;$i<sizeof($messagedProfile);$i++){ 
      Compatibility::where('userAId',$this->userBId)->where('userBId', $messagedProfile[$i]->userAId)->update(array('interactionAB' => $std)); 
      gc_collect_cycles(); 
     } 

Вторая вещь, где(), обновление() и т.д. может возвращать ссылку на объект так, если да, вы хотели бы попробовать:

  for($i=0;$i<sizeof($messagedProfile);$i++){ 
       $tmp = Compatibility::where('userAId',$this->userBId)->where('userBId', $messagedProfile[$i]->userAId)->update(array('interactionAB' => $std)); 
$tmp = null; 
      } 

Пожалуйста, обратите внимание, что PHP < 7.0 автоматически не разрушать объекты классов, созданные в верхнем классе. Проверьте это: https://codereview.stackexchange.com/questions/57847/case-of-the-hidden-memory-leak

Answer 2

В работе вокруг - если вы не можете найти источник утечки памяти - вы можете просто переключиться на queue:listen без флага демона.

Это будет «перезагружать» структуру после каждой работы, освобождая всю память от PHP.

Это совместимо с супервизором, который гарантирует, что queue:listen всегда перезапускается.