摘要：前言即將迎來最新版本，針對目前越來越流行，也推出了最新的擴(kuò)展。介紹即將推出的，已經(jīng)適配并推出，并且默認(rèn)適配了。和版本在使用方法上面有些許不同。其中的第一個(gè)參數(shù)和的第一個(gè)參數(shù)一致，作為事件名稱。

ThinkPHP即將迎來最新版本6.0，針對目前越來越流行Swoole，thinkphp也推出了最新的擴(kuò)展think-swoole 3.0。

即將推出的tp6.0，已經(jīng)適配swoole.并推出think-swoole 3.0，并且默認(rèn)適配了socketio。和2.0版本在使用方法上面有些許不同。

Websocket 繼承與Http，進(jìn)行websocket連接之前需要一次HTTP請求，如果當(dāng)期地址支持websocket則返回101，然后進(jìn)行連接。也就是說并不是我的服務(wù)支持websocket后，請求每個(gè)連接地址都可以進(jìn)行websocket連接，而是需要預(yù)先適配才可以連接。

如果要使用websocket需要在配置中啟用,將websocket下的enable設(shè)置為true

 "server"           => [
        "host"      => "0.0.0.0", // 監(jiān)聽地址
        "port"      => 808, // 監(jiān)聽端口
        "mode"      => SWOOLE_PROCESS, // 運(yùn)行模式 默認(rèn)為SWOOLE_PROCESS
        "sock_type" => SWOOLE_SOCK_TCP, // sock type 默認(rèn)為SWOOLE_SOCK_TCP
        "options"   => [
            "pid_file"              => runtime_path() . "swoole.pid",
            "log_file"              => runtime_path() . "swoole.log",
            "daemonize"             => false,
            // Normally this value should be 1~4 times larger according to your cpu cores.
            "reactor_num"           => swoole_cpu_num(),
            "worker_num"            => swoole_cpu_num(),
            "task_worker_num"       => 4,//swoole_cpu_num(),
            "enable_static_handler" => true,
            "document_root"         => root_path("public"),
            "package_max_length"    => 20 * 1024 * 1024,
            "buffer_output_size"    => 10 * 1024 * 1024,
            "socket_buffer_size"    => 128 * 1024 * 1024,
            "max_request"           => 3000,
            "send_yield"            => true,
        ],
    ],
    "websocket"        => [
        "enabled"       => true,// 開啟websocket
        "handler"       => Handler::class,  //自定義wbesocket綁定類
        "parser"        => Parser::class, //自定義解析類
        "route_file"    => base_path() . "websocket.php",
        "ping_interval" => 25000,
        "ping_timeout"  => 60000,
        "room"          => [
            "type"        => TableRoom::class,
            "room_rows"   => 4096,
            "room_size"   => 2048,
            "client_rows" => 8192,
            "client_size" => 2048,
        ],
    ],
    "auto_reload"      => true,
    "enable_coroutine" => true,
    "resetters"        => [],
    "tables"           => [],

handler和parser大大方便了自定義websocket服務(wù)，默認(rèn)系統(tǒng)集成socketio。

本文主要介紹如何使用socketio，這里假設(shè)大家有socketio有一定了解和使用基礎(chǔ)。

socketIo默認(rèn)會(huì)在請求地址后加相應(yīng)的參數(shù)

同時(shí)，socketio默認(rèn)情況下，會(huì)認(rèn)為 http://url/socket.io/ 是支持websocket服務(wù)的地址。

而在tp-swoole3.0內(nèi)部已經(jīng)對該地址請求進(jìn)行了處理

param("transport"), $this->transports)) {
            return json(
                [
                    "code"    => 0,
                    "message" => "Transport unknown",
                ],
                400
            );
        }

        if ($request->has("sid")) {
            $response = response("1:6");
        } else {
            $sid     = base64_encode(uniqid());
            $payload = json_encode(
                [
                    "sid"          => $sid,
                    "upgrades"     => ["websocket"],
                    "pingInterval" => $config->get("swoole.websocket.ping_interval"),
                    "pingTimeout"  => $config->get("swoole.websocket.ping_timeout"),
                ]
            );
            $cookie->set("io", $sid);
            $response = response("97:0" . $payload . "2:40");
        }

        return $response->contentType("text/plain");
    }

    public function reject(Request $request)
    {
        return json(
            [
                "code"    => 3,
                "message" => "Bad request",
            ],
            400
        );
    }
}

TP6.0,插件注冊采用了service方式進(jìn)行了注冊，可在tp-swoole 服務(wù)注冊文件中查看路由注冊信息,如果想自定義鏈接規(guī)則，則可以覆蓋該路由。

// +----------------------------------------------------------------------

namespace thinkswoole;

use SwooleHttpServer as HttpServer;
use SwooleWebsocketServer as WebsocketServer;
use thinkApp;
use thinkRoute;
use thinkswoolecommandServer as ServerCommand;
use thinkswoolefacadeServer;
use thinkswoolewebsocketsocketioController;
use thinkswoolewebsocketsocketioMiddleware;

class Service extends 	hinkService
{
    protected $isWebsocket = false;

    /**
     * @var HttpServer | WebsocketServer
     */
    protected static $server;

    public function register()
    {
        $this->isWebsocket = $this->app->config->get("swoole.websocket.enabled", false);

        $this->app->bind(Server::class, function () {
            if (is_null(static::$server)) {
                $this->createSwooleServer();
            }

            return static::$server;
        });

        $this->app->bind("swoole.server", Server::class);

        $this->app->bind(Swoole::class, function (App $app) {
            return new Swoole($app);
        });

        $this->app->bind("swoole", Swoole::class);
    }

    public function boot(Route $route)
    {
        $this->commands(ServerCommand::class);
        if ($this->isWebsocket) {
            $route->group(function () use ($route) {
                $route->get("socket.io/", "@upgrade");
                $route->post("socket.io/", "@reject");
            })->prefix(Controller::class)->middleware(Middleware::class);
        }
    }

    /**
     * Create swoole server.
     */
    protected function createSwooleServer()
    {
        $server     = $this->isWebsocket ? WebsocketServer::class : HttpServer::class;
        $config     = $this->app->config;
        $host       = $config->get("swoole.server.host");
        $port       = $config->get("swoole.server.port");
        $socketType = $config->get("swoole.server.socket_type", SWOOLE_SOCK_TCP);
        $mode       = $config->get("swoole.server.mode", SWOOLE_PROCESS);

        static::$server = new $server($host, $port, $mode, $socketType);

        $options = $config->get("swoole.server.options");

        static::$server->set($options);
    }
}

Socketio默認(rèn)使用demo

在app目錄下新建websocket.php文件,其中需要注意，由于使用了反射，閉包參數(shù)名稱不能隨意定義，不然無法注入。第一個(gè)參數(shù)是websocket，是當(dāng)前websocket的Server對象，第二個(gè)參數(shù)data是客戶端發(fā)送的數(shù)據(jù)。其中socketio emit的第一個(gè)參數(shù)和Websocket::on的第一個(gè)參數(shù)一致，作為事件名稱。

emit("test", "asd");
});

Websocket::on("test1", function ($websocket, $data) {
    $websocket->emit("test", "asd");
});

Websocket::on("join", function (	hinkswooleWebsocket $websocket, $data) {
    $websocket->join("1");
});

參考如上方法即可使用全新的websocket服務(wù)。當(dāng)然tp-swoole3.0同樣還有許多其他的新功能，這些功能需要大家去摸索嘗試。
我也會(huì)在接下來的文章中，一起與大家分享我的使用過程。