Forked PHP Daemon Example Daemon, Example, Forked, PHP

scyzxp

1. <?php
   
2. 
   
3. /*
   
4. 
   
5.     PHP forked daemon
   
6.     Standalone PHP binary must be compiled with --enable-sockets and --enable-pcntl
   
7.     Dave M. -2002
   
8.         Online Services USA
   
9. */
   
10. 
    
11. function sig_handler($signo) {
    
12. 
    
13.      switch($signo) {
    
14.          case SIGTERM:
    
15.              // handle shutdown tasks
    
16.              exit;
    
17.              break;
    
18.          case SIGHUP:
    
19.              // handle restart tasks
    
20.              break;
    
21.          case SIGUSR1:
    
22.              print "Caught SIGUSR1...\n";
    
23.              break;
    
24.          case SIGCHLD:
    
25.              while( pcntl_waitpid(-1,$status,WNOHANG)>0 ) {
    
26.              }
    
27.              break;
    
28.          case SIGINT:
    
29.         exit;
    
30.          default:
    
31.              // not implemented yet...
    
32.              break;
    
33.      }
    
34. 
    
35. }
    
36. 
    
37. function interact($sock) {
    
38. 
    
39.     // Custom code goes here... e.g: socket_read() socket_write()...
    
40. 
    
41. }
    
42. 
    
43. function become_daemon() {
    
44. 
    
45.     $child = pcntl_fork();
    
46.     if($child) {
    
47.         exit; // kill parent
    
48.     }
    
49.     posix_setsid(); // become session leader
    
50.     chdir("/");
    
51.     umask(0); // clear umask
    
52.     return posix_getpid();
    
53. 
    
54. }
    
55. 
    
56. function open_pid_file($file) {
    
57. 
    
58.     if(file_exists($file)) {
    
59.         $fp = fopen($file,"r");
    
60.         $pid = fgets($fp,1024);
    
61.         fclose($fp);
    
62.         if(posix_kill($pid,0)) {
    
63.             print "Server already running with PID: $pid\n";
    
64.             exit;
    
65.         }
    
66.         print "Removing PID file for defunct server process $pid\n";
    
67.         if(!unlink($file)) {
    
68.             print "Cannot unlink PID file $file\n";
    
69.             exit;
    
70.         }
    
71.     }
    
72.     if($fp = fopen($file,"w")) {
    
73.         return $fp;
    
74.     } else {
    
75.         print "Unable to open PID file $file for writing...\n";
    
76.         exit;
    
77.     }
    
78. }
    
79. 
    
80. function change_identity($uid,$gid) {
    
81.     global $pid_file;
    
82.     if(!posix_setgid($gid)) {
    
83.         print "Unable to setgid to $gid!\n";
    
84.         unlink($pid_file);
    
85.         exit;
    
86.     }   
    
87.     if(!posix_setuid($uid)) {
    
88.         print "Unable to setuid to $uid!\n";
    
89.         unlink($pid_file);
    
90.         exit;
    
91.     }
    
92.    
    
93.    
    
94. }
    
95. 
    
96. error_reporting (4);
    
97. 
    
98. set_time_limit (0);
    
99. 
    
100. ob_implicit_flush ();
     
101. 
     
102. $pid_file = '/tmp/php_daemon.pid';
     
103. 
     
104. $underpriv_uid = '99'; // uid 99 == user nobody, at least on my system.
     
105. $underpriv_gid = '99';
     
106. 
     
107. $port = 10000;
     
108. $address = 0; // 0 binds to all addresses, may not work on fbsd
     
109. 
     
110. $quit = 0;
     
111. 
     
112. pcntl_signal(SIGCHLD, "sig_handler");
     
113. pcntl_signal(SIGTERM, "sig_handler");
     
114. pcntl_signal(SIGINT, "sig_handler");
     
115. 
     
116. $fh = open_pid_file($pid_file);
     
117. 
     
118. if (($sock = socket_create (AF_INET, SOCK_STREAM, 0)) < 0) {
     
119.     print "socket_create() failed: reason: " . socket_strerror ($sock) . "\n";
     
120. }
     
121. 
     
122. if (($ret = socket_bind ($sock, $address, $port)) < 0) {
     
123.     print "socket_bind() failed: reason: " . socket_strerror ($ret) . "\n";
     
124. }
     
125. 
     
126. if (($ret = socket_listen ($sock, 0)) < 0) {
     
127.     print "socket_listen() failed: reason: " . socket_strerror ($ret) . "\n";
     
128. }
     
129. 
     
130. change_identity($underpriv_uid,$underpriv_gid);
     
131. 
     
132. print "Server ready. Waiting for connections.....\n";
     
133. 
     
134. $pid = become_daemon();
     
135. fputs($fh,$pid);
     
136. fclose($fh);
     
137. 
     
138. while(!$quit) {
     
139. 
     
140.     if (($connection = socket_accept($sock)) < 0) {
     
141.         next;
     
142.     }
     
143.    
     
144.     if( ($child = pcntl_fork()) == -1 ) {
     
145.         print  "Could not fork!!\n";
     
146.         print "Dying...\n";
     
147.         $quit++;
     
148.     }
     
149.     elseif($child == 0) {
     
150.         socket_close($sock);
     
151.         interact($connection);
     
152.         exit;
     
153.     }
     
154.    
     
155.     socket_close($connection);
     
156.    
     
157. }
     
158. 
     
159. if(posix_getpid() == $pid) {
     
160.     unlink($pid_file);
     
161. }
     
162. ?>

复制代码