• 技术文章 >php教程 >php手册

    PHP程序级守护进程的实现与优化的使用概述

    2016-06-13 11:52:26原创644
    首先需要解释的是什么是守护进程。

    守护进程就是在后台一直运行的进程。比如我们启动的httpd,mysqld等进程都是常驻内存内运行的程序。

    针对需求进行分析:

    需求:有一个常驻队列messageQueue(假设在redis内存中),这个队列会有可能有请求不定期的往队列中增加元素。同时我们要求在队列中有元素的时候,按照队列顺序将元素pop出来,并进行处理(假设这个处理只是echo ‘test');

    解决方法:

    现在假设已经有了两个函数

    function oPopMessageQueue(){ …} //获取队列最后一个元素;

    function vDealElement($element) { …} 处理元素;

    要求写出一个守护程序,完成上面的需求。

    程序:

    好了,这个程序很容易想到,可以使用while循环来做

    复制代码 代码如下:


    while(true)
    {
    if( $element = oPopMessageQueue())
    {
    vDealElement($element);
    }
    }


    考虑1 : 这个程序如果一直跑的话已经可以满足上面的需求了.

    但是考虑到:1 用php进程跑有可能会由于各种情况(比如运行时间过长),进程挂了,这样程序就无法自动重连了.

    方法:使用cron

    我们在定时脚本中每10分钟起一个进程跑这个程序。

    然后设置这个程序的运行时间为10分钟,10分钟后自动取消,于是代码变成

    复制代码 代码如下:


    while(true)
    {
    if($element = oPopMessageQueue())
    {
    vCheckTimeLimit();
    vDealElement($elemnt);
    }
    }

    $timeStart = 0;
    function vCheckTimeLimit()
    {
    global $timeStart;
    if(empty($timeStart))
    {
    $timeStart = time();
    }

    if(time() - $timeStart > 60*10)
    {
    exit;
    }
    }


    考虑2,可能会有这种需求: 需要有随时让脚本暂停的功能:

    于是考虑使用文件来增加暂停功能

    复制代码 代码如下:


    while(true)
    {
    if($element = oPopMessageQueue())
    {
    vCheckTimeLimit();
    vCheckEnd();
    vDealElement($elemnt);
    }
    }


    function vCheckEnd()
    {
    if(file_exists("/home/JesephYe/end"))
    {
    exit;
    }
    }


    考虑3, 是否可以改成多线程的程序,让运行的效率更高?

    这个只要把cron的10分钟起一个进程的限制改成每1分钟起一个进程就好了

    这样能保证有10个线程在运行程序

    但是有一个基本要求是:oPopMessageQueue()是一个原子操作
    声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn核实处理。
    上一篇:用PHP实现浏览器点击下载TXT文档的方法详解 下一篇:php 深入理解strtotime函数的使用详解
    千万级数据并发解决方案

    相关文章推荐

    • PHP获取网卡地址的代码• 第十四节 命名空间 [14]• PHP 设置MySQL连接字符集的方法• 一天学会PHP~!• 正则表达式判断email和URL, 帮忙看看有没有要补充的.
    1/1

    PHP中文网