<?php

 for ($i=0;$i<10;$i++){//开10个进程

     $ret = pcntl_fork(); //生成进程

     if ($ret == 0){

         $redis = new Redis();

         $redis->connect('127.0.0.1',6379);

         while (true){ //做一个循环，让进程反复运行

             if ($redis->setnx('job',1)==1) {//加锁

                 if (count($redis->keys('webpub')) == 0){//集合中没有数据跳出继续循环

                     $redis->del('job'); //解锁

                     continue;

                 }

                 $getjob = $redis->zRange('webpub',0,0);//取出一个

                 var_dump($getjob);

                 //开启事务

                 $redis->multi();

                 //有序集合删除

                 $redis->zRem('webpub',$getjob[0]);//删除

                 $redis->del('job'); //解锁

                 //执行事务代码

                 $redis->exec();

                 //下列代表为要执行的任务

                 file_put_contents('./job/'.$getjob[0].'.html',$getjob[0]);

                 echo $getjob[0].' is done'.PHP_EOL;

                 sleep(1);

             }

         }

     }

 }