PHP模擬supervisor進(jìn)程管理的示例
這篇文章給大家分享的是有關(guān)PHP模擬supervisor進(jìn)程管理的示例的內(nèi)容。小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考，一起跟隨小編過(guò)來(lái)看看吧。
為古縣等地區(qū)用戶提供了全套網(wǎng)頁(yè)設(shè)計(jì)制作服務(wù)，及古縣網(wǎng)站建設(shè)行業(yè)解決方案。主營(yíng)業(yè)務(wù)為成都做網(wǎng)站、成都網(wǎng)站制作、古縣網(wǎng)站設(shè)計(jì)，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠(chéng)的服務(wù)。我們深信只要達(dá)到每一位用戶的要求，就會(huì)得到認(rèn)可，從而選擇與我們長(zhǎng)期合作。這樣，我們也可以走得更遠(yuǎn)！
前言
模擬supervisor進(jìn)程管理DEMO（簡(jiǎn)易實(shí)現(xiàn)）
截圖：
在圖中自己實(shí)現(xiàn)了一個(gè)
Copy子進(jìn)程的功能。如果用在AMQP增減消費(fèi)者時(shí)，我覺(jué)得應(yīng)該會(huì)很有用。
實(shí)現(xiàn)
1、在主進(jìn)程循環(huán)內(nèi)啟動(dòng)子進(jìn)程執(zhí)行命令
2、在web輸入 127.0.0.1:7865 獲取子進(jìn)程狀態(tài)
3、socket接收請(qǐng)求消息，并且執(zhí)行相應(yīng)操作，返回web頁(yè)面
4、回收子進(jìn)程，防止稱為僵尸進(jìn)程
不足：無(wú)法持續(xù)監(jiān)聽(tīng)錯(cuò)誤頁(yè)面。由于socket得到的響應(yīng)是通過(guò)include函數(shù)加載的，所以在加載的頁(yè)面內(nèi)不能出現(xiàn)tail -f命令，否則stream就會(huì)掉入了死循環(huán)了~。我想應(yīng)該有方案解決（寫了socket+多進(jìn)程模式，模仿fpm在接收到請(qǐng)求之后就啟動(dòng)一個(gè)子進(jìn)程去處理的模式，但是執(zhí)行有問(wèn)題。因此將代碼貼出來(lái)希望得到大家的指點(diǎn)）。
延伸：由于對(duì)進(jìn)程可以很好的管理（期望如此），那么就可以定制化自己的一些需求，比如：（1）定制AMQP的消費(fèi)者進(jìn)程管理服務(wù)。（2）模擬crontab定時(shí)服務(wù)。
知識(shí)點(diǎn)
代碼實(shí)現(xiàn)的過(guò)程中，有很多的細(xì)節(jié)是值得學(xué)習(xí)的。
1、在while()循環(huán)中，啟用了stream的非阻塞模式。所以不能在循環(huán)中使用sleep(1)，而是用stream_select($read, $write, $except, 1)讓stream內(nèi)部阻塞。
關(guān)于阻塞非阻塞模式，可以參閱這里
2、能夠執(zhí)行外部程序的函數(shù)很多，但是都稍有不同。這里采用的是proc_open，是一個(gè)很強(qiáng)大的函數(shù)。在這之前我曾用pcntl_exec執(zhí)行過(guò)外部程序，但是需要先pcntl_fork。而用其他的如exec,shell_exec無(wú)法對(duì)子進(jìn)程進(jìn)行管理。
3、重啟或停止等操作子進(jìn)程時(shí)，只是先更改主進(jìn)程中該子進(jìn)程在內(nèi)存中的的狀態(tài)，并不是真正的對(duì)子進(jìn)程操作。在統(tǒng)一處init()處理子進(jìn)程。如此才能防止因?yàn)樽舆M(jìn)程啟動(dòng)時(shí)的上下文導(dǎo)致的一些怪異的現(xiàn)象。
代碼
由于代碼過(guò)多，所以如果你對(duì)我的方案有更好的建議可以在github這里看。
主進(jìn)程代碼：Process.php
<?php
require_once __DIR__ . '/Consumer.php';require_once __DIR__ . '/StreamConnection.php';require_once __DIR__ . '/Http.php';class Process{
/**
* 待啟動(dòng)的消費(fèi)者數(shù)組
*/
protected $consumers = array();
protected $childPids = array();
const PPID_FILE = __DIR__ . '/process';
protected $serializerConsumer;
public function __construct()
{
$this->consumers = $this->getConsumers();
}
// 這里是個(gè)DEMO，實(shí)際可以用讀取配置文件的方式。
public function getConsumers()
{
$consumer = new Consumer([
'program' => 'test',
'command' => '/usr/bin/php test.php',
'directory' => __DIR__,
'logfile' => __DIR__ . '/test.log',
'uniqid' => uniqid(),
'auto_restart' => false,
]);
return [
$consumer->uniqid => $consumer,
];
}
public function run()
{
if (empty($this->consumers)) {
// consumer empty
return;
}
if ($this->_notifyMaster()) {
// master alive
return;
}
$pid = pcntl_fork();
if ($pid < 0) {
exit;
} elseif ($pid > 0) {
exit;
}
if (!posix_setsid()) {
exit;
}
$stream = new StreamConnection('tcp://0.0.0.0:7865');
@cli_set_process_title('AMQP Master Process');
// 將主進(jìn)程ID寫入文件
file_put_contents(self::PPID_FILE, getmypid());
// master進(jìn)程繼續(xù)
while (true) {
$this->init();
pcntl_signal_dispatch();
$this->waitpid();
// 如果子進(jìn)程被全部回收，則主進(jìn)程退出
// if (empty($this->childPids)) {
// $stream->close($stream->getSocket());
// break;
// }
$stream->accept(function ($uniqid, $action) {
$this->handle($uniqid, $action);
return $this->display();
});
}
}
protected function init()
{
foreach ($this->consumers as &$c) {
switch ($c->state) {
case Consumer::RUNNING:
case Consumer::STOP:
break;
case Consumer::NOMINAL:
case Consumer::STARTING:
$this->fork($c);
break;
case Consumer::STOPING:
if ($c->pid && posix_kill($c->pid, SIGTERM)) {
$this->reset($c, Consumer::STOP);
}
break;
case Consumer::RESTART:
if (empty($c->pid)) {
$this->fork($c);
break;
}
if (posix_kill($c->pid, SIGTERM)) {
$this->reset($c, Consumer::STOP);
$this->fork($c);
}
break;
default:
break;
}
}
}
protected function reset(Consumer $c, $state)
{
$c->pid = '';
$c->uptime = '';
$c->state = $state;
$c->process = null;
}
protected function waitpid()
{
foreach ($this->childPids as $uniqid => $pid) {
$result = pcntl_waitpid($pid, $status, WNOHANG);
if ($result == $pid || $result == -1) {
unset($this->childPids[$uniqid]);
$c = &$this->consumers[$uniqid];
$state = pcntl_wifexited($status) ? Consumer::EXITED : Consumer::STOP;
$this->reset($c, $state);
}
}
}
/**
* 父進(jìn)程存活情況下，只會(huì)通知父進(jìn)程信息，否則可能產(chǎn)生多個(gè)守護(hù)進(jìn)程
*/
private function _notifyMaster()
{
$ppid = file_get_contents(self::PPID_FILE );
$isAlive = $this->checkProcessAlive($ppid);
if (!$isAlive) return false;
return true;
}
public function checkProcessAlive($pid)
{
if (empty($pid)) return false;
$pidinfo = `ps co pid {$pid} | xargs`;
$pidinfo = trim($pidinfo);
$pattern = "/.*?PID.*?(\d+).*?/";
preg_match($pattern, $pidinfo, $matches);
return empty($matches) ? false : ($matches[1] == $pid ? true : false);
}
/**
* fork一個(gè)新的子進(jìn)程
*/
protected function fork(Consumer $c)
{
$descriptorspec = [2 => ['file', $c->logfile, 'a'],];
$process = proc_open('exec ' . $c->command, $descriptorspec, $pipes, $c->directory);
if ($process) {
$ret = proc_get_status($process);
if ($ret['running']) {
$c->state = Consumer::RUNNING;
$c->pid = $ret['pid'];
$c->process = $process;
$c->uptime = date('m-d H:i');
$this->childPids[$c->uniqid] = $ret['pid'];
} else {
$c->state = Consumer::EXITED;
proc_close($process);
}
} else {
$c->state = Consumer::ERROR;
}
return $c;
}
public function display()
{
$location = 'http://127.0.0.1:7865';
$basePath = Http::$basePath;
$scriptName = isset($_SERVER['SCRIPT_NAME']) &&
!empty($_SERVER['SCRIPT_NAME']) &&
$_SERVER['SCRIPT_NAME'] != '/' ? $_SERVER['SCRIPT_NAME'] : '/index.php';
if ($scriptName == '/index.html') {
return Http::status_301($location);
}
$sourcePath = $basePath . $scriptName;
if (!is_file($sourcePath)) {
return Http::status_404();
}
ob_start();
include $sourcePath;
$response = ob_get_contents();
ob_clean();
return Http::status_200($response);
}
public function handle($uniqid, $action)
{
if (!empty($uniqid) && !isset($this->consumers[$uniqid])) {
return;
}
switch ($action) {
case 'refresh':
break;
case 'restartall':
$this->killall(true);
break;
case 'stopall':
$this->killall();
break;
case 'stop':
$c = &$this->consumers[$uniqid];
if ($c->state != Consumer::RUNNING) break;
$c->state = Consumer::STOPING;
break;
case 'start':
$c = &$this->consumers[$uniqid];
if ($c->state == Consumer::RUNNING) break;
$c->state = Consumer::STARTING;
break;
case 'restart':
$c = &$this->consumers[$uniqid];
$c->state = Consumer::RESTART;
break;
case 'copy':
$c = $this->consumers[$uniqid];
$newC = clone $c;
$newC->uniqid = uniqid('C');
$newC->state = Consumer::NOMINAL;
$newC->pid = '';
$this->consumers[$newC->uniqid] = $newC;
break;
default:
break;
}
}
protected function killall($restart = false)
{
foreach ($this->consumers as &$c) {
$c->state = $restart ? Consumer::RESTART : Consumer::STOPING;
}
}}$cli = new Process();$cli->run();Consumer消費(fèi)者對(duì)象
<?php
require_once __DIR__ . '/BaseObject.php';class Consumer extends BaseObject{
/** 開(kāi)啟多少個(gè)消費(fèi)者 */
public $numprocs = 1;
/** 當(dāng)前配置的唯一標(biāo)志 */
public $program;
/** 執(zhí)行的命令 */
public $command;
/** 當(dāng)前工作的目錄 */
public $directory;
/** 通過(guò) $qos $queueName $duplicate 生成的 $queue */
public $queue;
/** 程序執(zhí)行日志記錄 */
public $logfile = '';
/** 消費(fèi)進(jìn)程的唯一ID */
public $uniqid;
/** 進(jìn)程IDpid */
public $pid;
/** 進(jìn)程狀態(tài) */
public $state = self::NOMINAL;
/** 自啟動(dòng) */
public $auto_restart = false;
public $process;
/** 啟動(dòng)時(shí)間 */
public $uptime;
const RUNNING = 'running';
const STOP = 'stoped';
const NOMINAL = 'nominal';
const RESTART = 'restart';
const STOPING = 'stoping';
const STARTING = 'stating';
const ERROR = 'error';
const BLOCKED = 'blocked';
const EXITED = 'exited';
const FATEL = 'fatel';}stream相關(guān)代碼：StreamConnection.php
<?php
class StreamConnection{
protected $socket;
protected $timeout = 2; //s
protected $client;
public function __construct($host)
{
$this->socket = $this->connect($host);
}
public function connect($host)
{
$socket = stream_socket_server($host, $errno, $errstr);
if (!$socket) {
exit('stream error');
}
stream_set_timeout($socket, $this->timeout);
stream_set_chunk_size($socket, 1024);
stream_set_blocking($socket, false);
$this->client = [$socket];
return $socket;
}
public function accept(Closure $callback)
{
$read = $this->client;
if (stream_select($read, $write, $except, 1) < 1) return;
if (in_array($this->socket, $read)) {
$cs = stream_socket_accept($this->socket);
$this->client[] = $cs;
}
foreach ($read as $s) {
if ($s == $this->socket) continue;
$header = fread($s, 1024);
if (empty($header)) {
$index = array_search($s, $this->client);
if ($index)
unset($this->client[$index]);
$this->close($s);
continue;
}
Http::parse_http($header);
$uniqid = isset($_GET['uniqid']) ? $_GET['uniqid'] : '';
$action = isset($_GET['action']) ? $_GET['action'] : '';
$response = $callback($uniqid, $action);
$this->write($s, $response);
$index = array_search($s, $this->client);
if ($index)
unset($this->client[$index]);
$this->close($s);
}
}
public function write($socket, $response)
{
$ret = fwrite($socket, $response, strlen($response));
}
public function close($socket)
{
$flag = fclose($socket);
}
public function getSocket()
{
return $this->socket;
}}Http響應(yīng)代碼：Http.php
<?php
class Http{
public static $basePath = __DIR__ . '/views';
public static $max_age = 120; //秒
/*
* 函數(shù): parse_http
* 描述: 解析http協(xié)議
*/
public static function parse_http($http)
{
// 初始化
$_POST = $_GET = $_COOKIE = $_REQUEST = $_SESSION = $_FILES = array();
$GLOBALS['HTTP_RAW_POST_DATA'] = '';
// 需要設(shè)置的變量名
$_SERVER = array(
'QUERY_STRING' => '',
'REQUEST_METHOD' => '',
'REQUEST_URI' => '',
'SERVER_PROTOCOL' => '',
'SERVER_SOFTWARE' => '',
'SERVER_NAME' => '',
'HTTP_HOST' => '',
'HTTP_USER_AGENT' => '',
'HTTP_ACCEPT' => '',
'HTTP_ACCEPT_LANGUAGE' => '',
'HTTP_ACCEPT_ENCODING' => '',
'HTTP_COOKIE' => '',
'HTTP_CONNECTION' => '',
'REMOTE_ADDR' => '',
'REMOTE_PORT' => '0',
'SCRIPT_NAME' => '',
'HTTP_REFERER' => '',
'CONTENT_TYPE' => '',
'HTTP_IF_NONE_MATCH' => '',
);
// 將header分割成數(shù)組
list($http_header, $http_body) = explode("\r\n\r\n", $http, 2);
$header_data = explode("\r\n", $http_header);
list($_SERVER['REQUEST_METHOD'], $_SERVER['REQUEST_URI'], $_SERVER['SERVER_PROTOCOL']) = explode(' ', $header_data[0]);
unset($header_data[0]);
foreach ($header_data as $content) {
// \r\n\r\n
if (empty($content)) {
continue;
}
list($key, $value) = explode(':', $content, 2);
$key = strtolower($key);
$value = trim($value);
switch ($key) {
case 'host':
$_SERVER['HTTP_HOST'] = $value;
$tmp = explode(':', $value);
$_SERVER['SERVER_NAME'] = $tmp[0];
if (isset($tmp[1])) {
$_SERVER['SERVER_PORT'] = $tmp[1];
}
break;
case 'cookie':
$_SERVER['HTTP_COOKIE'] = $value;
parse_str(str_replace('; ', '&', $_SERVER['HTTP_COOKIE']), $_COOKIE);
break;
case 'user-agent':
$_SERVER['HTTP_USER_AGENT'] = $value;
break;
case 'accept':
$_SERVER['HTTP_ACCEPT'] = $value;
break;
case 'accept-language':
$_SERVER['HTTP_ACCEPT_LANGUAGE'] = $value;
break;
case 'accept-encoding':
$_SERVER['HTTP_ACCEPT_ENCODING'] = $value;
break;
case 'connection':
$_SERVER['HTTP_CONNECTION'] = $value;
break;
case 'referer':
$_SERVER['HTTP_REFERER'] = $value;
break;
case 'if-modified-since':
$_SERVER['HTTP_IF_MODIFIED_SINCE'] = $value;
break;
case 'if-none-match':
$_SERVER['HTTP_IF_NONE_MATCH'] = $value;
break;
case 'content-type':
if (!preg_match('/boundary="?(\S+)"?/', $value, $match)) {
$_SERVER['CONTENT_TYPE'] = $value;
} else {
$_SERVER['CONTENT_TYPE'] = 'multipart/form-data';
$http_post_boundary = '--' . $match[1];
}
break;
}
}
// script_name
$_SERVER['SCRIPT_NAME'] = parse_url($_SERVER['REQUEST_URI'], PHP_URL_PATH);
// QUERY_STRING
$_SERVER['QUERY_STRING'] = parse_url($_SERVER['REQUEST_URI'], PHP_URL_QUERY);
if ($_SERVER['QUERY_STRING']) {
// $GET
parse_str($_SERVER['QUERY_STRING'], $_GET);
} else {
$_SERVER['QUERY_STRING'] = '';
}
// REQUEST
$_REQUEST = array_merge($_GET, $_POST);
return array('get' => $_GET, 'post' => $_POST, 'cookie' => $_COOKIE, 'server' => $_SERVER, 'files' => $_FILES);
}
public static function status_404()
{
return <<<EOFHTTP/1.1 404 OK
content-type: text/htmlEOF;
}
public static function status_301($location)
{
return <<<EOFHTTP/1.1 301 Moved Permanently
Content-Length: 0
Content-Type: text/plain
Location: $locationCache-Control: no-cacheEOF;
}
public static function status_304()
{
return <<<EOFHTTP/1.1 304 Not Modified
Content-Length: 0EOF;
}
public static function status_200($response)
{
$contentType = $_SERVER['CONTENT_TYPE'];
$length = strlen($response);
$header = '';
if ($contentType)
$header = 'Cache-Control: max-age=180';
return <<<EOFHTTP/1.1 200 OK
Content-Type: $contentTypeContent-Length: $length$header$responseEOF;
}}待執(zhí)行的腳本：test.php
<?php
while(true) {
file_put_contents(__DIR__ . '/test.log', date('Y-m-d H:i:s'));
sleep(1);}在當(dāng)前目錄下的視圖頁(yè)面：
|- Process.php
|- Http.php
|- StreamConnection.php
|- Consumer.php
|- BaseObject.php
|- views/
感謝各位的閱讀！關(guān)于“PHP模擬supervisor進(jìn)程管理的示例”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，讓大家可以學(xué)到更多知識(shí)，如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到吧！
分享題目：PHP模擬supervisor進(jìn)程管理的示例
URL鏈接：http://www.chinadenli.net/article2/jdjeoc.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供小程序開(kāi)發(fā)、品牌網(wǎng)站設(shè)計(jì)、關(guān)鍵詞優(yōu)化、手機(jī)網(wǎng)站建設(shè)、ChatGPT、全網(wǎng)營(yíng)銷推廣
聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)
- 網(wǎng)站建設(shè)中如何避免這些錯(cuò)誤的做法 2022-05-18
- 網(wǎng)站建設(shè)團(tuán)隊(duì)分工詳細(xì)講解 2022-12-06
- 網(wǎng)站建設(shè)：網(wǎng)站站內(nèi)整站營(yíng)銷的八大要素 2022-05-21
- 網(wǎng)站定制功能解決方案-網(wǎng)站建設(shè)創(chuàng)新互聯(lián)科技 2021-11-26
- 知道這些 會(huì)讓你的網(wǎng)站建設(shè)更加有意義 2016-05-04
- 營(yíng)銷型網(wǎng)站建設(shè)時(shí)需要注意哪幾點(diǎn)問(wèn)題？ 2022-11-14
- 企業(yè)如何精心千挑萬(wàn)選出一個(gè)專業(yè)又靠譜的網(wǎng)站建設(shè)公司？ 2022-05-16
- 江夏網(wǎng)站建設(shè)需要注意哪些細(xì)節(jié)要素 2020-12-24
- 成都創(chuàng)新互聯(lián)：企業(yè)網(wǎng)站建設(shè)有哪些步驟流程？企業(yè)網(wǎng)站建設(shè)介紹 2016-09-23
- 網(wǎng)站建設(shè)中WEB技術(shù)與數(shù)據(jù)庫(kù)技術(shù)的對(duì)比 2016-09-07
- 網(wǎng)站建設(shè)尋找個(gè)人小團(tuán)隊(duì)和正規(guī)公司有什么區(qū)別 2022-01-26
- ?選擇直銷網(wǎng)站建設(shè)公司需考慮哪些因素？如何更好的建設(shè)直銷網(wǎng)站？ 2022-12-01