Swoole的webSocket部分服務端封裝

//封裝單例模式（三私一公）
class SwooleWebSocket
{
    private static $instance;       //存放當前對象屬性
    private static $server;         //存放webSocket對象屬性

    private $dir = 'swooleLogs/swoole.log';

    private function __construct() {
        //創建webSocket對象
        self::$server = new Swoole\WebSocket\Server('0.0.0.0', 9505);
        //設置參數
        self::$server->set([
            'daemonize'     => 1,               // 作為守護進程運行，需同時設置log_file
            'log_file'      => $this->dir,      // 指定標準輸出和錯誤日志文件
        ]);
        //注冊事件
        self::$server->on('open',[$this,'onOpen']);           //將當前類中的onOpen方法作為open的事件處理函數
        self::$server->on('message',[$this,'onMessage']);
        self::$server->on('close',[$this,'onClose']);
    }

    private function __clone() {
        // TODO: Implement __clone() method.
        trigger_error('Clone is not allowed !');
    }

    public static function getInstance() {
        if ( !(self::$instance instanceof self) ){
            self::$instance = new self();
        }
        return self::$instance;
    }

    //當前客戶端連接之后要執行的方法
    public function onOpen($server,$request) {
        echo "client: {$request->fd}\n";
        $server->push($request->fd, "hello, welcome\n");
    }

    //當客戶端向服務器發送消息時要執行的方法
    public function onMessage($server,$frame) {
        //處理業務邏輯
        echo "client: {$frame->data}\n";
        $server->push($frame->fd, "server: {$frame->data}");
    }

    //當客戶端和服務端斷開連接時要執行的方法
    public function onClose($server,$fd) {
        echo "client-{$fd} is closed\n";
    }

    //啟動webSocket方法
    public static function start(){
        self::$server->start();
    }
}

SwooleWebSocket::getInstance()->start();