PHP Daemon/worker environment worker, environment, Daemon, PHP

scyzxp

1. <?
   
2. define('WANT_PROCESSORS', 5);
   
3. define('PROCESSOR_EXECUTABLE', '/path/to/your/processor');
   
4. set_time_limit(0);
   
5. $cycles = 0;
   
6. $run = true;
   
7. $reload = false;
   
8. declare(ticks = 30);
   
9. 
   
10. function signal_handler($signal) {
    
11.     switch($signal) {
    
12.     case SIGTERM :
    
13.         global $run;
    
14.         $run = false;
    
15.         break;
    
16.     case SIGHUP  :
    
17.         global $reload;
    
18.         $reload = true;
    
19.         break;
    
20.     }   
    
21. }
    
22. 
    
23. pcntl_signal(SIGTERM, 'signal_handler');
    
24. pcntl_signal(SIGHUP, 'signal_handler');
    
25. 
    
26. function spawn_processor() {
    
27.     $pid = pcntl_fork();
    
28.     if($pid) {
    
29.         global $processors;
    
30.         $processors[] = $pid;
    
31.     } else {
    
32.         if(posix_setsid() == -1)
    
33.             die("Forked process could not detach from terminal\n");
    
34.         fclose(stdin);
    
35.         fclose(stdout);
    
36.         fclose(stderr);
    
37.         pcntl_exec(PROCESSOR_EXECUTABLE);
    
38.         die('Failed to fork ' . PROCESSOR_EXECUTABLE . "\n");
    
39.     }
    
40. }
    
41. 
    
42. function spawn_processors() {
    
43.     global $processors;
    
44.     if($processors)
    
45.         kill_processors();
    
46.     $processors = array();
    
47.     for($ix = 0; $ix < WANT_PROCESSORS; $ix++)
    
48.         spawn_processor();
    
49. }
    
50. 
    
51. function kill_processors() {
    
52.     global $processors;
    
53.     foreach($processors as $processor)
    
54.         posix_kill($processor, SIGTERM);
    
55.     foreach($processors as $processor)
    
56.         pcntl_waitpid($processor);
    
57.     unset($processors);
    
58. }
    
59. 
    
60. function check_processors() {
    
61.     global $processors;
    
62.     $valid = array();
    
63.     foreach($processors as $processor) {
    
64.         pcntl_waitpid($processor, $status, WNOHANG);
    
65.         if(posix_getsid($processor))
    
66.             $valid[] = $processor;
    
67.     }
    
68.     $processors = $valid;
    
69.     if(count($processors) > WANT_PROCESSORS) {
    
70.         for($ix = count($processors) - 1; $ix >= WANT_PROCESSORS; $ix--)
    
71.             posix_kill($processors[$ix], SIGTERM);
    
72.         for($ix = count($processors) - 1; $ix >= WANT_PROCESSORS; $ix--)
    
73.             pcntl_waitpid($processors[$ix]);
    
74.     } elseif(count($processors) < WANT_PROCESSORS) {
    
75.         for($ix = count($processors); $ix < WANT_PROCESSORS; $ix++)
    
76.             spawn_processor();
    
77.     }
    
78. }
    
79. 
    
80. spawn_processors();
    
81. 
    
82. while($run) {
    
83.     $cycles++;
    
84.     if($reload) {
    
85.         $reload = false;
    
86.         kill_processors();
    
87.         spawn_processors();
    
88.     } else {
    
89.         check_processors();
    
90.     }
    
91.     usleep(150000);
    
92. }
    
93. kill_processors();
    
94. pcntl_wait();
    
95. ?>

复制代码