PHP共享内存的应用shmop系列

时间  2019-11-24
标签 php 共享 内存 应用 shmop 系列 栏目 PHP 繁體版
原文   原文链接

简单的说明php

可能不多状况会使用PHP来操控共享内存，一方面在内存的控制上，MC已经提供了一套很好的方式，另外一方面，本身来操控内存的难度较大，内存的读写与转存，包括后面可能会用到的存储策略，要是没有必定计算机组成原理的基础，想作这些不是一件容易的事情。那为何还要使用它呢？若是我想进行管道通讯，为其它的应用服务准备数据；我想创建本身的数据缓存体系，使用MC有点大炮打苍蝇的感受。那么shmop会是一个选择，固然，在操做内存前，必定要谨慎。数据库

系统要求apache

shmop系列函数只是在unix/Linux下可用，能够经过命令：缓存

 

Plain代码 
  1. ipcs -m  


 

来查看当前的共享内存使用状况。其中，各个部分解释以下：服务器

key ：共享内存的惟一的key值，共享内存经过该key来判断你读取的是哪一块内存。网络

shmid：当使用key来获取内存时，你得到的是这个id的值。它做为你操做内存块的标识。架构

owner：建立该共享内存块的用户app

perms：该共享内存的读写权限，8禁止，能够是777，与文件的读写权限一致。函数

bytes：该内存块的大小ui

nattch：链接该内存块的进程数

status：当前状态，如：dest，即将删除等。

使用示例

具体的使用说明，在PHP手册中有详细介绍，这里不进行赘述。这里将写一些简单的操做例子。

写入

 

Php代码 
  1. <?php  
  2. /** 
  3.   * SHMOP共享内存操做示例 
  4.   * @author monkee 
  5.  **/  
  6. $key = 0x4337b700;  
  7. $size = 4096;  
  8. $shmid = @shmop_open($key, 'c', 0644, $size);  
  9. if($shmid === FALSE){  
  10.     exit('shmop_open error!');  
  11. }  
  12.   
  13. $data = '世界，你好！我将写入不少的数据，你能罩得住么？';  
  14.   
  15. $length = shmop_write($shmid, pack('a*',$data), 0);  
  16. if($length === FALSE){  
  17.     exit('shmop_write error!');  
  18. }  
  19.   
  20. @shmop_close($shmid);  
  21.   
  22. exit('succ');  
  23. ?>  

 

 

读取

 

Php代码 
  1. <?php  
  2. /** 
  3.   * SHMOP共享内存操做示例 
  4.   * @author monkee 
  5.  **/  
  6. $key = 0x4337b700;  
  7. $size = 256;  
  8. $shmid = @shmop_open($key, 'c', 0644, $size);  
  9. if($shmid === FALSE){  
  10.     exit('shmop_open error!');  
  11. }  
  12.   
  13. $data = unpack('a*', shmop_read($shmid, 0, 256));  
  14. if($data === FALSE){  
  15.     exit('shmop_read error!');  
  16. }  
  17. @shmop_close($shmid);  
  18.   
  19. exit($data[1]);  
  20. ?>  


这里使用到了函数：pack() 这个函数用来将内存里的内容转化为二进制内容，具体请查看手册内容。

 

多服务器内存同步

已经在本地作好了这个服务，如今须要在多台服务器上进行内存数据同步。虽然这个时候能够放弃共享内存的方式来处理数据了，然而你被要求须要这么作。因而，同步我想不是问题，作好“主-从”的架构，我同步好的内存及时推送过去就能够了。然而，我是否是须要在从机上作一个监听程序呢？这样的代价有点大，好的一点是，从机上有apache。也就是说可使用HTTP协议来进行通讯了。

同步策略

如何同步？看似无聊的问题，却又产生了疑惑。同步数据呗，可是同步什么数据！一种方式是主机的内存改变后，程序读取全部内存数据而后发送到从机进行同步；若是我只是更改一些简单的操做位的话，那么小的更新却要引发整个内存块的同步，彷佛有些浪费。还有一种，是更新变化。将变化进行更新。这种比较复杂，由于你须要定义每一种操做的处理。幸运的是，你须要操做的数据并很少，还有，你要定义的操做也很少：write，delete（read能够不要，由于你不多会从从机上读取数据）。那么好了，咱们选择其中一种来作吧。

主机发送

 

Php代码 
  1. <?php  
  2.   
  3. /**  
  4.   * 共享内存操做，支持远程内存同步。 
  5.   * @author hufeng@ 
  6.   * @since 2011-08-10 
  7.   * 
  8.   */  
  9. define('PSHMOP_HOST', '192.168.0.1');   
  10. define('PSHMOP_SEPE', "\r\n----------CKSJFIOWKJDFOCKJVNBBSDF----------\r\n");  
  11. class Pshmop   
  12. {  
  13.     static private $data = array();  
  14.     static public function write($key, $offset, $data, $size = 0){   
  15.         $h = array('key' => $key, 'offset' => $offset, 'size' => $size, 'ac' => 'write');   
  16.         return self::add($h, $data);   
  17.     }   
  18.        
  19.     static public function del($key){   
  20.         $h = array('key' => $key, 'ac' => 'delete');   
  21.         return self::add($h);   
  22.     }  
  23.   
  24.     static private function add($dataheader, $databody=''){  
  25.         self::$data[] = serialize($dataheader)."\n".$databody;   
  26.     }  
  27.    
  28.     static private function send(){   
  29.         $d = & self::$data;  
  30.         if(count($d) == 0){  
  31.             return ;   
  32.         }  
  33.         $http_entity_body = join(PSHMOP_SEPE, $d);  
  34.         $http_entity_length = strlen($http_entity_body);  
  35.         $fp = fsockopen(PSHMOP_HOST, 80, $errno, $error);   
  36.         if(!$fp){   
  37.             return -1;   
  38.         }   
  39.   
  40.         fputs($fp, "PUT /pshmop.php HTTP/1.1\r\n");   
  41.         fputs($fp, 'Host: '.PSHMOP_HOST."\r\n");   
  42.         fputs($fp, "Content-Type: application/x-www-form-urlencoded\r\n");   
  43.         fputs($fp, "Content-Length: {$http_entity_length}\r\n");   
  44.         fputs($fp, "Connection: close\r\n\r\n");   
  45.         fputs($fp, $http_entity_body . "\r\n\r\n");   
  46.         $d = '';   
  47.         while(!feof($fp)){   
  48.             $d .= fgets($fp, 4096);   
  49.         }   
  50.         fclose($fp);   
  51.         return $d;   
  52.     }   
  53. }   


使用的时候，进行：

 

 

Php代码 
  1. Pshmop::write();  
  2. Pshmop::write();  
  3. Pshmop::write();  
  4. Pshmop::send();  


PS:为了支持多个更新一次传递的原则，以上即是举例。

 

从机监听

 

Php代码 
  1. <?php  
  2.   
  3. /** 
  4.   * 共享内存远程处理类 
  5.   * 对从远端传输到的数据进行处理、内存同步更新 
  6.   * @author hufeng@ 
  7.   * @since 2011-08-11 
  8.   **/  
  9. define('RSHMOP_SEPE', "\r\n----------CKSJFIOWKJDFOCKJVNBBSDF----------\r\n");  
  10. class Rshmop  
  11. {  
  12.     static public function run($data){  
  13.         $items = @explode(RSHMOP_SEPE, $data);  
  14.         if($items === NULL){  
  15.             return -1;  
  16.         }  
  17.         $result = array('succ' => 0, 'error' => 0);  
  18.         foreach($items as $k => $i){  
  19.             self::op($i) === 0 ? $result['succ']++ : $result['error']++;  
  20.             unset($items[$k]);  
  21.         }  
  22.         return $result;  
  23.     }  
  24.     static public function op($str){  
  25.         $p = strpos($str, "\n");  
  26.         $header = @unserialize(substr($str, 0, $p));  
  27.         if($header === FALSE){  
  28.             return 'Data Format Error!';  
  29.         }  
  30.         $body = substr($str, $p+1);  
  31.         $shmid = null;  
  32.         if($header['size'] > 0){  
  33.             $shmid = @shmop_open($header['key'], 'c', 0644, $header['size']);  
  34.         }  
  35.         if(!$shmid){  
  36.             $cmd = "ipcs -m | grep '{$header['key']}'";  
  37.             $em = exec($cmd);  
  38.             $em = preg_replace('/ +/', ' ', $em);  
  39.             $ems = explode(' ', $em);  
  40.             $header['size'] = intval($ems[4]);  
  41.             if($header['size'] == 0){  
  42.                 if($headerreturn ['ac'] == 'delete'){  
  43.                     return 0;  
  44.                 }else{  
  45.                     return 'Param `size` required!';  
  46.                 }  
  47.             }  
  48.             $shmid = @shmop_open($header['key'], 'c', 0644, $header['size']);  
  49.         }  
  50.         if($header['ac'] == 'write'){  
  51.             shmop_write($shmid, $body, $header['offset']);  
  52.         }  
  53.         if($header['ac'] == 'delete'){  
  54.             shmop_delete($shmid);  
  55.         }  
  56.         shmop_close($shmid);  
  57.         return 0;  
  58.     }  
  59. }  


若是遇到主机有而从机未有的数据块（可能由网络问题形成，也能够有其它解决办法），能够选择delete而后再进行其它操做。

 

缓存使用的策略

以为使用MC代价有点高，能够本身来控制内存和使用。固然，小部分的数据能够容易使用，可是当数据多的时候，决定哪部分数据进入内存，哪部分数据进入硬盘都是值得商榷的。这也就是为何要提策略。

常见的策略无非是 FIFO，LUR，LAR等，但并非说这些策略就是好的。实际状况中，根据具体的业务需求，来组织相应的策略。最多见的，咱们是将从数据库查询时间长的、获取数据耗时（从其它机器上获取）、计算耗时的、须要及时使用的放入内存中。

这部分的代码就不写了，但愿有所帮助。

 

转载自：http://tubaluer.iteye.com/blog/1349797 做者 tubaluer

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程