首页 建站教程 正文
我要投稿

分享PHP守护进程类

建站教程
2025-05-29 0 57
也想出现在这里？点击联系我~

用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

445

446
<?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';

}

}

收藏 (0) 打赏

感谢您的支持，我会继续努力的!

打开微信/支付宝扫一扫，即可进行扫码打赏哦，分享从这里开始，精彩与您同在
点赞 (0)

声明：本站所有文章，如无特殊说明或标注，均为本站原创发布。任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。

快网idc优惠网 建站教程 分享PHP守护进程类 https://www.kuaiidc.com/99687.html

也想出现在这里？点击联系我~

相关文章

64M VPS建站：怎样选择合适的域名和SSL证书？
64M VPS建站：怎样选择合适的域名和SSL证书？
建站教程
5个月前 99
64M VPS建站：怎样优化以提高网站加载速度？
64M VPS建站：怎样优化以提高网站加载速度？
建站教程
5个月前 136
64M VPS建站：是否适合初学者操作和管理？
64M VPS建站：是否适合初学者操作和管理？
建站教程
5个月前 95
ASP.NET自助建站系统中的用户注册和登录功能定制方法
ASP.NET自助建站系统中的用户注册和登录功能定制方法
建站教程
5个月前 157
猜你喜欢
发表评论
暂无评论
TA的动态
快网idc优惠网

idc信息共同学习，共同进步，共同成长！

QQ交流群
快网idc优惠网

QQ交流群

您的支持，是我们最大的动力！
热门文章
热门评论
终身VIP会员限时钜惠
首页 SSL证书 菜单 论坛 问答