PHP高级编程实例:编写守护进程

作者:junjie 时间:2023-10-27 02:03:22 

1.什么是守护进程

守护进程是脱离于终端并且在后台运行的进程。守护进程脱离于终端是为了避免进程在执行过程中的信息在任何终端上显示并且进程也不会被任何终端所产生的终端信息所打断。

例如 apache, nginx, mysql 都是守护进程

2.为什么开发守护进程

很多程序以服务形式存在,他没有终端或UI交互,它可能采用其他方式与其他程序交互,如TCP/UDP Socket, UNIX Socket, fifo。程序一旦启动便进入后台,直到满足条件他便开始处理任务。

3.何时采用守护进程开发应用程序

以我当前的需求为例,我需要运行一个程序,然后监听某端口,持续接受服务端发起的数据,然后对数据分析处理,再将结果写入到数据库中; 我采用ZeroMQ实现数据收发。

如果我不采用守护进程方式开发该程序,程序一旦运行就会占用当前终端窗框,还有受到当前终端键盘输入影响,有可能程序误退出。

4.守护进程的安全问题

我们希望程序在非超级用户运行,这样一旦由于程序出现漏洞被骇客控制,攻击者只能继承运行权限,而无法获得超级用户权限。

我们希望程序只能运行一个实例,不运行同事开启两个以上的程序,因为会出现端口冲突等等问题。

5.怎样开发守护进程

例 1. 守护进程例示


<?php
class ExampleWorker extends Worker {

#public function __construct(Logging $logger) {
# $this->logger = $logger;
#}

#protected $logger;
protected static $dbh;
public function __construct() {

}
public function run(){
 $dbhost = '192.168.2.1';  // 数据库服务器
 $dbport = 3306;
  $dbuser = 'www';  // 数据库用户名
$dbpass = 'qwer123';    // 数据库密码
 $dbname = 'example';  // 数据库名

 self::$dbh = new PDO("mysql:host=$dbhost;port=$dbport;dbname=$dbname", $dbuser, $dbpass, array(
  /* PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES \'UTF8\'', */
  PDO::MYSQL_ATTR_COMPRESS => true,
  PDO::ATTR_PERSISTENT => true
  )
 );

}
protected function getInstance(){
return self::$dbh;
 }

}

/* the collectable class implements machinery for Pool::collect */
class Fee extends Stackable {
public function __construct($msg) {
 $trades = explode(",", $msg);
 $this->data = $trades;
 print_r($trades);
}

public function run() {
 #$this->worker->logger->log("%s executing in Thread #%lu", __CLASS__, $this->worker->getThreadId() );

 try {
  $dbh = $this->worker->getInstance();
 
  $insert = "INSERT INTO fee(ticket, login, volume, `status`) VALUES(:ticket, :login, :volume,'N')";
  $sth = $dbh->prepare($insert);
  $sth->bindValue(':ticket', $this->data[0]);
  $sth->bindValue(':login', $this->data[1]);
  $sth->bindValue(':volume', $this->data[2]);
  $sth->execute();
  $sth = null;
 
  /* ...... */
 
  $update = "UPDATE fee SET `status` = 'Y' WHERE ticket = :ticket and `status` = 'N'";
  $sth = $dbh->prepare($update);
  $sth->bindValue(':ticket', $this->data[0]);
  $sth->execute();
  //echo $sth->queryString;
  //$dbh = null;
 }
 catch(PDOException $e) {
  $error = sprintf("%s,%s\n", $mobile, $id );
  file_put_contents("mobile_error.log", $error, FILE_APPEND);
 }
}
}

class Example {
/* config */
const LISTEN = "tcp://192.168.2.15:5555";
const MAXCONN = 100;
const pidfile = __CLASS__;
const uid = 80;
const gid = 80;

protected $pool = NULL;
protected $zmq = NULL;
public function __construct() {
 $this->pidfile = '/var/run/'.self::pidfile.'.pid';
}
private function daemon(){
 if (file_exists($this->pidfile)) {
  echo "The file $this->pidfile exists.\n";
  exit();
 }
 
 $pid = pcntl_fork();
 if ($pid == -1) {
   die('could not fork');
 } else if ($pid) {
   // we are the parent
   //pcntl_wait($status); //Protect against Zombie children
  exit($pid);
 } else {
  // we are the child
  file_put_contents($this->pidfile, getmypid());
  posix_setuid(self::uid);
  posix_setgid(self::gid);
  return(getmypid());
 }
}
private function start(){
 $pid = $this->daemon();
 $this->pool = new Pool(self::MAXCONN, \ExampleWorker::class, []);
 $this->zmq = new ZMQSocket(new ZMQContext(), ZMQ::SOCKET_REP);
 $this->zmq->bind(self::LISTEN);
 
 /* Loop receiving and echoing back */
 while ($message = $this->zmq->recv()) {
  //print_r($message);
  //if($trades){
    $this->pool->submit(new Fee($message));
    $this->zmq->send('TRUE');
  //}else{
  // $this->zmq->send('FALSE');
  //}
 }
 $pool->shutdown();
}
private function stop(){

 if (file_exists($this->pidfile)) {
  $pid = file_get_contents($this->pidfile);
  posix_kill($pid, 9);
  unlink($this->pidfile);
 }
}
private function help($proc){
 printf("%s start | stop | help \n", $proc);
}
public function main($argv){
 if(count($argv) < 2){
  printf("please input help parameter\n");
  exit();
 }
 if($argv[1] === 'stop'){
  $this->stop();
 }else if($argv[1] === 'start'){
  $this->start();
 }else{
  $this->help($argv[0]);
 }
}
}

$cgse = new Example();
$cgse->main($argv);

5.1. 程序启动

下面是程序启动后进入后台的代码

通过进程ID文件来判断,当前进程状态,如果进程ID文件存在表示程序在运行中,通过代码file_exists($this->pidfile)实现,但而后进程被kill需要手工删除该文件才能运行


private function daemon(){
 if (file_exists($this->pidfile)) {
  echo "The file $this->pidfile exists.\n";
  exit();
 }
 
 $pid = pcntl_fork();
 if ($pid == -1) {
   die('could not fork');
 } else if ($pid) {
  // we are the parent
  //pcntl_wait($status); //Protect against Zombie children
  exit($pid);
 } else {
  // we are the child
  file_put_contents($this->pidfile, getmypid());
  posix_setuid(self::uid);
  posix_setgid(self::gid);
  return(getmypid());
 }
}

程序启动后,父进程会推出,子进程会在后台运行,子进程权限从root切换到指定用户,同时将pid写入进程ID文件。

5.2. 程序停止

程序停止,只需读取pid文件,然后调用posix_kill($pid, 9); 最后将该文件删除。


private function stop(){

 if (file_exists($this->pidfile)) {
  $pid = file_get_contents($this->pidfile);
  posix_kill($pid, 9);
  unlink($this->pidfile);
 }
}

标签:PHP,高级编程,守护进程
0
投稿

猜你喜欢

  • Python编程super应用场景及示例解析

    2023-06-10 03:00:46
  • Oracle创建主键自增表(sql语句实现)及触发器应用

    2024-01-17 07:12:37
  • win10子系统python开发环境准备及kenlm和nltk的使用教程

    2023-07-31 01:48:28
  • python读取xml文件方法解析

    2021-04-25 03:53:45
  • python模拟登录百度代码分享(获取百度贴吧等级)

    2022-05-13 02:54:34
  • XML的语法、结构以及相关的一些技术

    2007-10-23 07:27:00
  • Python机器学习之决策树

    2022-02-24 07:19:01
  • python中的Pyperclip模块功能详解

    2021-10-25 05:28:22
  • Python获取基金网站网页内容、使用BeautifulSoup库分析html操作示例

    2022-10-04 00:34:40
  • Python实现多并发访问网站功能示例

    2022-12-16 11:42:47
  • 这可能是最好玩的python GUI入门实例(推荐)

    2021-02-01 15:33:42
  • PID原理与python的简单实现和调参

    2021-08-13 13:27:36
  • python实现unicode转中文及转换默认编码的方法

    2021-05-02 22:19:59
  • Sql Server查询性能优化之不可小觑的书签查找介绍

    2024-01-18 22:32:48
  • Centos5.x下升级python到python2.7版本教程

    2023-04-15 13:50:07
  • Django中传递参数到URLconf的视图函数中的方法

    2021-09-16 23:46:33
  • 使用Python操作FTP实现上传和下载的方法

    2023-03-09 20:49:51
  • 深度理解Python中Class类、Object类、Type元类

    2022-07-14 03:10:13
  • 解决Pytorch训练过程中loss不下降的问题

    2023-03-01 09:30:22
  • 10个python爬虫入门实例(小结)

    2021-04-21 01:08:57
  • asp之家 网络编程 m.aspxhome.com