设为首页收藏本站

UNIX技术社区

 找回密码
 注册

QQ登录

只需一步,快速开始

搜索
热搜: console
查看: 493|回复: 0

PHP多线程编程之管道通信实例分析

[复制链接]
发表于 2015-5-14 14:42:09 | 显示全部楼层 |阅读模式
本文实例讲述了PHP多线程编程之管道通信用法。分享给大家供大家参考。具体分析如下:
一个线程如果是个人英雄主义,那么多线程就是集体主义,你不再是一个独行侠,而是一个指挥家。

管道通信:
1. 管道可以认为是一个队列,不同的线程都可以往里面写东西,也都可以从里面读东西。写就是
在队列末尾添加,读就是在队头删除。
  
2. 管道一般有大小,默认一般是4K,也就是内容超过4K了,你就只能读,不能往里面写了。
  
3. 默认情况下,管道写入以后,就会被阻止,直到读取他的程序读取把数据读完。而读取线程也会被阻止,
   直到有进程向管道写入数据。当然,你可以改变这样的默认属性,用stream_set_block  函数,设置成非阻断模式。
  
下面是我分装的一个管道的类(这个类命名有问题,没有统一,没有时间改成统一的了,我一般先写测试代码,最后分装,所以命名上可能不统一):

  1. <?php
  2. class Pipe
  3. {
  4.   public $fifoPath;
  5.   private $w_pipe;
  6.   private $r_pipe;
  7.   
  8.   /**
  9.    * 自动创建一个管道
  10.    *
  11.    * @param string $name 管道名字
  12.    * @param int $mode 管道的权限,默认任何用户组可以读写
  13.    */
  14.   function __construct($name = 'pipe', $mode = 0666)
  15.   {
  16.     $fifoPath = "/tmp/$name." . posix_getpid();
  17.     if (!file_exists($fifoPath)) {
  18.       if (!posix_mkfifo($fifoPath, $mode)) {
  19.         error("create new pipe ($name) error.");
  20.         return false;
  21.       }
  22.     } else {
  23.       error( "pipe ($name) has exit.");
  24.       return false;
  25.     }
  26.     $this->fifoPath = $fifoPath;
  27.   }
  28. ///////////////////////////////////////////////////
  29. // 写管道函数开始
  30. ///////////////////////////////////////////////////
  31.   function open_write()
  32.   {
  33.     $this->w_pipe = fopen($this->fifoPath, 'w');
  34.     if ($this->w_pipe == NULL) {
  35.       error("open pipe {$this->fifoPath} for write error.");
  36.       return false;
  37.     }
  38.     return true;
  39.   }
  40.   
  41.   function write($data)
  42.   {
  43.     return fwrite($this->w_pipe, $data);
  44.   }
  45.   
  46.   function write_all($data)
  47.   {
  48.     $w_pipe = fopen($this->fifoPath, 'w');
  49.     fwrite($w_pipe, $data);
  50.     fclose($w_pipe);
  51.   }
  52.   
  53.   function close_write()
  54.   {
  55.     return fclose($this->w_pipe);
  56.   }
  57. /////////////////////////////////////////////////////////
  58. /// 读管道相关函数开始
  59. ////////////////////////////////////////////////////////
  60.   function open_read()
  61.   {
  62.     $this->r_pipe = fopen($this->fifoPath, 'r');
  63.     if ($this->r_pipe == NULL) {
  64.       error("open pipe {$this->fifoPath} for read error.");
  65.       return false;
  66.     }
  67.     return true;
  68.   }
  69.   function read($byte = 1024)
  70.   {
  71.     return fread($this->r_pipe, $byte);
  72.   }
  73.   function read_all()
  74.   {
  75.     $r_pipe = fopen($this->fifoPath, 'r');
  76.     $data = '';
  77.     while (!feof($r_pipe)) {
  78.       //echo "read one K\n";
  79.       $data .= fread($r_pipe, 1024);
  80.     }
  81.     fclose($r_pipe);
  82.     return $data;
  83.   }
  84.   function close_read()
  85.   {
  86.     return fclose($this->r_pipe);
  87.   }
  88.   /**
  89.    * 删除管道
  90.    *
  91.    * @return boolean is success
  92.    */
  93.   function rm_pipe()
  94.   {
  95.     return unlink($this->fifoPath);
  96.   }
  97. }
  98. ?>
  99. /*
  100. 有了这个类,就可以实现简单的管道通信了。*/
复制代码
您需要登录后才可以回帖 登录 | 注册

本版积分规则

快速回复 返回顶部 返回列表