# Process 用戶進程 ## 創建一個用戶進程 ```php use Server\Components\Process\Process; class MyProcess extends Process { public function start($process) { } public function getData() { return '123'; } } ``` 繼承Process類，實現start方法。 可以在start方法中創建異步連接池，或者定時器，或者異步客戶端。 ```php if ($this->config->get('redis.enable', true)) { get_instance()->addAsynPool('redisPool', new RedisAsynPool($this->config, $this->config->get('redis.active'))); } if ($this->config->get('mysql.enable', true)) { get_instance()->addAsynPool('mysqlPool', new MysqlAsynPool($this->config, $this->config->get('mysql.active'))); } ``` ## 啟動進程 在AppServer中添加進程 ```php /** * 用戶進程 */ public function startProcess() { parent::startProcess(); ProcessManager::getInstance()->addProcess(MyProcess::class,true,1); //可以多次添加 ProcessManager::getInstance()->addProcess(MyProcess::class,true,2); } ``` 如果需要協程的支持請將第二個參數設置為true，默認支持協程。 如果相同的類名的進程需要設置額外的名稱。 ``` addProcess($class_name, $needCoroutine = true, $name = '') ``` ## 進程間IPC SD為進程間的IPC提供了封裝 ``` function getRpcCall($class_name, $oneWay = false, $name = '') ``` 用法很簡單 ### IPC ``` $data = yield ProcessManager::getInstance()->getRpcCall(SDHelpProcess::class)->getData(ConsulHelp::DISPATCH_KEY); ``` ### oneway 這是一個單通道的訪問 ``` ProcessManager::getInstance()->getRpcCall(ClusterProcess::class, true)->my_dispatchEvent($type, $data); ```