thinkphp 6.0 swoole擴展websocket使用教程

来源:https://www.cnblogs.com/it-3327/archive/2019/10/30/11767750.html
-Advertisement-
Play Games

前言 ThinkPHP即將迎來最新版本6.0，針對目前越來越流行Swoole，thinkphp也推出了最新的擴展think-swoole 3.0。 介紹 即將推出的tp6.0，已經適配swoole.並推出think-swoole 3.0，並且預設適配了socketio。和2.0版本在使用方法上面有些 ...


前言

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

介紹

即將推出的tp6.0，已經適配swoole.並推出think-swoole 3.0，並且預設適配了socketio。和2.0版本在使用方法上面有些許不同。

Websocket 繼承與Http，進行websocket連接之前需要一次HTTP請求，如果當期地址支持websocket則返回101，然後進行連接。也就是說並不是我的服務支持websocket後，請求每個連接地址都可以進行websocket連接，而是需要預先適配才可以連接。

參數配置

1

2

3

4

5

6

7

8

9

10

11

12

13

14

'server'           => [        'host'      => '0.0.0.0', // 監聽地址

        'port'      => 808, // 監聽埠

        'mode'      => SWOOLE_PROCESS, // 運行模式 預設為SWOOLE_PROCESS

        'sock_type' => SWOOLE_SOCK_TCP, // sock type 預設為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服務，預設系統集成socketio。

本文主要介紹如何使用socketio，這裡假設大家有socketio有一定瞭解和使用基礎。

socketIo預設會在請求地址後加相應的參數

同時，socketio預設情況下，會認為 http://url/socket.io/ 是支持websocket服務的地址。

而在tp-swoole3.0內部已經對該地址請求進行了處理

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

<?phpnamespace think\swoole\websocket\socketio;use think\Config;use think\Cookie;use think\Request;class Controller{    protected $transports = ['polling', 'websocket'];    public function upgrade(Request $request, Config $config, Cookie $cookie)

    {        if (!in_array($request->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方式進行了註冊，可在tp-swoole 服務註冊文件中查看路由註冊信息,如果想自定義鏈接規則，則可以覆蓋該路由。

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

<?php// +----------------------------------------------------------------------// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]// +----------------------------------------------------------------------// | Copyright (c) 2006-2018 http://thinkphp.cn All rights reserved.// +----------------------------------------------------------------------// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )// +----------------------------------------------------------------------// | Author: yunwuxin <[email protected]>// +----------------------------------------------------------------------namespace think\swoole;use Swoole\Http\Server as HttpServer;use Swoole\Websocket\Server as WebsocketServer;use think\App;use think\Route;use think\swoole\command\Server as ServerCommand;use think\swoole\facade\Server;use think\swoole\websocket\socketio\Controller;use think\swoole\websocket\socketio\Middleware;class Service extends \think\Service{    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預設使用demo

1

2

3

4

5

6

7

<!DOCTYPE html><html lang="en"><head>

    <meta charset="UTF-8">

    <title>Title</title>

    <script src="./static/js/socket.io.js"></script></head><body><script>

    const socket = io('http://localhost:808');

    socket.emit("test", "your message");

    socket.on("test",function(res){console.log(res)});</script></body></html>

Websocket路由配置方法

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

1

2

3

4

5

6

7

8

9

10

11

12

13

14

<?php/**

 * Author:Xavier Yang

 * Date:2019/6/5

 * Email:[email protected]

 */use \think\swoole\facade\Websocket;

Websocket::on("test", function (\think\swoole\Websocket $websocket, $data) {    //var_dump($class);

    $websocket->emit("test", "asd");

});

Websocket::on("test1", function ($websocket, $data) {

    $websocket->emit("test", "asd");

});

Websocket::on("join", function (\think\swoole\Websocket $websocket, $data) {

    $websocket->join("1");

});

2128369977-5d172fd1aa6af_articlex.gif

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


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Python切片中的誤區與高級用法
    眾所周知，我們可以通過索引值（或稱下標）來查找序列類型（如字元串、列表、元組...）中的單個元素，那麼，如果要獲取一個索引區間的元素該怎麼辦呢？ 切片（slice）就是一種截取索引片段的技術，藉助切片技術，我們可以十分靈活地處理序列類型的對象。通常來說，切片的作用就是截取序列對象，然而，它還有一些使 ...
  • laravel如何引用外部文件
    （1）、首先在app\Http\routes.php中定義路由； 1 2 3 Route::get('view','ViewController@view'); Route::get('article','ViewController@article'); Route::get('layout',' ...
  • 程式員：利用Python實現可控制肉雞的反向Shell
    一、初識 瞭解TCP協議瞭解C/S結構程式設計Python socket模塊的使用Python subprocess模塊的使用 二、理論基礎 以下內容整理自百度百科，參考鏈接： TCP（傳輸控制協議）2.1 C/S結構程式設計 C/S 結構，即大家熟知的客戶機和伺服器結構。它是軟體系統體繫結構，通過 ...
  • 20191030-Python實現閉包
    打算在過年前每天總結一個知識點，所以把自己總結的知識點分享出來，中間參考了網路上很多大神的總結，但是發佈時候因為時間太久可能沒有找到原文鏈接，如果侵權請聯繫我刪除 20191030：閉包 首先一個函數，如果函數名後緊跟一對括弧，相當於現在我就要調用這個函數，如果不跟括弧，相當於只是一個函數的名字，里 ...
  • 多線程中Runnable 和Thread關於synchronized的疑點
    學java時和同學碰到的一道題： 轉自https://blog.csdn.net/qq_40857349/article/details/102809100 某公司組織年會,會議入場時有兩個入口,在入場時每位員工都能獲取一張雙色球彩票,假設公司有100個員工,利用多線程模擬年會入場過程, 並分別統計 ...
  • Laravel 實現前後臺用戶分離登錄
    在很多時候，我們需要前臺和後臺進行不同的登錄操作，以限制用戶許可權，現在用 Laravel 實現這個需求。 前戲 一、獲取 Laravel 這個在文檔中都有說明的，也比較簡單，可以使用 composer 下載（我下載的時候是有些慢），我就複製之前下載好的空項目。 二、修改配置文件 在這一步我只修改了 ...
  • Java和SQL取兩個字元間的值
    Java String str = "abcdefg"; String result = str.substring(str.indexOf(" ")+1, str.lastIndexOf("得到結果為： 192 取最後逗號後面的部分： SELECT SUBSTRING_INDEX(‘192;168 ...
  • MOOC C++筆記（七）輸入輸出流
    輸入輸出流 與輸入輸出流操作相關的類 istream:是用於輸入的流類，cin就是該類的對象。 ostream:是用於輸出的流類，cout就是該類的對象。 ifstream:是用於從文件讀取數據的類。 ofstream:是用與向文件寫入數據的類。 iostream:是既能用於輸入，又能用於輸出的類。 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類