海运的博客

<?php  
   $start = microtime ( true ); 
   function convert($size)
   {
      $unit=array('b','kb','mb','gb','tb','pb');
      return @round($size/pow(1024,($i=floor(log($size,1024)))),2).$unit[$i];
   }

   function strtr_words($str)  
   {  
      $words=array();  
      $content = file_get_contents('t.txt');
      $content = preg_split('/\r\n/', $content, -1, PREG_SPLIT_NO_EMPTY); //分割字符串为数组
      foreach($content as $key => $value)  
      {  
         //if ($key != '')  
         if (!empty($key))  
         {  
            $str_data = explode(',', $value); //分割同义词为k-v数组
            $str = str_replace($str_data[0], $str_data[1] , $str);
            //$words+=array("$str_data[0]"=>"$str_data[1]");  
         }  
      }  
      return $str;
      //return strtr($str,$words);
   }  
   echo strtr_words('村庄,一眼望不到边际')."\n";  
   echo convert(memory_get_usage(true))."\n"; 
   $end = microtime ( true ); 
   echo "脚本执行时间".($end - $start)."\n";  
?>

14.12.22更新：
此方法词库太大时效率很差，可以将词库以key->vale方式加载到内存，文章分词遍历再替换。

使用yum直接安装：

yum install gearmand

安装PHP扩展：

yum install libgearman re2c
wget http://pecl.php.net/get/gearman-1.1.2.tgz
tar zxvf gearman-1.1.2.tgz 
cd gearman-1.1.2
phpize 
./configure 
make && make install
echo "extension=gearman.so" >> /etc/php.ini

启动任务分发进程：

gearmand -d --keepalive --libtokyocabinet-file /tmp/gearmand.tch

PHP客户端，提交任务：

<?php  
   $client= new GearmanClient();  
   $client->addServer("127.0.0.1", 4730); 
   //发送任务到Job，处理函数和数据
   //echo $client->do("reverse", "Hello World!");  
   echo $client->doBackground("reverse", "Hello World!");  
?> 

PHP执行端：

<?php  
   $worker= new GearmanWorker();  
   $worker->addServer("127.0.0.1", 4730); 
   //处理接收到数据的回调函数
   $worker->addFunction("reverse", "reverse_function");  
   while ($worker->work());  
   function reverse_function($job)  
   {  
      for($i = 0; $i < 10; $i++){  
         sleep(1);  
         echo "{$i}\n";  
      }  
      return $job->workload();  
   }  
?>  

<?php
   $key = ftok(__FILE__, 's');
   // 同时最多只能有一个进程进入临界区
   $sem_id = sem_get($key, 1);
   echo "This is a room，can only stay one people!\n\r";
   // 派生子进程
   $pid = pcntl_fork();
   if ($pid == -1) {
      exit('fork failed!');
   } else if ($pid > 0) {
      $name = 'parent';
   } else {
      $name = 'child';
   }
   echo "{$name} want to enter the room \n";
   sem_acquire($sem_id);
   // 原子操作开始
   echo "{$name} in the room , other people can't enter!\n";
   sleep(3);
   echo "{$name} leave the room\n";
   // 原子操作结束
   sem_release($sem_id);
   if ($pid > 0) {
      pcntl_waitpid($pid, $status);
      sem_remove($sem_id);//移除信号量
   }
?>

Yum安装的PHP需安装扩展包php-process：

<?php 
   $shm_key = intval(bin2hex('node'), '16');               
   $memsize = 120;
   $shm_h = shm_attach($shm_key, $memsize, 0644);
   $var_key = intval(bin2hex('key'), '16'); 
   $var_value = 'hello';
   shm_put_var($shm_h, $var_key, $var_value);
   echo shm_get_var($shm_h, $var_key);
   shm_remove_var($shm_h, $var_key);
   shm_detach($shm_h);
?>

多进程：

<?php
   //生成key
   $message_queue_key = ftok(__FILE__, 'a');
   //根据生成的key新建队列，也可自定，如123456
   $message_queue = msg_get_queue($message_queue_key, 0666);

   $pids = array();
   for ($i = 0; $i < 5; $i++) {
      //创建子进程
      $pids[$i] = pcntl_fork();

      if ($pids[$i]) {
         echo "No.$i child process was created, the pid is $pids[$i]\r\n";
         pcntl_wait($status);//非阻塞的线程等待,防止僵尸进程的出现
      } elseif ($pids[$i] == 0) {
         $pid = posix_getpid();
         echo "process.$pid is writing now\r\n";
         //写队列
         msg_send($message_queue, 1, "this is process.$pid's data\r\n");
         posix_kill($pid, SIGTERM);
      }
   }

   do {
      //读队列
      msg_receive($message_queue, 0, $message_type, 1024, $message, true, MSG_IPC_NOWAIT);
      echo $message;
      //获取队列内消息数
      $a = msg_stat_queue($message_queue);
      if($a['msg_qnum'] == 0){
         break;
      }
   } while(true)
?>

父子进程：

<?php
   $message_queue_key = ftok(__FILE__, 'a');
   $message_queue = msg_get_queue($message_queue_key, 0666);
   $pid = pcntl_fork();
   if ($pid==-1) {
      die("cannot fork");
   } else if ($pid) { //父进程
      pcntl_wait($status);
      msg_receive($message_queue, 0, $message_type, 1024, $message, true, MSG_IPC_NOWAIT);
      echo $message;

   } else {
      $pid = posix_getpid(); //子进程
      msg_send($message_queue, 1, "this is process.$pid's data\r\n");
   }
?>