PHP守护进程类

Jun 20, 2016 pm 01:01 PM

PHP守护进程类,守护进程(Daemon)是运行在后台的一种特殊进程。它独立于控制终端并且周期性地执行某种任务或等待处理某些发生的事件。守护进程是一种很有用的进程。php也可以实现守护进程的功能,需要的朋友可以参考下

用PHP实现的Daemon类。可以在服务器上实现队列或者脱离 crontab 的计划任务。 
使用的时候,继承于这个类,并重写 _doTask 方法,通过 main 初始化执行。

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

311

312

313

314

315

316

317

318

319

320

321

322

323

324

325

326

327

328

329

330

331

332

333

334

335

336

337

338

339

340

341

342

343

344

345

346

347

348

349

350

351

352

353

354

355

356

357

358

359

360

361

362

363

364

365

366

367

368

369

370

371

372

373

374

375

376

377

378

379

380

381

382

383

384

385

386

387

388

389

390

391

392

393

394

395

396

397

398

399

400

401

402

403

404

405

406

407

408

409

410

411

412

413

414

415

416

417

418

419

420

421

422

423

424

425

426

427

428

429

430

431

432

433

434

435

436

437

438

439

440

441

442

443

444

<?php class Daemon {

  

  const DLOG_TO_CONSOLE = 1;

  const DLOG_NOTICE = 2;

  const DLOG_WARNING = 4;

  const DLOG_ERROR = 8;

  const DLOG_CRITICAL = 16;

  

  const DAPC_PATH = '/tmp/daemon_apc_keys';

  

  /**

   * User ID

   *

   * @var int

   */

  public $userID = 65534; // nobody

  

  /**

   * Group ID

   *

   * @var integer

   */

  public $groupID = 65533; // nobody

  

  /**

   * Terminate daemon when set identity failure ?

   *

   * @var bool

   * @since 1.0.3

   */

  public $requireSetIdentity = false;

  

  /**

   * Path to PID file

   *

   * @var string

   * @since 1.0.1

   */

  public $pidFileLocation = '/tmp/daemon.pid';

  

  /**

   * processLocation

   * 进程信息记录目录

   *

   * @var string

   */

  public $processLocation = '';

  

  /**

   * processHeartLocation

   * 进程心跳包文件

   *

   * @var string

   */

  public $processHeartLocation = '';

  

  /**

   * Home path

   *

   * @var string

   * @since 1.0

   */

  public $homePath = '/';

  

  /**

   * Current process ID

   *

   * @var int

   * @since 1.0

   */

  protected $_pid = 0;

  

  /**

   * Is this process a children

   *

   * @var boolean

   * @since 1.0

   */

  protected $_isChildren = false;

  

  /**

   * Is daemon running

   *

   * @var boolean

   * @since 1.0

   */

  protected $_isRunning = false;

  

  /**

   * Constructor

   *

   * @return void

   */

  public function __construct() {

  

    error_reporting(0);

    set_time_limit(0);

    ob_implicit_flush();

  

    register_shutdown_function(array(&$this, 'releaseDaemon'));

  }

  

  /**

   * 启动进程

   *

   * @return bool

   */

  public function main() {

  

    $this->_logMessage('Starting daemon');

  

    if (!$this->_daemonize()) {

      $this->_logMessage('Could not start daemon', self::DLOG_ERROR);

  

      return false;

    }

  

    $this->_logMessage('Running...');

  

    $this->_isRunning = true;

  

    while ($this->_isRunning) {

      $this->_doTask();

    }

  

    return true;

  }

  

  /**

   * 停止进程

   *

   * @return void

   */

  public function stop() {

  

    $this->_logMessage('Stoping daemon');

  

    $this->_isRunning = false;

  }

  

  /**

   * Do task

   *

   * @return void

   */

  protected function _doTask() {

    // override this method

  }

  

  /**

   * _logMessage

   * 记录日志

   *

   * @param string 消息

   * @param integer 级别

   * @return void

   */

  protected function _logMessage($msg, $level = self::DLOG_NOTICE) {

    // override this method

  }

  

  /**

   * Daemonize

   *

   * Several rules or characteristics that most daemons possess:

   * 1) Check is daemon already running

   * 2) Fork child process

   * 3) Sets identity

   * 4) Make current process a session laeder

   * 5) Write process ID to file

   * 6) Change home path

   * 7) umask(0)

   *

   * @access private

   * @since 1.0

   * @return void

   */

  private function _daemonize() {

  

    ob_end_flush();

  

    if ($this->_isDaemonRunning()) {

      // Deamon is already running. Exiting

      return false;

    }

  

    if (!$this->_fork()) {

      // Coudn't fork. Exiting.

      return false;

    }

  

    if (!$this->_setIdentity() && $this->requireSetIdentity) {

      // Required identity set failed. Exiting

      return false;

    }

  

    if (!posix_setsid()) {

      $this->_logMessage('Could not make the current process a session leader', self::DLOG_ERROR);

  

      return false;

    }

  

    if (!$fp = fopen($this->pidFileLocation, 'w')) {

      $this->_logMessage('Could not write to PID file', self::DLOG_ERROR);

      return false;

    } else {

      fputs($fp, $this->_pid);

      fclose($fp);

    }

  

    // 写入监控日志

    $this->writeProcess();

  

    chdir($this->homePath);

    umask(0);

  

    declare(ticks = 1);

  

    pcntl_signal(SIGCHLD, array(&$this, 'sigHandler'));

    pcntl_signal(SIGTERM, array(&$this, 'sigHandler'));

    pcntl_signal(SIGUSR1, array(&$this, 'sigHandler'));

    pcntl_signal(SIGUSR2, array(&$this, 'sigHandler'));

  

    return true;

  }

  

  /**

   * Cheks is daemon already running

   *

   * @return bool

   */

  private function _isDaemonRunning() {

  

    $oldPid = file_get_contents($this->pidFileLocation);

  

    if ($oldPid !== false && posix_kill(trim($oldPid),0))

    {

      $this->_logMessage('Daemon already running with PID: '.$oldPid, (self::DLOG_TO_CONSOLE | self::DLOG_ERROR));

  

      return true;

    }

    else

    {

      return false;

    }

  }

  

  /**

   * Forks process

   *

   * @return bool

   */

  private function _fork() {

  

    $this->_logMessage('Forking...');

  

    $pid = pcntl_fork();

  

    if ($pid == -1) {

      // 出错

      $this->_logMessage('Could not fork', self::DLOG_ERROR);

  

      return false;

    } elseif ($pid) {

      // 父进程

      $this->_logMessage('Killing parent');

  

      exit();

    } else {

      // fork的子进程

      $this->_isChildren = true;

      $this->_pid = posix_getpid();

  

      return true;

    }

  }

  

  /**

   * Sets identity of a daemon and returns result

   *

   * @return bool

   */

  private function _setIdentity() {

  

    if (!posix_setgid($this->groupID) || !posix_setuid($this->userID))

    {

      $this->_logMessage('Could not set identity', self::DLOG_WARNING);

  

      return false;

    }

    else

    {

      return true;

    }

  }

  

  /**

   * Signals handler

   *

   * @access public

   * @since 1.0

   * @return void

   */

  public function sigHandler($sigNo) {

  

    switch ($sigNo)

    {

      case SIGTERM:  // Shutdown

        $this->_logMessage('Shutdown signal');

        exit();

        break;

  

      case SIGCHLD:  // Halt

        $this->_logMessage('Halt signal');

        while (pcntl_waitpid(-1, $status, WNOHANG) > 0);

        break;

      case SIGUSR1:  // User-defined

        $this->_logMessage('User-defined signal 1');

        $this->_sigHandlerUser1();

        break;

      case SIGUSR2:  // User-defined

        $this->_logMessage('User-defined signal 2');

        $this->_sigHandlerUser2();

        break;

    }

  }

  

  /**

   * Signals handler: USR1

   * 主要用于定时清理每个进程里被缓存的域名dns解析记录

   *

   * @return void

   */

  protected function _sigHandlerUser1() {

    apc_clear_cache('user');

  }

  

  /**

   * Signals handler: USR2

   * 用于写入心跳包文件

   *

   * @return void

   */

  protected function _sigHandlerUser2() {

  

    $this->_initProcessLocation();

  

    file_put_contents($this->processHeartLocation, time());

  

    return true;

  }

  

  /**

   * Releases daemon pid file

   * This method is called on exit (destructor like)

   *

   * @return void

   */

  public function releaseDaemon() {

  

    if ($this->_isChildren && is_file($this->pidFileLocation)) {

      $this->_logMessage('Releasing daemon');

  

      unlink($this->pidFileLocation);

    }

  }

  

  /**

   * writeProcess

   * 将当前进程信息写入监控日志,另外的脚本会扫描监控日志的数据发送信号,如果没有响应则重启进程

   *

   * @return void

   */

  public function writeProcess() {

  

    // 初始化 proc

    $this->_initProcessLocation();

  

    $command = trim(implode(' ', $_SERVER['argv']));

  

    // 指定进程的目录

    $processDir = $this->processLocation . '/' . $this->_pid;

    $processCmdFile = $processDir . '/cmd';

    $processPwdFile = $processDir . '/pwd';

  

    // 所有进程所在的目录

    if (!is_dir($this->processLocation)) {

      mkdir($this->processLocation, 0777);

      chmod($processDir, 0777);

    }

  

    // 查询重复的进程记录

    $pDirObject = dir($this->processLocation);

    while ($pDirObject && (($pid = $pDirObject->read()) !== false)) {

      if ($pid == '.' || $pid == '..' || intval($pid) != $pid) {

        continue;

      }

  

      $pDir = $this->processLocation . '/' . $pid;

      $pCmdFile = $pDir . '/cmd';

      $pPwdFile = $pDir . '/pwd';

      $pHeartFile = $pDir . '/heart';

  

      // 根据cmd检查启动相同参数的进程

      if (is_file($pCmdFile) && trim(file_get_contents($pCmdFile)) == $command) {

        unlink($pCmdFile);

        unlink($pPwdFile);

        unlink($pHeartFile);

  

        // 删目录有缓存

        usleep(1000);

  

        rmdir($pDir);

      }

    }

  

    // 新进程目录

    if (!is_dir($processDir)) {

      mkdir($processDir, 0777);

      chmod($processDir, 0777);

    }

  

    // 写入命令参数

    file_put_contents($processCmdFile, $command);

    file_put_contents($processPwdFile, $_SERVER['PWD']);

  

    // 写文件有缓存

    usleep(1000);

  

    return true;

  }

  

  /**

   * _initProcessLocation

   * 初始化

   *

   * @return void

   */

  protected function _initProcessLocation() {

  

    $this->processLocation = ROOT_PATH . '/app/data/proc';

    $this->processHeartLocation = $this->processLocation . '/' . $this->_pid . '/heart';

  }

}

Copy after login


Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn

Hot AI Tools

Undresser.AI Undress

Undresser.AI Undress

AI-powered app for creating realistic nude photos

AI Clothes Remover

AI Clothes Remover

Online AI tool for removing clothes from photos.

Undress AI Tool

Undress AI Tool

Undress images for free

Clothoff.io

Clothoff.io

AI clothes remover

AI Hentai Generator

AI Hentai Generator

Generate AI Hentai for free.

Hot Article

R.E.P.O. Energy Crystals Explained and What They Do (Yellow Crystal)
2 weeks ago By 尊渡假赌尊渡假赌尊渡假赌
Repo: How To Revive Teammates
1 months ago By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Adventure: How To Get Giant Seeds
4 weeks ago By 尊渡假赌尊渡假赌尊渡假赌

Hot Tools

Notepad++7.3.1

Notepad++7.3.1

Easy-to-use and free code editor

SublimeText3 Chinese version

SublimeText3 Chinese version

Chinese version, very easy to use

Zend Studio 13.0.1

Zend Studio 13.0.1

Powerful PHP integrated development environment

Dreamweaver CS6

Dreamweaver CS6

Visual web development tools

SublimeText3 Mac version

SublimeText3 Mac version

God-level code editing software (SublimeText3)

11 Best PHP URL Shortener Scripts (Free and Premium) 11 Best PHP URL Shortener Scripts (Free and Premium) Mar 03, 2025 am 10:49 AM

Long URLs, often cluttered with keywords and tracking parameters, can deter visitors. A URL shortening script offers a solution, creating concise links ideal for social media and other platforms. These scripts are valuable for individual websites a

Working with Flash Session Data in Laravel Working with Flash Session Data in Laravel Mar 12, 2025 pm 05:08 PM

Laravel simplifies handling temporary session data using its intuitive flash methods. This is perfect for displaying brief messages, alerts, or notifications within your application. Data persists only for the subsequent request by default: $request-

Build a React App With a Laravel Back End: Part 2, React Build a React App With a Laravel Back End: Part 2, React Mar 04, 2025 am 09:33 AM

This is the second and final part of the series on building a React application with a Laravel back-end. In the first part of the series, we created a RESTful API using Laravel for a basic product-listing application. In this tutorial, we will be dev

Simplified HTTP Response Mocking in Laravel Tests Simplified HTTP Response Mocking in Laravel Tests Mar 12, 2025 pm 05:09 PM

Laravel provides concise HTTP response simulation syntax, simplifying HTTP interaction testing. This approach significantly reduces code redundancy while making your test simulation more intuitive. The basic implementation provides a variety of response type shortcuts: use Illuminate\Support\Facades\Http; Http::fake([ 'google.com' => 'Hello World', 'github.com' => ['foo' => 'bar'], 'forge.laravel.com' =>

cURL in PHP: How to Use the PHP cURL Extension in REST APIs cURL in PHP: How to Use the PHP cURL Extension in REST APIs Mar 14, 2025 am 11:42 AM

The PHP Client URL (cURL) extension is a powerful tool for developers, enabling seamless interaction with remote servers and REST APIs. By leveraging libcurl, a well-respected multi-protocol file transfer library, PHP cURL facilitates efficient execution of various network protocols, including HTTP, HTTPS, and FTP. This extension offers granular control over HTTP requests, supports multiple concurrent operations, and provides built-in security features.

12 Best PHP Chat Scripts on CodeCanyon 12 Best PHP Chat Scripts on CodeCanyon Mar 13, 2025 pm 12:08 PM

Do you want to provide real-time, instant solutions to your customers' most pressing problems? Live chat lets you have real-time conversations with customers and resolve their problems instantly. It allows you to provide faster service to your custom

Announcement of 2025 PHP Situation Survey Announcement of 2025 PHP Situation Survey Mar 03, 2025 pm 04:20 PM

The 2025 PHP Landscape Survey investigates current PHP development trends. It explores framework usage, deployment methods, and challenges, aiming to provide insights for developers and businesses. The survey anticipates growth in modern PHP versio

Notifications in Laravel Notifications in Laravel Mar 04, 2025 am 09:22 AM

In this article, we're going to explore the notification system in the Laravel web framework. The notification system in Laravel allows you to send notifications to users over different channels. Today, we'll discuss how you can send notifications ov

See all articles