濮阳杆衣贸易有限公司

主頁 > 知識庫 > 淺談并發(fā)處理PHP進(jìn)程間通信之System V IPC

淺談并發(fā)處理PHP進(jìn)程間通信之System V IPC

熱門標(biāo)簽:新河科技智能外呼系統(tǒng)怎么樣 地圖標(biāo)注平臺怎么給錢注冊 福州人工外呼系統(tǒng)哪家強(qiáng) 注冊400電話申請 釘釘打卡地圖標(biāo)注 常州地圖標(biāo)注服務(wù)商 安裝電銷外呼系統(tǒng) 衡水外呼系統(tǒng)平臺 百度商鋪地圖標(biāo)注

前言

它的安裝和使用非常簡單,在編譯 PHP 時(shí)添加 --enable-sysvsem --enable-sysvshm --enable-sysvmsg 參數(shù)就可以,當(dāng)然 Windows 上無法使用。

今天我們?nèi)耘f使用上一篇文章的例子來介紹 PHP 內(nèi)部實(shí)現(xiàn)的進(jìn)程間通信,在了解它們的具體使用之前,先簡單介紹一下信號量、共享內(nèi)存、消息隊(duì)列的概念。

Unix System V IPC

信號量

信號量又稱為信號燈,它是用來協(xié)調(diào)不同進(jìn)程間的數(shù)據(jù)對象的,而最主要的應(yīng)用是共享內(nèi)存方式的進(jìn)程間通信。本質(zhì)上,信號量是一個(gè)計(jì)數(shù)器,它用來記錄對某個(gè)資源(如共享內(nèi)存)的存取狀況。

一般說來,為了獲得共享資源,進(jìn)程需要執(zhí)行下列操作:

1.獲取控制共享資源的信號量的值;

2.若值為正,進(jìn)程將信號量減1,進(jìn)程操作共享資源,進(jìn)入步驟4;

3.若值0,則拒絕進(jìn)程使用共享資源,進(jìn)程進(jìn)入睡眠狀態(tài),直至信號量值大于0后,進(jìn)程被喚醒,轉(zhuǎn)入步驟1;

4.當(dāng)進(jìn)程不再使用共享資源時(shí),將信號量值加1。如果此時(shí)有進(jìn)程正在睡眠等待此信號量,則喚醒此進(jìn)程;

信號量的使用可以類比為:

一個(gè)房間必須用鑰匙才能開門,有N把鑰匙放在門口,拿到鑰匙開門進(jìn)入房間,出來時(shí)將鑰匙放回并告知等待的人去取鑰匙開門。 此例中,鑰匙的數(shù)量限制了同一時(shí)間內(nèi)在房間的最大人數(shù)。房間即共享資源,鑰匙是信號量,而想進(jìn)入房間的人則是多個(gè)進(jìn)程。

信號量有二值和多值之分,一般共享資源都不允許多個(gè)進(jìn)程同時(shí)操作,多使用二值信號量。

共享內(nèi)存

為了在多個(gè)進(jìn)程間交換信息,內(nèi)核專門留出了一塊內(nèi)存區(qū),可以由需要訪問的進(jìn)程將其映射到自己的私有地址空間。進(jìn)程就可以直接讀寫這一塊內(nèi)存而不需要進(jìn)行數(shù)據(jù)的拷貝,從而大大提高效率。共享內(nèi)存可以比喻成一塊公用黑板,每個(gè)人都能在上面留言,寫東西。

到于共享內(nèi)存,我們一定要關(guān)心其生存周期:System V 共享內(nèi)存區(qū)域?qū)ο笫请S內(nèi)核持續(xù)的,除非顯式刪除共享內(nèi)存區(qū)域?qū)ο?,即使所有訪問共享內(nèi)存區(qū)域?qū)ο蟮倪M(jìn)程都已經(jīng)正常結(jié)束,共享內(nèi)存區(qū)域?qū)ο笕匀辉趦?nèi)核中存在,在內(nèi)核重新引導(dǎo)之前,對該共享內(nèi)存區(qū)域?qū)ο蟮娜魏胃膶懖僮鞫紝⒁恢北A簟?/p>

消息隊(duì)列

消息隊(duì)列是一條公共消息鏈,消息存取一般為先進(jìn)先出(FIFO),能實(shí)現(xiàn)多個(gè)進(jìn)程對消息的原子操作和異步存取。消息隊(duì)列的應(yīng)用十分廣泛,不光是進(jìn)程間通信,流程異步化、解耦方面也應(yīng)用廣泛。

消息隊(duì)列則相當(dāng)于一條流水線的一段,上層有多個(gè)工人把產(chǎn)品放入,下層有多個(gè)工人將產(chǎn)品取出加工。

本文的實(shí)現(xiàn)不包括消息隊(duì)列的使用,但對于消息隊(duì)列實(shí)現(xiàn)互斥鎖,這里給出一個(gè)思路:先給消息隊(duì)列初始化一個(gè)值,并發(fā)進(jìn)程競爭獲取此值,獲取到值的進(jìn)程進(jìn)行共享資源的處理,進(jìn)程不再共享資源時(shí),再將此值放入隊(duì)列,通過隊(duì)列的原子性來保證同時(shí)只有一個(gè)進(jìn)程訪問共享資源。

函數(shù)介紹

ftok

int ftok ( string $pathname, string $proj )

ftok將一個(gè)路徑 pathname 和一個(gè)項(xiàng)目名(必須為一個(gè)字符), 轉(zhuǎn)化成一個(gè)整數(shù)形的 System V IPC 鍵,本文介紹的 System V 通信方式都是基于此鍵來完成的,此ID 值也可以自己指定一個(gè) INT 型來確定,不必要使用 ftok 獲??;

需要注意的是:ftok 的結(jié)果是通過文檔的索引節(jié)點(diǎn)號來計(jì)算獲取的,而文件的刪除重建會導(dǎo)致其索引節(jié)點(diǎn)號變動,所以即使是相同的文件名,也可能會導(dǎo)致獲取到的 IPC 鍵不同,所以需要盡量保證 $pathname 不變動;

semaphore函數(shù)

resource sem_get ( int $key [, int $max_acquire = 1 [, int $perm = 0666 [, int $auto_release = 1 ]]] )

獲取或生成一個(gè)信號量標(biāo)識,我們注意其 max_acquire 值為 1,即保證同時(shí)只有一個(gè)進(jìn)程能獲取到它;auto_release 為 1 ,保證進(jìn)程在非正常情況退出時(shí)能釋放此信號量;

bool sem_acquire ( resource $sem_identifier [, bool $nowait = false ] )

bool sem_release ( resource $sem_identifier )

獲取/釋放一個(gè)信號量,注意獲取信號量的 $nowait 為false,使進(jìn)程在獲取信號量失敗后進(jìn)行進(jìn)程等待即可。

shared_memory函數(shù)

resource shm_attach ( int $key [, int $memsize [, int $perm = 0666 ]] )

bool shm_detach ( resource $shm_identifier )

連接/斷開 與 共享內(nèi)存段的連接 $memsize, 以字節(jié) byte 為單位;需要注意,在第一次使用 $key 連接內(nèi)存段創(chuàng)建時(shí),會初始化內(nèi)存大小和權(quán)限,后續(xù)再連接時(shí),這兩個(gè)參數(shù)會被忽略。

bool shm_put_var ( resource $shm_identifier , int $variable_key , mixed $variable )

mixed shm_get_var ( resource $shm_identifier , int $variable_key )

向共享內(nèi)存內(nèi)寫入或讀取一個(gè)變量,需要注意變量 key 只能是 int 型;

代碼實(shí)現(xiàn)

function getCycleIdFromSystemV($max, $min = 0) {
    $key = ftok('/tmp/cycleIdFromSystemV.tok', 'd');
    $var_key = 0;
    $sem_id = sem_get($key);
    $shm_id = shm_attach($key, 4096);

    if (sem_acquire($sem_id)) {
        $cycle_id = intval(shm_get_var($shm_id, $var_key));
        $cycle_id++;
        if ($cycle_id > $max) {
            $cycle_id = $min;
        }
        shm_put_var($shm_id, $var_key, $cycle_id);

        shm_detach($shm_id);
        sem_release($sem_id);

        return $cycle_id;
    }
    
    return false;
}

小結(jié)

我們發(fā)現(xiàn) PHP 對信號量和共享內(nèi)存封裝得很好,使用起來非常簡單。除此之外,PHP 的類庫 Sync 將常用 IPC 方法封裝成為類,能實(shí)現(xiàn)跨平臺的使用,感興趣的可以了解使用一下。

當(dāng)然進(jìn)程間通信的方式和種類有很多,本文介紹的 id 遞增只是很簡單的一種,不過,知道了方法,再去把這些方法改造成為其他種類也就不難了。

以上就是淺談并發(fā)處理PHP進(jìn)程間通信之System V IPC的詳細(xì)內(nèi)容,更多關(guān)于并發(fā)處理PHP進(jìn)程間通信之System V IPC的資料請關(guān)注腳本之家其它相關(guān)文章!

您可能感興趣的文章:
  • PHP下用Swoole實(shí)現(xiàn)Actor并發(fā)模型的方法
  • 淺談并發(fā)處理PHP進(jìn)程間通信之外部介質(zhì)
  • PHP+Redis鏈表解決高并發(fā)下商品超賣問題(實(shí)現(xiàn)原理及步驟)
  • 詳解PHP中curl_multi并發(fā)的實(shí)現(xiàn)
  • php多進(jìn)程并發(fā)編程防止出現(xiàn)僵尸進(jìn)程的方法分析
  • PHP高并發(fā)和大流量解決方案整理
  • PHP 并發(fā)場景的幾種解決方案
  • php多進(jìn)程模擬并發(fā)事務(wù)產(chǎn)生的問題小結(jié)
  • 淺談Swoole并發(fā)編程的魅力

標(biāo)簽:六安 柳州 白城 鶴崗 鷹潭 唐山 遼陽 克拉瑪依

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《淺談并發(fā)處理PHP進(jìn)程間通信之System V IPC》,本文關(guān)鍵詞  淺談,并發(fā),處理,PHP,進(jìn)程,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《淺談并發(fā)處理PHP進(jìn)程間通信之System V IPC》相關(guān)的同類信息!
  • 本頁收集關(guān)于淺談并發(fā)處理PHP進(jìn)程間通信之System V IPC的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章
    申扎县| 深水埗区| 峨眉山市| 错那县| 云林县| 北宁市| 清水河县| 大宁县| 叶城县| 西和县| 东乌珠穆沁旗| 棋牌| 肇州县| 天等县| 杨浦区| 乌审旗| 红河县| 西乌珠穆沁旗| 大庆市| 凤山县| 夹江县| 竹北市| 新闻| 万年县| 宁南县| 循化| 昌黎县| 怀安县| 新闻| 方山县| 金坛市| 青铜峡市| 宁明县| 东辽县| 韶关市| 富锦市| 沙坪坝区| 新乐市| 九江县| 泉州市| 乐昌市|