bridgeReload

scripts/crontab/push/runRedisBase.php

@@ -5,11 +5,9 @@
  * Date: 2019/1/17 0017
  * Time: 下午 2:29
  */
-define("APPLICATION_PATH", realpath(dirname(__FILE__) . '/../../../')); //指向public的上一级
+require APPLICATION_PATH . '/scripts/crontab/common.php';
+error_reporting(E_ALL ^ E_NOTICE);
 function callback($instance,$channelName,$message){
-    define("APPLICATION_PATH", realpath(dirname(__FILE__) . '/../../../')); //指向public的上一级
-    require APPLICATION_PATH . '/scripts/crontab/common.php';
-    error_reporting(E_ALL ^ E_NOTICE);
     try{
         $message=json_decode($message,true);
         $callInstance=$message['className']::getInstance(\Our\DbNameConst::masterDBConnectName);
@@ -30,8 +28,11 @@ function callback($instance,$channelName,$message){
     }catch(Exception $ex){
         echo $ex->getMessage();
     }
+    pcntl_signal_dispatch();
+    if (Signal::get() == SIGHUP) {
+        Signal::reset();
+    }
 }
-require APPLICATION_PATH . '/scripts/crontab/common.php';
 $conf = \Yaf\Registry::get('config')->get('redis.database.params');
 $redisPublishName=\Yaf\Registry::get('config')->get('redis.redisPublishName');
 $redis=new Redis();

scripts/crontab/push/runRedisCanReload.php

@@ -37,17 +37,17 @@ class Test extends Logger
 
     public function run()
     {
-         require APPLICATION_PATH . '/scripts/crontab/push/runRedisBase.php';
-
-//        while (true) {
-//            pcntl_signal_dispatch();
-//            printf(".123");
-//            sleep(1);
-//            if (Signal::get() == SIGHUP) {
-//                Signal::reset();
-//                break;
-//            }
-//        }
+         include APPLICATION_PATH . '/scripts/crontab/push/runRedisBase.php';
+
+        while (true) {
+            pcntl_signal_dispatch();
+            printf(".123");
+            sleep(1);
+            if (Signal::get() == SIGHUP) {
+                Signal::reset();
+                break;
+            }
+        }
         printf("\n");
     }
 }