laravel結合workerman第二節 · 開發者必備的知識

## 1、安裝 GatewayWorker ~~~ composer require workerman/gateway-worker composer require workerman/gatewayclient ~~~ ## 2、創建 Workerman 啟動文件創建一個 artisan 命令行工具來啟動 Socket 服務端，在`app/Console/Commands`目錄下建立命令行文件。 ~~~ php artisan make:command GatewayworkerCommandAsr1 ~~~ ~~~ <?php namespace App\Console\Commands; use Illuminate\Console\Command; use Illuminate\Support\Facades\Log; use Workerman\Worker; use GatewayWorker\Gateway; use GatewayWorker\Register; use GatewayWorker\BusinessWorker; use App\Gatewayworker\Asr1Events; class GatewayworkerCommandAsr1 extends Command { /** 命令 php artisan workerman start * @var string */ protected $worker_name = 'asr1'; protected $gate_port = '5752'; protected $register_port = '5751'; protected $start_port = '5000'; protected $signature = ''; protected $description = 'Start a Workerman server'; public function __construct() { $this->signature = $this->worker_name. ' {action} {--d}'; parent::__construct(); } public function handle() { global $argv; if (!in_array($action = $this->argument('action'), ['start', 'stop', 'restart', 'status','reload'])) { $this->error('Error Arguments'); exit; } $argv[0] = $this->worker_name; $argv[1] = $action; $argv[2] = $this->option('d') ? '-d' : '';//該參數是以daemon（守護進程）方式啟動 $this->startRun(); } public function startRun(){ $this->startGateWay(); $this->startBusinessWorker(); $this->startRegister(); Worker::$pidFile = '/www/wwwroot/admin/vendor/workerman/'.$this->worker_name.'.pid'; Worker::runAll(); } private function startBusinessWorker() { $worker = new BusinessWorker(); $worker->name = $this->worker_name; $worker->count = 4; $worker->registerAddress = '127.0.0.1:'. $this->register_port; $worker->eventHandler = Asr1Events::class; } private function startGateWay() { $context = array( 'ssl' => array( // 使用絕對路徑 'local_cert' => '/www/wwwroot/admin/app/socket_exam/ssl/server.pem' , 'local_pk' => '/www/wwwroot/admin/app/socket_exam/ssl/server.key' , 'verify_peer' => false, 'allow_self_signed' => true ) ); $gateway = new Gateway("websocket://0.0.0.0:". $this->gate_port); //$gateway->transport = 'ssl'; $gateway->name = $this->worker_name; $gateway->count = 4; $gateway->lanIp = '127.0.0.1'; $gateway->registerAddress = '127.0.0.1:'. $this->register_port; $gateway->startPort = $this->start_port; // 心跳間隔 $gateway->pingInterval = 30; // 發給客戶端你的心跳數據 $gateway->pingData = '{"type":"ping"}'; } private function startRegister() { new Register('text://0.0.0.0:'. $this->register_port); } } ~~~ ## 3、創建事件監聽文件創建一個*app/Gatewayworker/Asr1Events.php*文件來監聽處理 workman 的各種事件。 ~~~ <?php namespace App\Gatewayworker; use App\Services\Trans\DialogTransService; use GatewayWorker\Lib\Gateway; use Illuminate\Support\Facades\Log; use Workerman\Protocols\Ws; use Workerman\Connection\AsyncTcpConnection; use Workerman\Timer; class Asr1Events { use AsrTrait; static $connectionToB; static $token = ''; static $header = []; public static function onWorkerStart($businessWorker) { // echo "onWorkerStart\r\n"; } public static function onWebSocketConnect(string $client_id, array $data){ self::$header = $data; } public static function onConnect($client_id){ // 連接到來后，定時10秒關閉這個鏈接，需要10秒內發認證并刪除定時器阻止關閉連接的執行 $auth_timer_id = Timer::add(10, function($client_id){ Gateway::closeClient($client_id); }, array($client_id), false); Gateway::updateSession($client_id, array('auth_timer_id' => $auth_timer_id)); /*客戶端連接到時候觸發*/ self::response($client_id,'',0,'','init'); //wss://api.aicloud.com/v10/asr/freetalk/cn_16k_common/utterance_stream?appkey=bc5d5437&access-token=3vo8NrO3TCKgvSXYQ7lKiQ self::$connectionToB = new AsyncTcpConnection('ws://api.aicloud.com'); self::$connectionToB->transport = 'ssl'; /*設置token*/ self::$token = DialogTransService::get_token_info(); } public static function onMessage($client_id, $data){ $option = self::setOption($data); usleep(10000); // 延遲 10 毫秒 self::$connectionToB->send($option); // 當收到消息時 self::$connectionToB->onMessage = function(AsyncTcpConnection $con, $result) use ($client_id) { $result_array = json_decode($result, true); if (isset($result_array['ERROR']) || isset($result_array['FATAL_ERROR'])){ $err_code = $result_array['errCode']; $err_msg = $result_array['errMessage']; self::response($client_id,'',$err_code,$err_msg,'end'); self::cloesWs($client_id); }/*錯誤*/ if (isset($result_array['respType']) && $result_array['respType'] == 'START'){ self::response($client_id,'',0,'','start'); }/*識別開始*/ if (isset($result_array['respType']) && $result_array['respType'] == 'RESULT'){ self::response( $client_id, $result_array['sentence']['result']['text'], 0, '', 'start' ); }/*結果*/ if (isset($result_array['respType']) && $result_array['respType'] == 'END'){ self::response($client_id,'',0,'','end'); self::cloesWs($client_id); }/*結束*/ }; self::$connectionToB->onError = function($connection, $code, $msg) use ($client_id) { self::cloesWs($client_id); }; self::$connectionToB->onClose = function($connection) use ($client_id){ self::cloesWs($client_id); }; self::$connectionToB->connect(); } public static function onClose($client_id) { self::response($client_id,'連接斷開',419); } private static function setOption($data){ $data_arr = json_decode($data, true); if ( isset($data_arr['endFlag']) && $data_arr['endFlag'] == false || isset($data_arr['endFlag']) && $data_arr['endFlag'] == true ){ self::setLang(); // BINARY_TYPE_BLOB為文本 // BINARY_TYPE_ARRAYBUFFER為二進制 self::$connectionToB->websocketType = Ws::BINARY_TYPE_BLOB; if ($data_arr['endFlag'] == false){ // 認證成功，刪除 10 關閉連接定的時器 Timer::del($_SESSION['auth_timer_id']); return json_encode([ 'command' => 'START', 'config' => [ 'audioFormat' => 'pcm_s16le_16k', 'vadTail' => 3000, //結尾 'vadEnd' => 3500, //中間 'vadHead' => 3000, //開始 'vadMaxSegment' => 60 ], 'extraInfo' => '', 'recordId' => '', 'userId' => '', ],JSON_UNESCAPED_UNICODE); }else{ return json_encode([ 'command' => 'end', 'cancel' => false, ], JSON_UNESCAPED_UNICODE); } }else{ self::$connectionToB->websocketType = Ws::BINARY_TYPE_ARRAYBUFFER; return $data; } } private static function setLang(){ $lang = 'zh'; if (isset(self::$header['server']['REQUEST_URI'])){ $lang = explode('_', self::$header['server']['REQUEST_URI'])[1]; } if ($lang == 'zh'){ self::$connectionToB->_remoteURI = '/v10/asr/freetalk/cn_16k_common/utterance_stream?appkey=bc5d5437&access-token='. self::$token; }elseif($lang == 'ug'){ self::$connectionToB->_remoteURI = '/v10/asr/freetalk/ug_16k_common/utterance_stream?appkey=bc5d5437&access-token='. self::$token; }else{ self::$connectionToB->_remoteURI = '/v10/asr/freetalk/kk_16k_common/utterance_stream?appkey=bc5d5437&access-token='. self::$token; } } } ~~~ ### 命令 php artisan asr1 stop || start || start --d