mr.wen 整理代码

Author: 陈家文

Src/AsyncLogHandle/AsyncLogObserver.php

@@ -11,9 +11,11 @@ interface AsyncLogObserver
 {
     /**
      * 绑定处理方法
+     * @param $context
+     * @return mixed
      * @Author jiaWen.chen
      */
-    public function onHandle();
+    public function onHandle($context);
 
     /**
      * 订阅消息内容

Src/AsyncLogHandle/AsyncLogSubject.php

@@ -80,14 +80,13 @@ public function handle()
 
             // 2.1 格式化数据结构
             $this->_handleBefore(fgets($fp, 1024 * 1024 * 1024), $lineNum++);
-
             // 2.2 判断是否已经执行完毕
             if (empty($this->log_deal['deal_contain'])) {
                 $this->_dealSuccessContain();
                 Log::notice("执行定时任务，读取日志文件来完成订阅与发布，执行完毕！！！");
                 break;
             }
-
+            dump('执行定时任务，读取日志文件来完成订阅与发布,正在执行第'.$this->log_deal['deal_contain']['line_num'].'行...');
 
             // 2.3 执行对应的message事物。
             $observerExists = $observerResult = null;
@@ -97,7 +96,7 @@ public function handle()
                     $observerExists = true;
                 }
             }
-            dump($observerResult);
+
             if (empty($observerExists)) {
                 // 2.4 如果不存在这个观察者
                 $this->_dealSuccessContain();
@@ -127,12 +126,10 @@ public function handle()
                     ]);
             } else if ($observerResult === true) {
                 // 2.7 执行成功
-//                 dump($this->log_deal['success_contain']);
                 $this->log_deal['success_contain'] = [
                     'start_line' =>  $this->log_deal['success_contain']['start_line']?:$this->log_deal['deal_contain']['line_num'],
                     'end_line' => $this->log_deal['deal_contain']['line_num']
                 ];
-//                dump($this->log_deal['success_contain']);
             }
         }
     }

example/AsyncLogCommand.php

@@ -42,7 +42,6 @@ public function handle()
         $asyncLogSubject->addObserver(new AsyncLogObserverOfNumA());
         $asyncLogSubject->addObserver(new AsyncLogObserverOfNumB());
         $asyncLogSubject->handle();
-//        dd($asyncLogSubject);
     }
 
 }

example/AsyncLogObserverOfNumA.php

@@ -6,8 +6,11 @@
 
 class AsyncLogObserverOfNumA extends AsyncLogObserverOfGenerator
 {
-    public function onHandle()
+    public function onHandle($context)
     {
-       return false;
+        // TODO: Implement onHandle() method.
+
+        dump($context);
+        return true;
     }
 }

example/AsyncLogObserverOfNumB.php

@@ -6,8 +6,10 @@
 
 class AsyncLogObserverOfNumB extends AsyncLogObserverOfGenerator
 {
-    public function onHandle()
+    public function onHandle($context)
     {
-       return true;
+        dump($context);
+
+        return true;
     }
 }