如何停止 PHP 脚本？阻止发送电子邮件？

Question

我有一个 php 应用程序（使用 LAMP 堆栈）发送数千个应用程序。我很想强制停止发送电子邮件。显然我无法通过关闭浏览器来停止 senidng。

我应该杀死进程，还是有其他方法可以这样做？我应该杀死什么进程？可能不止一个..？

PS：当然，该应用程序设计得很糟糕..但这不是问题。

Answer 1

如果它是您自己的（自己编写的）应用程序，也许您应该添加一些允许您暂停或停止执行的功能。

一个例子是在每 X 次迭代中，脚本都会检查资源中的命令。如果资源队列中有命令，它将按顺序执行它们，删除它们并继续（如果适用）。

例如，平面文件或数据库，您可以添加 STOP-SUSPEND_EXECUTION 命令。当您的脚本读取该行或行时，它会暂停正常执行，但会继续定期检查资源。此后，如果读取 RESUME 命令，则会从中断处恢复执行，因为它尚未离开迭代循环。

现在您可以通过 CLI 或其他界面将命令添加到队列中，应用程序将做出相应的响应。

您甚至可以想像一下，添加时间戳来推迟命令执行。

PS：如果您正在执行群发邮件等任务，也许您会考虑将这些脚本移至命令行界面。我只是根据您关于“关闭浏览器”的评论才提到这一点。

---

可能需要一些工作，但它确实有效。 run() 将回调函数 $job 作为参数。该函数代表您正在执行的任何批处理作业（群发邮件等）的单次迭代，并将 $data 作为数据数组。每次迭代时，$job 都会被赋予 $data 数组的下一个元素作为一组参数。

$data = array(
    array('name' => 'bob', 'email' => '[email protected]'),
    array('name' => 'jim', 'email' => '[email protected]'),
    array('name' => 'ann', 'email' => '[email protected]'),
);

$job = function($name, $email){
    // do something with $name
    // and $email
};

$batch->run($job, $data);

您需要一些表（类似于 MySQL Workbench）：

CREATE SCHEMA IF NOT EXISTS `batchtest` DEFAULT CHARACTER SET latin1 COLLATE latin1_swedish_ci ;
USE `batchtest` ;

CREATE  TABLE IF NOT EXISTS `batchtest`.`job` (
  `id` CHAR(24) NOT NULL ,
  `alias` VARCHAR(255) NOT NULL ,
  `status` INT NOT NULL DEFAULT 0 ,
  `timestamp` TIMESTAMP NOT NULL ,
  PRIMARY KEY (`id`) )
ENGINE = InnoDB;

CREATE  TABLE IF NOT EXISTS `batchtest`.`queue` (
  `id` INT UNSIGNED NOT NULL AUTO_INCREMENT ,
  `job_id` CHAR(24) NOT NULL ,
  `action` VARCHAR(255) NOT NULL ,
  `params` TEXT NULL ,
  `timestamp` TIMESTAMP NOT NULL ,
  PRIMARY KEY (`id`) )
ENGINE = InnoDB;

每当您想要暂停/恢复/中止作业时，请使用 job_id 和 queue 表添加一行。 code>action（pause、resume 或 abort），作业将做出响应。该作业将自动从队列表中删除已完成的命令。

这就是它的要点。

class BatchJob{

    const STATUS_STARTING   = 0;
    const STATUS_RUNNING    = 1; 
    const STATUS_PAUSED     = 2; 
    const STATUS_ABORTED    = 4; 
    const STATUS_COMPLETED  = 5; 

    protected $_id          = null;
    protected $_alias       = null;
    protected $_pdo         = null;
    protected $_pauseSleep  = null;
    protected $_status      = self::STATUS_STARTING;
    protected $_jobTable    = 'job';
    protected $_queueTable  = 'queue';

    public function __construct($pdo, $alias){
        $this->_pdo     = $pdo;
        $this->_alias   = $alias;
        $this->_id       = vsprintf('%04x%04x%04x%04x%04x%04x', array(
            mt_rand(0, 0xffff),
            mt_rand(0, 0xffff),
            mt_rand(0, 0xffff),
            mt_rand(0, 0xffff),
            mt_rand(0, 0xffff),
            mt_rand(0, 0xffff),
        ));
        $this->output("Initializing job");
        $this->_pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
        $statement = $this->_pdo->prepare("INSERT INTO {$this->_jobTable} (id, alias, status) VALUES (:id, :alias, :status)");
        $statement->execute(array(
            ':id'       => $this->_id,
            ':alias'    => $this->_alias,
            ':status'   => $this->_status,
        ));
    }

    public function run($job, Array $data, $pauseSleep = 10){
        $this->_pauseSleep  = $pauseSleep;
        $iteration          = 0;
        $this->updateStatus(self::STATUS_RUNNING);

        while($this->_status != self::STATUS_ABORTED
            &&$this->_status != self::STATUS_COMPLETED){

            $statement = $this->_pdo->prepare("SELECT id, action, params FROM {$this->_queueTable} WHERE job_id = :job_id");
            $statement->execute(array(
                ':job_id'       => $this->_id,
            ));

            foreach($statement->fetchAll() as $command){
                switch($command['action']){
                    case 'resume':
                        $this->updateStatus(self::STATUS_RUNNING);
                        break;
                    case 'pause':
                        $this->updateStatus(self::STATUS_PAUSED);
                        break;
                    case 'abort':
                        $this->updateStatus(self::STATUS_ABORTED, true, false);
                        exit;
                        break;
                }
                $statement = $this->_pdo->prepare("DELETE FROM {$this->_queueTable} WHERE id = :id");
                $statement->execute(array(
                    ':id'   => $command['id'],
                ));
            }

            if($this->_status == self::STATUS_PAUSED){
                sleep($this->_pauseSleep);
                continue;
            }

            call_user_func_array($job, (Array) current($data));

            if(!next($data)){
                $this->updateStatus(self::STATUS_COMPLETED, true, false);
            }

        }
    }

    protected function output($string){
        echo ">>> [{$this->_alias}:{$this->_id}] [" . date('Y-m-d H:i:s') . "] {$string}" . PHP_EOL;
    }

    protected function updateStatus($status = null, $updateDatabase = true, $updateOutput = true){
        if(!is_null($status)){
            $this->_status = $status;
        }

        if($updateDatabase){
            $statement = $this->_pdo->prepare("UPDATE {$this->_jobTable} SET status = :status WHERE id = :id");
            $statement->execute(array(
                ':id'       => $this->_id,
                ':status'   => $this->_status,
            ));
        }
        if($updateOutput){
            $reflection = new ReflectionClass(__CLASS__);
            $statusCodes = array_flip($reflection->getConstants());
            $this->output("Job status change [{$statusCodes[$this->_status]}]");
        }
    }

    public function __destruct(){
        $this->updateStatus();
    }

}

Answer 2

如果您可以修改脚本，您可以在脚本的主循环中插入这样的一行（最好在 mail() 行之前）：

if (connection_aborted ())
    exit ();

如果您关闭浏览器窗口，这将停止 PHP 脚本。尽管这是默认行为，php 通常无法立即停止脚本。

您可以在不了解脚本内部工作原理的情况下执行此操作，这比杀死 Apache 更好。

Answer 3

httpd - 这将停止所有 Apache。

Answer 4

通常您会终止 Web 服务器。如果你运行 cgi exe 你可以杀死它。

Answer 5

您是在问如何关闭疯狂的 php 脚本吗？如果是这样，你可以随时重新启动 apache。如果我误解了你的问题，我提前道歉。

Answer 6

编辑 php.ini 以在禁用功能中设置邮件。那么php将无法使用邮件功能。

disable_functions = mail

http://www.php.net/manual/en /ini.core.php#ini.disable-functions