消息队列feed程序实现中的问题

时间：2022-04-06 17:31:39

因项目需要, 构建了很多消息队列还排队处理任务, 相应的每个队列也配有一个feed程序来feed消息

一开始很简单地这样做:

        while (true){

            $msg = $query->bPop();

            //消息处理程序

        }

这种方式下feed程序一开始运行就永远不会退出,  乍看没有问题, 但存在一个问题, 一旦消息处理程序发生变化, 如果不手动kill进程后重启进程, 改动就不会被加载.

另: 据说PHP进程运行过久就会产生垃圾难以回收, 需要终止进程来回收进程垃圾.

所以我讲feed程序都改成以下方式:

        set_time_limit ( 0 );

        $startTime = time ();

        $maxDealNum = 1000; // 最大处理次数

        $maxLifeTime = 12 * 3600; // 最大生命周期时长

        $dealedNum = 0;

        while ( true ) {

            $this->load->model ( 'item/category_frequently' )->bDealMsg ();

            $dealedNum ++;

            //超过最大处理次数或处理时长时程序退出, 以守护进程重新启动的方式清理内存垃圾

            if ($dealedNum > $maxDealNum || (time () - $startTime) > $maxLifeTime) {

                return;

            }

        }

每处理完一个消息后计数, 以及记录feed程序开始执行时间, 如果2者都超过某一个阙值就让程序退出, 这样可以避免单一的长时间饥饿或执行频繁情景下进程不会退出. 而消息处理程序发生改变的时候也可以在可预期时间内被重新加载

相关文章