介紹EasySwoole安裝使用

<?phpnamespace AppHttpController;use EasySwooleHttpAbstractInterfaceController;class Index extends Controller{  public function hello(){         $this->response()->write('hello world');     }      public function index()     {         $file = EASYSWOOLE_ROOT.'/vendor/easyswoole/easyswoole/src/Resource/Http/welcome.html';         if(!is_file($file)){             $file = EASYSWOOLE_ROOT.'/src/Resource/Http/welcome.html';//歡迎頁面         }         $this->response()->write(file_get_contents($file));     }      protected function actionNotFound(?string $action)     {         $this->response()->withStatus(404);         $file = EASYSWOOLE_ROOT.'/vendor/easyswoole/easyswoole/src/Resource/Http/404.html';         if(!is_file($file)){             $file = EASYSWOOLE_ROOT.'/src/Resource/Http/404.html';         }         $this->response()->write(file_get_contents($file));     }}

<?phpnamespace EasySwooleEasySwoole;use EasySwooleEasySwooleSwooleEventRegister;use EasySwooleEasySwooleAbstractInterfaceEvent;use EasySwooleHttpRequest;use EasySwooleHttpResponse;class EasySwooleEvent implements Event{      public static function initialize()     {         // TODO: Implement initialize() method.         date_default_timezone_set('Asia/Shanghai');     }      public static function mainServerCreate(EventRegister $register)     {         // TODO: Implement mainServerCreate() method.         $register->set(EventRegister::onMessage,function (swoole_websocket_server $server, swoole_websocket_frame $frame){             var_dump($frame);         });     }      public static function onRequest(Request $request, Response $response): bool    {         // TODO: Implement onRequest() method.         return true;     }      public static function afterRequest(Request $request, Response $response): void    {         // TODO: Implement afterAction() method.     }}

public static function mainServerCreate(EventRegister $register): void{     /**      * **************** websocket控制器 **********************      */     // 創(chuàng)建一個 Dispatcher 配置     $conf = new EasySwooleSocketConfig();     // 設(shè)置 Dispatcher 為 WebSocket 模式     $conf->setType(EasySwooleSocketConfig::WEB_SOCKET);     // 設(shè)置解析器對象     $conf->setParser(new WebSocketParser());     // 創(chuàng)建 Dispatcher 對象 并注入 config 對象     $dispatch = new Dispatcher($conf);     // 給server 注冊相關(guān)事件 在 WebSocket 模式下  on message 事件必須注冊 并且交給 Dispatcher 對象處理     $register->set(EventRegister::onMessage, function (swoole_websocket_server $server, swoole_websocket_frame $frame) use ($dispatch) {         $dispatch->dispatch($server, $frame->data, $frame);     });}

namespace AppWebSocket;use EasySwooleSocketAbstractInterfaceParserInterface;use EasySwooleSocketClientWebSocket;use EasySwooleSocketBeanCaller;use EasySwooleSocketBeanResponse;/**  * Class WebSocketParser  *  * 此類是自定義的 websocket 消息解析器  * 此處使用的設(shè)計是使用 json string 作為消息格式  * 當客戶端消息到達服務(wù)端時，會調(diào)用 decode 方法進行消息解析  * 會將 websocket 消息 轉(zhuǎn)成具體的 Class -> Action 調(diào)用 并且將參數(shù)注入  *  * @package AppWebSocket  */class WebSocketParser implements ParserInterface{     /**      * decode      * @param  string         $raw    客戶端原始消息      * @param  WebSocket      $client WebSocket Client 對象      * @return Caller         Socket  調(diào)用對象      */     public function decode($raw, $client) : ? Caller    {         // 解析 客戶端原始消息         $data = json_decode($raw, true);         if (!is_array($data)) {             echo "decode message error!  ";             return null;         }          // new 調(diào)用者對象         $caller =  new Caller();         /**          * 設(shè)置被調(diào)用的類 這里會將ws消息中的 class 參數(shù)解析為具體想訪問的控制器          * 如果更喜歡 event 方式 可以自定義 event 和具體的類的 map 即可          * 注 目前 easyswoole 3.0.4 版本及以下 不支持直接傳遞 class string 可以通過這種方式          */         $class = 'AppWebSocket'. ucfirst($data['class'] ?? 'Index');         $caller->setControllerClass($class);          // 提供一個事件風格的寫法//         $eventMap = [//             'index' => Index::class//         ];//         $caller->setControllerClass($eventMap[$data['class']] ?? Index::class);          // 設(shè)置被調(diào)用的方法         $caller->setAction($data['action'] ?? 'index');         // 檢查是否存在args         if (!empty($data['content'])) {             // content 無法解析為array 時 返回 content => string 格式             $args = is_array($data['content']) ? $data['content'] : ['content' => $data['content']];         }          // 設(shè)置被調(diào)用的Args         $caller->setArgs($args ?? []);         return $caller;     }     /**      * encode      * @param  Response     $response Socket Response 對象      * @param  WebSocket    $client   WebSocket Client 對象      * @return string             發(fā)送給客戶端的消息      */     public function encode(Response $response, $client) : ? string    {         /**          * 這里返回響應(yīng)給客戶端的信息          * 這里應(yīng)當只做統(tǒng)一的encode操作 具體的狀態(tài)等應(yīng)當由 Controller處理          */         return $response->getMessage();     }}

<?php/**  * Created by PhpStorm.  * User: Apple  * Date: 2018/11/1 0001  * Time: 14:42  */namespace AppWebSocket;use EasySwooleEasySwooleServerManager;use EasySwooleEasySwooleTaskTaskManager;use EasySwooleSocketAbstractInterfaceController;/**  * Class Index  *  * 此類是默認的 websocket 消息解析后訪問的 控制器  *  * @package AppWebSocket  */class Index extends Controller{     function hello()     {         $this->response()->setMessage('call hello with arg:'. json_encode($this->caller()->getArgs()));     }      public function who(){         $this->response()->setMessage('your fd is '. $this->caller()->getClient()->getFd());     }      function delay()     {         $this->response()->setMessage('this is delay action');         $client = $this->caller()->getClient();          // 異步推送, 這里直接 use fd也是可以的         TaskManager::getInstance()->async(function () use ($client){             $server = ServerManager::getInstance()->getSwooleServer();             $i = 0;             while ($i < 5) {                 sleep(1);                 $server->push($client->getFd(),'push in http at '. date('H:i:s'));                 $i++;             }         });     }}