PHP shared memory cache

keithyau 發(fā)布于2019-06-27 11:39 / 3122人閱讀

摘要：引子最近在寫(xiě)的時(shí)候，需要使用內(nèi)存緩存，大家都知道有比較成熟的基于，，以及等緩存。此函數(shù)支持兩種調(diào)用方式，可以設(shè)置和獲取緩存。設(shè)置的時(shí)候還能一并設(shè)置緩存過(guò)期時(shí)間。如果數(shù)據(jù)過(guò)大會(huì)不能更新緩存。這樣就避免了每次全部緩存導(dǎo)致的多余的開(kāi)銷(xiāo)。

PHP shared memory cache 引子

最近在寫(xiě)PHP的時(shí)候，需要使用內(nèi)存緩存，大家都知道有比較成熟的基于memcached，redis，以及apc等緩存。但是不是要裝插件就是要第三方軟件支持。在小項(xiàng)目中用起來(lái)不是很方便！

實(shí)現(xiàn) shmop_*

所以打算使用php的shared memory的shmop_*前綴的API來(lái)實(shí)現(xiàn)一個(gè)簡(jiǎn)單的緩存接口。
此函數(shù)支持兩種調(diào)用方式，可以設(shè)置和獲取緩存。設(shè)置的時(shí)候還能一并設(shè)置緩存過(guò)期時(shí)間。

  function cache($key, $val=null, $expire=100) {
      static $_caches = null;
      static $_shm = null;
      if ( null === $_shm ) $_shm = @shmop_open(crc32("mcache.solt"),    
          "c", 0755, config("cache.size", null, 10485760));
      if ( null === $_caches && $_shm && ($size = intval(shmop_read($_shm, 0, 10))))
          $_caches = $size ? @unserialize(@shmop_read($_shm, 10, $size)) : array();
      if (($time = time()) && $val && $expire){
          $_caches[$key] = array($time + intval($expire), $val);
          if($_shm && ($size = @shmop_write($_shm, serialize(array_filter($_caches, function($  n)use($time){return $n[0] > $time;})), 10)))
              @shmop_write($_shm, sprintf("%10d", $size), 0);
          return $val;
      }
      return (isset($_caches[$key]) && $_caches[$key][0] > $time) ? $_caches[$key][1] : null;
  }

不過(guò)有個(gè)缺點(diǎn)每次load cache的時(shí)候需要全部一起load，然后反序列化保存到靜態(tài)數(shù)組里面。只能緩存一些比較小的數(shù)據(jù)。如果數(shù)據(jù)過(guò)大會(huì)不能更新緩存。

shm_*

后來(lái)發(fā)現(xiàn)PHP還有提供一個(gè)操作shared memory的API，可以使用這個(gè)API按照key value的形式存取緩存。這樣就避免了每次load全部緩存導(dǎo)致的多余的開(kāi)銷(xiāo)。

 function shmcache($key, $val=null, $expire=100) {
     static $_shm = null;
     if ( null === $_shm ) $_shm = @shm_attach(crc32(config("mcache.solt", null, "mcac  he.solt")),
         config("cache.size", null, 10485760), 0755);
     if (($time = time()) && ($k = crc32($key)) && $val && $expire){
         shm_put_var($_shm, $k, array($time + $expire, $val));
         return $val;
     }
     return shm_has_var($_shm, $k) && ($data = shm_get_var($_shm, $k)) && $data[0] >   $time ? $data[1] : null;
 }

我把這兩個(gè)函數(shù)和一些其他的基本函數(shù)（現(xiàn)在只有9個(gè)函數(shù)）放在一個(gè)utils倉(cāng)庫(kù)里面。也可以直接使用 composer require lloydzhou/utils 安裝