初步整合

luoyanshou
1 parent 800e411f
Showing 3 changed files with 27 additions and 14 deletions
trunk/Swoole/Cli/Controller/Index/IndexController.class.php
trunk/Swoole/SwooleClient.php
trunk/Swoole/SwooleServer.php
@@ -14,7 +14,7 @@ class IndexController extends AbstractController
 {
     public function index()
     {
-        //print_r(C('MODULE_DENY_LIST'));
-        echo "Swoole 已启动。\n";
+        echo "Swoole work进程已成功启动。\n";
     }
-}
 \ No newline at end of file
+}
+
@@ -53,8 +53,15 @@ class SwooleClient
 }
 $client = new SwooleClient();
-$client->connect('127.0.0.1', 9501);
-$client->send('11223');
+$client->connect('127.0.0.1',9501);
-$recv = $client->recv();
-echo $recv;
 \ No newline at end of file
+$data = [
+    'class' => 'Cli\Controller\Index\Task',
+    'method' => 'index',
+    'data' => [
+        'name' => 'task',
+        'env' => 'dev'
+    ],
+];
+$data = json_encode($data);
+$client->send($data);
 \ No newline at end of file
@@ -16,8 +16,8 @@ class SwooleServer
             'port'             => $port,
             'env'              => 'dev', //环境 dev|test|prod
             'process_name'     => SWOOLE_TASK_NAME_PRE,  //swoole 进程名称
-            'worker_num'       => 4, //一般设置为服务器CPU数的1-4倍
-            'task_worker_num'  => 1,  //task进程的数量
+            'worker_num'       => 1, //一般设置为服务器CPU数的1-4倍
+            'task_worker_num'  => 2,  //task进程的数量
             'task_ipc_mode'    => 3,  //使用消息队列通信，并设置为争抢模式
             'task_max_request' => 10000,  //task进程的最大任务数
             'daemonize'        => 1, //以守护进程执行
@@ -101,13 +101,14 @@ class SwooleServer
      */
     public function onWorkerStart($serv, $workerId)
     {
-        if ($workerId >= $this->_setting['worker_num']) {
+        /*if ($workerId >= $this->_setting['worker_num']) {
             $this->setProcessName($this->_setting['process_name'] . '-task');
         } else {
             $this->setProcessName($this->_setting['process_name'] . '-event');
-        }
+        }*/
+
         // 开启调试模式 建议开发阶段开启 部署阶段注释或者设为false
-        define('APP_DEBUG', True);
+        define('APP_DEBUG', true);
         // 定义应用目录
         define('APP_PATH', SWOOLE_PATH . DIRECTORY_SEPARATOR . 'Swoole' . DIRECTORY_SEPARATOR);
         // 定义应用模式
@@ -208,9 +209,13 @@ class SwooleServer
      */
     public function onTask($serv, $task_id, $from_id, $data)
     {
-        $result = json_decode($data, true);
+        $data = json_decode($data, true);
         //用TP处理各种逻辑
-        $serv->finish($data);
+        $class = new $data['class']();
+        $method = $data['method'] ?? 'index';
+        $res = $class->$method($data['data']);
+
+        $serv->finish($res);
     }
     /**
@@ -238,4 +243,4 @@ class SwooleServer
             echo 'Date:' . date('Y-m-d H:i:s') . "\t swoole_server close[" . $fd . "]\n";
         }
     }
 -}
+}
 \ No newline at end of file