php 共享內存

時間 2019-11-25

標籤 php 共享內存欄目 PHP 简体版

原文原文鏈接

共享內存主要用於進程間通訊php

php中的共享內存有兩套擴展能夠實現html

一、shmop 編譯時須要開啓 --enable-shmop 參數linux

實例：web

$shm_key = ftok(__FILE__, 't');

/**
 開闢一塊共享內存
 
int $key , string $flags , int $mode , int $size 
$flags: a:訪問只讀內存段
        c:建立一個新內存段，或者若是該內存段已存在，嘗試打開它進行讀寫
        w:可讀寫的內存段
        n:建立一個新內存段，若是該內存段已存在，則會失敗
$mode: 八進制格式  0655
$size: 開闢的數據大小 字節

 */

$shm_id = shmop_open($shm_key, "c", 0644, 1024);

/**
 * 寫入數據 數據必須是字符串格式 , 最後一個指偏移量
 * 注意：偏移量必須在指定的範圍以內，不然寫入不了
 * 
 */
$size = shmop_write($shm_id, 'songjiankang', 0);
echo "write into {$size}";

#讀取的範圍也必須在申請的內存範圍以內,不然失敗
$data = shmop_read($shm_id, 0, 100);
var_dump($data);

#刪除 只是作一個刪除標誌位，同時不在容許新的進程進程讀取，當在沒有任何進程讀取時系統會自動刪除
shmop_delete($shm_id);

#關閉該內存段
shmop_close($shm_id);

二、用 Semaphore 擴展中的 sem 類函數（用起來更方便，相似 key-value 格式）函數

// Get the file token key
$key = ftok(__DIR__, 'a');

// 建立一個共享內存
$shm_id = shm_attach($key, 1024, 777); // resource type
if ($shm_id === false) {
    die('Unable to create the shared memory segment');
}

#設置一個值
shm_put_var($shm_id, 111, 'value');

#刪除一個key
//shm_remove_var($shm_id, 111);

#獲取一個值
$value = shm_get_var($shm_id,  111);
var_dump($value);

#檢測一個key是否存在
// var_dump(shm_has_var($shm_id,  111));

#從系統中移除
shm_remove($shm_id);

#關閉和共享內存的鏈接
shm_detach($shm_id);

注意：這兩種方式不通用的ui

一個用共享內存和信號量實現的消息隊列this

/**
* 使用共享內存和信號量實現
* 
* 支持多進程, 支持各類數據類型的存儲
* 注: 完成入隊或出隊操做,儘快使用unset(), 以釋放臨界區
*
*/
class ShmQueue
{

    private $maxQSize = 0; // 隊列最大長度
    private $front = 0; // 隊頭指針
    private $rear = 0; // 隊尾指針
    private $blockSize = 256; // 塊的大小(byte)
    private $memSize = 25600; // 最大共享內存(byte)
    private $shmId = 0;

    private $filePtr = './shmq.ptr';

    private $semId = 0;

    public function __construct ()
    {
        $shmkey = ftok(__FILE__, 't');
        
        $this->shmId = shmop_open($shmkey, "c", 0644, $this->memSize);
        $this->maxQSize = $this->memSize / $this->blockSize;
        
        // 申請一個信號量
        $this->semId = sem_get($shmkey, 1);
        sem_acquire($this->semId); // 申請進入臨界區
        
        $this->init();
    }

    private function init ()
    {
        if (file_exists($this->filePtr)) {
            $contents = file_get_contents($this->filePtr);
            $data = explode('|', $contents);
            if (isset($data[0]) && isset($data[1])) {
                $this->front = (int) $data[0];
                $this->rear = (int) $data[1];
            }
        }
    }

    public function getLength ()
    {
        return (($this->rear - $this->front + $this->memSize) % ($this->memSize)) /
                 $this->blockSize;
    }

    public function enQueue ($value)
    {
        if ($this->ptrInc($this->rear) == $this->front) { // 隊滿
            return false;
        }
        
        $data = $this->encode($value);
        shmop_write($this->shmId, $data, $this->rear);
        $this->rear = $this->ptrInc($this->rear);
        return true;
    }

    public function deQueue ()
    {
        if ($this->front == $this->rear) { // 隊空
            return false;
        }
        $value = shmop_read($this->shmId, $this->front, $this->blockSize - 1);
        $this->front = $this->ptrInc($this->front);
        return $this->decode($value);
    }

    private function ptrInc ($ptr)
    {
        return ($ptr + $this->blockSize) % ($this->memSize);
    }

    private function encode ($value)
    {
        $data = serialize($value) . "__eof";
        echo '';
        
        echo strlen($data);
        echo '';
        
        echo $this->blockSize - 1;
        echo '';
        
        if (strlen($data) > $this->blockSize - 1) {
            throw new Exception(strlen($data) . " is overload block size!");
        }
        return $data;
    }

    private function decode ($value)
    {
        $data = explode("__eof", $value);
        return unserialize($data[0]);
    }

    public function __destruct ()
    {
        $data = $this->front . '|' . $this->rear;
        file_put_contents($this->filePtr, $data);
        
        sem_release($this->semId); // 出臨界區, 釋放信號量
    }
}

/*
 * // 進隊操做 $shmq = new ShmQueue(); $data = 'test data'; $shmq->enQueue($data);
 * unset($shmq); // 出隊操做 $shmq = new ShmQueue(); $data = $shmq->deQueue();
 * unset($shmq);
 */