Hủy và tiếp tục lệnh Symfony Console

Question

Tôi có lệnh Symfony Console lặp lại trên bộ sưu tập các mục có khả năng lớn và thực hiện nhiệm vụ với từng mục. Vì bộ sưu tập có thể lớn, lệnh có thể mất nhiều thời gian để chạy (giờ). Khi lệnh kết thúc, nó sẽ hiển thị một số thống kê.

Tôi muốn làm cho nó có thể hủy bỏ lệnh một cách tốt đẹp. Ngay bây giờ nếu tôi hủy bỏ nó (tức là với ctrl + c trong CLI), không có tóm tắt thống kê và không có cách nào để xuất các tham số cần thiết để tiếp tục lệnh. Một vấn đề khác là lệnh có thể bị chấm dứt ở giữa việc xử lý một mục - nó sẽ tốt hơn nếu nó chỉ có thể chấm dứt giữa các mục xử lý.

Vì vậy, có cách nào để yêu cầu lệnh "hủy bỏ độc đáo càng sớm càng tốt" hoặc có lệnh ctrl + c được hiểu là như vậy không?

Tôi đã thử sử dụng sự kiện ConsoleEvents::TERMINATE, mặc dù các trình xử lý cho điều này chỉ được kích hoạt khi hoàn thành lệnh, chứ không phải khi tôi ctrl + c điều. Và tôi đã không thể tìm thêm thông tin về việc thực hiện các lệnh có thể tiếp tục như vậy.

Answer 1

Đây là những gì làm việc cho tôi. Bạn cần gọi pcntl_signal_dispatch trước khi các trình xử lý tín hiệu thực sự được thực hiện. Nếu không có nó, tất cả các nhiệm vụ sẽ hoàn thành đầu tiên.

<?php 
use Symfony\Component\Console\Command\Command; 

class YourCommand extends Command 
{ 
    protected function execute(InputInterface $input, OutputInterface $output) 
    { 
     pcntl_signal(SIGTERM, [$this, 'stopCommand']); 
     pcntl_signal(SIGINT, [$this, 'stopCommand']); 

     $this->shouldStop = false; 

     foreach ($this->tasks as $task) 
     { 
      pcntl_signal_dispatch(); 
      if ($this->shouldStop) break; 
      $task->execute(); 
     } 

     $this->showSomeStats($output); 
    } 

    public function stopCommand() 
    { 
     $this->shouldStop = true; 
    } 
} 

Answer 2

Bạn nên xem xét xử lý tín hiệu của RabbitMqBundle. Phương thức execute của nó chỉ liên kết một số cuộc gọi lại thông qua cuộc gọi hàm pcntl_signal(). Một trường hợp phổ biến sẽ trông khá giống như thế này:

<?php 
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand as Command; 

class YourCommand extends Command 
{ 
    protected function execute(InputInterface $input, OutputInterface $output) 
    { 
     pcntl_signal(SIGTERM, array(&$this, 'stopCommand', $output)); 
     pcntl_signal(SIGINT, array(&$this, 'stopCommand', $output)); 
     pcntl_signal(SIGHUP, array(&$this, 'restartCommand', $output)); 

     // The real execute method body 
    } 

    public function stopCommand(OutputInterface $output) 
    { 
     $output->writeln('Stopping'); 

     // Do what you need to stop your process 
    } 

    public function restartCommand(OutputInterface $output) 
    { 
     $output->writeln('Restarting'); 

     // Do what you need to restart your process 
    } 
} 

Answer 3

Câu trả lời phức tạp hơn mức cần thiết. Chắc chắn, bạn có thể đăng ký bộ xử lý tín hiệu POSIX, nhưng nếu các tín hiệu duy nhất cần được xử lý là ngắt cơ bản và tương tự, bạn chỉ cần xác định một destructor trên Command.

class YourCommand extends Command 
{ 
    // Other code goes here. 

    __destruct() 
    { 
     $this->shouldStop = true; 
    } 
} 

Một trường hợp bạn muốn đăng ký một tín hiệu POSIX là cho SIGCONT tín hiệu, mà có thể xử lý việc nối lại của một quá trình mà đã được ngừng lại (SIGSTOP).

Một trường hợp khác sẽ là nơi bạn muốn mọi tín hiệu hoạt động khác nhau; đối với hầu hết các phần, mặc dù, SIGINT và SIGTERM và một số ít người khác sẽ được đăng ký với cùng một quy trình "OMG THE PROCESS HAS BEEN KILLED".

Ngoài những ví dụ này, việc đăng ký các sự kiện tín hiệu là không cần thiết. Đây là lý do tại sao destructors tồn tại.

Bạn thậm chí có thể mở rộng lớp cơ sở của Symfony Command với phương thức __destruct, sẽ tự động cung cấp dọn dẹp cho mọi lệnh; nên một lệnh cụ thể yêu cầu hoạt động bổ sung, chỉ cần ghi đè lên nó.