浅谈并发处理PHP进程间通信之System V IPC

前言

它的安装和使用非常简单，在编译 PHP 时添加 --enable-sysvsem --enable-sysvshm --enable-sysvmsg 参数就可以，当然 Windows 上无法使用。

今天我们仍旧使用上一篇文章的例子来介绍 PHP 内部实现的进程间通信，在了解它们的具体使用之前，先简单介绍一下信号量、共享内存、消息队列的概念。

Unix System V IPC

信号量

信号量又称为信号灯，它是用来协调不同进程间的数据对象的，而最主要的应用是共享内存方式的进程间通信。本质上，信号量是一个计数器，它用来记录对某个资源（如共享内存）的存取状况。

一般说来，为了获得共享资源，进程需要执行下列操作：

1.获取控制共享资源的信号量的值；

2.若值为正，进程将信号量减1，进程操作共享资源，进入步骤4；

3.若值0，则拒绝进程使用共享资源，进程进入睡眠状态，直至信号量值大于0后，进程被唤醒，转入步骤1；

4.当进程不再使用共享资源时，将信号量值加1。如果此时有进程正在睡眠等待此信号量，则唤醒此进程；

信号量的使用可以类比为：

一个房间必须用钥匙才能开门，有N把钥匙放在门口，拿到钥匙开门进入房间，出来时将钥匙放回并告知等待的人去取钥匙开门。 此例中，钥匙的数量限制了同一时间内在房间的最大人数。房间即共享资源，钥匙是信号量，而想进入房间的人则是多个进程。

信号量有二值和多值之分，一般共享资源都不允许多个进程同时操作，多使用二值信号量。

共享内存

为了在多个进程间交换信息，内核专门留出了一块内存区，可以由需要访问的进程将其映射到自己的私有地址空间。进程就可以直接读写这一块内存而不需要进行数据的拷贝，从而大大提高效率。共享内存可以比喻成一块公用黑板，每个人都能在上面留言，写东西。

到于共享内存，我们一定要关心其生存周期：System V 共享内存区域对象是随内核持续的，除非显式删除共享内存区域对象，即使所有访问共享内存区域对象的进程都已经正常结束，共享内存区域对象仍然在内核中存在，在内核重新引导之前，对该共享内存区域对象的任何改写操作都将一直保留。

消息队列

消息队列是一条公共消息链，消息存取一般为先进先出（FIFO），能实现多个进程对消息的原子操作和异步存取。消息队列的应用十分广泛，不光是进程间通信，流程异步化、解耦方面也应用广泛。

消息队列则相当于一条流水线的一段，上层有多个工人把产品放入，下层有多个工人将产品取出加工。

本文的实现不包括消息队列的使用，但对于消息队列实现互斥锁，这里给出一个思路：先给消息队列初始化一个值，并发进程竞争获取此值，获取到值的进程进行共享资源的处理，进程不再共享资源时，再将此值放入队列，通过队列的原子性来保证同时只有一个进程访问共享资源。

函数介绍

ftok

int ftok ( string $pathname, string $proj )

ftok将一个路径 pathname 和一个项目名（必须为一个字符）， 转化成一个整数形的 System V IPC 键，本文介绍的 System V 通信方式都是基于此键来完成的，此ID 值也可以自己指定一个 INT 型来确定，不必要使用 ftok 获取；

需要注意的是：ftok 的结果是通过文档的索引节点号来计算获取的，而文件的删除重建会导致其索引节点号变动，所以即使是相同的文件名，也可能会导致获取到的 IPC 键不同，所以需要尽量保证 $pathname 不变动；

semaphore函数

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

获取或生成一个信号量标识，我们注意其 max_acquire 值为 1，即保证同时只有一个进程能获取到它；auto_release 为 1 ，保证进程在非正常情况退出时能释放此信号量；

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

bool sem_release ( resource $sem_identifier )

获取/释放一个信号量，注意获取信号量的 $nowait 为false，使进程在获取信号量失败后进行进程等待即可。

shared_memory函数

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

bool shm_detach ( resource $shm_identifier )

连接/断开 与 共享内存段的连接 $memsize， 以字节 byte 为单位；需要注意，在第一次使用 $key 连接内存段创建时，会初始化内存大小和权限，后续再连接时，这两个参数会被忽略。

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

mixed shm_get_var ( resource $shm_identifier , int $variable_key )

向共享内存内写入或读取一个变量，需要注意变量 key 只能是 int 型；

代码实现

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;
}

小结

我们发现 PHP 对信号量和共享内存封装得很好，使用起来非常简单。除此之外，PHP 的类库 Sync 将常用 IPC 方法封装成为类，能实现跨平台的使用，感兴趣的可以了解使用一下。

当然进程间通信的方式和种类有很多，本文介绍的 id 递增只是很简单的一种，不过，知道了方法，再去把这些方法改造成为其他种类也就不难了。

以上就是浅谈并发处理PHP进程间通信之System V IPC的详细内容，更多关于并发处理PHP进程间通信之System V IPC的资料请关注我们其它相关文章！

赞 (0)

相关推荐

  • PHP基于进程控制函数实现多线程

    php有一组进程控制函数(编译时需要–enable-pcntl与posix扩展),使得php能在nginx系统中实现跟c一样的创建子进程.使用exec函数执行程序.处理信号等功能. CentOS 6 下yum安装php的,默认是不安装pcntl的,因此需要单独编译安装,首先下载对应版本的php,解压后 cd php-version/ext/pcntl phpize ./configure && make && make install cp /usr/lib/php/mod

  • 一文看懂PHP进程管理器php-fpm

    一文看懂PHP进程管理器php-fpm

    php-fpm是什么 php-fpm是PHP的一个进程管理器.php下面的众多work进程皆有php-fpm进程管理器管理. php-fpm的工作原理 php-fpm全名是PHP FastCGI进程管理器.php-fpm启动后会先读php.ini,然后再读相应的conf配置文件,conf配置可以覆盖php.ini的配置. 启动php-fpm之后,会创建一个master进程,监听9000端口(可配置),master进程又会根据fpm.conf/www.conf去创建若干子进程,子进程用于处理实际的

  • PHP 进程池与轮询调度算法实现多任务的示例代码

    PHP 进程池与轮询调度算法实现多任务的示例代码

    phper 请了解进程调度策略,CPU 时间片,进程控制[创建,销毁,回收,进程信号]与及进程运行流程和基本的进程组,信号中断原理,以及进程之间的关系. 关于进程的更多内容可参考本人前面撸过的文章或是百度了解. 进程的通信: 匿名管道,命名管道,消息队列,内存共享,socketpair 请自行撸代码测试哦 进程的调度算法: 轮询,随机分发,计分板等策略或是搞个优先极或是队列,或是堆栈等基本的算法[自己去发挥哦] 进程池: 撸过 tcp 的话应该知道要能处理多个客户端,就得用 IO 复用技术[事件

  • 浅谈并发处理PHP进程间通信之外部介质

    进程间通信 进程间通信,指至少两个进程或线程间传送数据或信号的一些技术或方法.进程是计算机系统分配资源的最小单位(严格说来是线程).每个进程都有自己的一部分独立的系统资源,彼此是隔离的.为了能使不同的进程互相访问资源并进行协调工作,才有了进程间通信. 根据定义可知,要进行进程间通信,我们需要解决两个问题: 互相访问:消息传输和暂时存储介质选择问题: 协调工作:消息的存取冲突问题: 文章介绍的中心就是围绕着这么两点来说的, 为了更使文章更简明,这边以之前在公司做的一个需求为例: 需要一个循环ID生

  • php进程(线程)通信基础之System V共享内存简单实例分析

    php进程(线程)通信基础之System V共享内存简单实例分析

    本文实例讲述了php进程(线程)通信基础之System V共享内存.分享给大家供大家参考,具体如下: PHP默认情况没有开启功能,要支持该功能在编译PHP的时候要加入下面几个选项  System V消息,--enable-sysvmsg   System V信号量支持,--enable-sysvsem  System V共享内存支持,--enable-sysvshm PHP还挺shmop共享内存,在编译的时候开启 --enable-shmop System V共享内存的相关函数: 1: 创建信号

  • php 多进程编程父进程的阻塞与非阻塞实例分析

    php 多进程编程父进程的阻塞与非阻塞实例分析

    本文实例讲述了php 多进程编程父进程的阻塞与非阻塞.分享给大家供大家参考,具体如下: php中进程的阻塞,主要是父进程等待子进程退出. 1.php代码如下: <?php //定义进程数量 define('FORK_NUMS', 5); //用于保存进程pid $pids = array(); //我们创建5个子进程 for ($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if ($pids[$i] == -1) { die

  • PHP如何限制定时任务的进程数量

    前言 现在的工作中,经常要写一些脚本做一些异步的操作. 一般是大量的数据修改,或者解决部分并发问题. 为了能够稳定的做好数据处理,一般情况下会用定时脚本的方式. 那么问题来了. 可能存在的问题 当我们处理大量数据的时候,脚本的执行时间可能很长,或者重复处理某条数据(写错的情况下). 为了避免数据的重复处理.运行脚本过多导致服务器压力过大等问题,我们需要限制脚本的运行数量. 如何做 思路一 查询某种标识的进程数量,如果超过一定数量,则直接退出,不处理. 思路二 记录每次的PID,可以使用 文件.r

  • php实现的简单多进程服务器类完整示例

    本文实例讲述了php实现的简单多进程服务器类.分享给大家供大家参考,具体如下: php写的一个简单的多进程服务器. <?php class server { public $port; public $ip; protected $server; public function __construct($ip = '0.0.0.0', $port) { $this->ip = $ip; $this->port = $port; $this->createSocket(); //创建

  • php 的多进程操作实践案例分析

    本文实例讲述了php 的多进程操作.分享给大家供大家参考,具体如下: php的多进程处理依赖于pcntl扩展,通过pcntl_fork创建子进程来进行并行处理. 例1如下: <?php $pid = pcntl_fork(); if($pid == -1) { //错误处理:创建子进程失败时返回-1. die('fork error'); } else if ($pid) { //父进程会得到子进程号,所以这里是父进程执行的逻辑 echo "parent \n"; //等待子进程

  • 浅谈并发处理PHP进程间通信之System V IPC

    前言 它的安装和使用非常简单,在编译 PHP 时添加 --enable-sysvsem --enable-sysvshm --enable-sysvmsg 参数就可以,当然 Windows 上无法使用. 今天我们仍旧使用上一篇文章的例子来介绍 PHP 内部实现的进程间通信,在了解它们的具体使用之前,先简单介绍一下信号量.共享内存.消息队列的概念. Unix System V IPC 信号量 信号量又称为信号灯,它是用来协调不同进程间的数据对象的,而最主要的应用是共享内存方式的进程间通信.本质上,

  • 浅谈Linux进程间通信方式及优缺点

    1)管道 管道分为有名管道和无名管道 无名管道是一种半双工的通信方式,数据只能单向流动,而且只能在具有亲缘关系的进程间使用.进程的亲缘关系一般指的是父子关系.无明管道一般用于两个不同进程之间的通信.当一个进程创建了一个管道,并调用fork创建自己的一个子进程后,父进程关闭读管道端,子进程关闭写管道端,这样提供了两个进程之间数据流动的一种方式. 有名管道也是一种半双工的通信方式,但是它允许无亲缘关系进程间的通信. 2)信号量 信号量是一个计数器,可以用来控制多个线程对共享资源的访问.,它不是用于交

  • 浅谈Android中Service的注册方式及使用

    Service通常总是称之为"后台服务",其中"后台"一词是相对于前台而言的,具体是指其本身的运行并不依赖于用户可视的UI界面,因此,从实际业务需求上来理解,Service的适用场景应该具备以下条件: 1.并不依赖于用户可视的UI界面(当然,这一条其实也不是绝对的,如前台Service就是与Notification界面结合使用的): 2.具有较长时间的运行特性. 1.Service AndroidManifest.xml 声明 一般而言,从Service的启动方式上

  • 浅谈多线程_让程序更高效的运行

    浅谈多线程_让程序更高效的运行

    Java Thread 的一些认识: Java是抢占式线程,一个线程就是进程中单一的顺序控制流,单个进程可以拥有多个并发任务,其底层是切分CPU时间,多线程和多任务往往是使用多处理器系统的最合理方式 进程可以看作一个程序或者一个应用:线程是进程中执行的一个任务,多个线程可以共享资源 一个Java 应用从main 方法开始运行,main 运行在一个线程内,也被称为 "主线程",Runnable也可以理解为Task (任务) JVM启动后,会创建一些守护线程来进行自身的常规管理(垃圾回收,

  • 浅谈oracle SCN机制

    SCN(System Change Number)作为oracle中的一个重要机制,在数据恢复.Data Guard.Streams复制.RAC节点间的同步等各个功能中起着重要作用.理解SCN的运作机制,可以帮助你更加深入地了解上述功能. 在理解SCN之前,我们先看下oracle事务中的数据变化是如何写入数据文件的: 1.事务开始: 2.在buffer cache中找到需要的数据块,如果没有找到,则从数据文件中载入buffer cache中: 3.事务修改buffer cache的数据块,该数据

  • 浅谈JS正则表达式的RegExp对象和括号的使用

    RegExp对象的创建: 常规的正则表达式的创建可用直接量,即斜杠 "/" 括起来的字符.但在要求参数变化的环境下,RegExp()构造函数是更好的选择: var reg1 = /'\w+'/g; var reg2 = new RegExp('\'\\w+\'','g'); 对比两种创建方式,RegExp中的第一个参数为要创建的正则字符串,一方面注意,因为不是直接量的表示形式,因此不用斜杠" / "括起来了:而是字符串中必须要对引号" ' "和转

  • 浅谈Sublime Text 3运行JavaScript控制台

    Node.js是一个基于Chrome JavaScript运行时建立的平台,小巧方便搭建.运行的端口可以在浏览器上运行,显示效果,但每次用浏览器也挺麻烦,我们这里讲的是在sublime text2中配置,是的js在sublimetext2中运行,再也不用切换到浏览器了. 1.首先安装node.js,直接去官网下载,然后安装,点击下一步就好了,如果需要更改安装路径,选择好安装路径即可.安装完以后,运行  node -v 如果显示出版本号,则说明安装成功. 2.这时候,我们还是不可以运行js文件的,

  • 浅谈Java多线程处理中Future的妙用（附源码）

    java 中Future是一个未来对象,里面保存这线程处理结果,它像一个提货凭证,拿着它你可以随时去提取结果.在两种情况下,离开Future几乎很难办.一种情况是拆分订单,比如你的应用收到一个批量订单,此时如果要求最快的处理订单,那么需要并发处理,并发的结果如果收集,这个问题如果自己去编程将非常繁琐,此时可以使用CompletionService解决这个问题.CompletionService将Future收集到一个队列里,可以按结果处理完成的先后顺序进队.另外一种情况是,如果你需要并发去查询一

  • 浅谈linux几种定时函数的使用

    在程序开发过程中,我们时不时要用到一些定时器,通常如果时间精度要求不高,可以使用sleep,uslepp函数让进程睡眠一段时间来实现定时, 前者单位为秒(s),后者为微妙(us):但有时候我们又不想让进程睡眠阻塞在哪儿,我们需要进程正常执行,当到达规定的时间时再去执行相应的操作, 在linux下面我们一般使用alarm函数跟setitimer函数来实现定时功能: 下面对这两个函数进行详细分析: (1)alarm函数 alarm也称为闹钟函数,它可以在进程中设置一个定时器,当定时器指定的时间到时,

随机推荐