Swoole WebSocket 的應用

来源:https://www.cnblogs.com/xinliangcoder/archive/2019/05/01/10800910.html
-Advertisement-
Play Games

概述 這是關於 Swoole 學習的第三篇文章：Swoole WebSocket 的應用。 "第二篇：Swoole Task 的應用" "第一篇：Swoole Timer 的應用" 什麼是 WebSocket ？ WebSocket 是一種在單個TCP連接上進行全雙工通信的協議。 WebSocket ...


概述

這是關於 Swoole 學習的第三篇文章：Swoole WebSocket 的應用。

什麼是 WebSocket ？

WebSocket 是一種在單個TCP連接上進行全雙工通信的協議。

WebSocket 使得客戶端和伺服器之間的數據交換變得更加簡單，允許服務端主動向客戶端推送數據。

在 WebSocket API 中，瀏覽器和伺服器只需要完成一次握手，兩者之間就直接可以創建持久性的連接，併進行雙向數據傳輸。

我們利用 WebSocket 進行及時通訊，今天實現一個 視頻彈幕效果。

實現彈幕其實就和群聊類似，將消息推送給所有的客戶端，只不過前端的展示所有不同。

本地版本：

  • 後端 PHP 7.2.6、Swoole 4.3.1。
  • 前端 HTML5 WebSocket、Canvas。

廢話不多說，先看效果。

批量版：

手動版：

代碼

server.php

<?php

class Server
{
    private $serv;

    public function __construct() {
        $this->serv = new swoole_websocket_server("0.0.0.0", 9501);
        $this->serv->set([
            'worker_num'      => 2, //開啟2個worker進程
            'max_request'     => 4, //每個worker進程 max_request設置為4次
            'task_worker_num' => 4, //開啟4個task進程
            'dispatch_mode'   => 4, //數據包分發策略 - IP分配
            'daemonize'       => false, //守護進程(true/false)
        ]);

        $this->serv->on('Start', [$this, 'onStart']);
        $this->serv->on('Open', [$this, 'onOpen']);
        $this->serv->on("Message", [$this, 'onMessage']);
        $this->serv->on("Close", [$this, 'onClose']);
        $this->serv->on("Task", [$this, 'onTask']);
        $this->serv->on("Finish", [$this, 'onFinish']);

        $this->serv->start();
    }

    public function onStart($serv) {
        echo "#### onStart ####".PHP_EOL;
        echo "SWOOLE ".SWOOLE_VERSION . " 服務已啟動".PHP_EOL;
        echo "master_pid: {$serv->master_pid}".PHP_EOL;
        echo "manager_pid: {$serv->manager_pid}".PHP_EOL;
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onOpen($serv, $request) {
        echo "#### onOpen ####".PHP_EOL;
        echo "server: handshake success with fd{$request->fd}".PHP_EOL;
        $serv->task([
            'type' => 'login'
        ]);
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onTask($serv, $task_id, $from_id, $data) {
        echo "#### onTask ####".PHP_EOL;
        echo "#{$serv->worker_id} onTask: [PID={$serv->worker_pid}]: task_id={$task_id}".PHP_EOL;
        $msg = '';
        switch ($data['type']) {
            case 'login':
                $msg = '我來了...';
                break;
            case 'speak':
                $msg = $data['msg'];
                break;
        }
        foreach ($serv->connections as $fd) {
            $connectionInfo = $serv->connection_info($fd);
            if ($connectionInfo['websocket_status'] == 3) {
                $serv->push($fd, $msg); //長度最大不得超過2M
            }
        }
        $serv->finish($data);
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onMessage($serv, $frame) {
        echo "#### onMessage ####".PHP_EOL;
        echo "receive from fd{$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}".PHP_EOL;
        $serv->task(['type' => 'speak', 'msg' => $frame->data]);
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onFinish($serv,$task_id, $data) {
        echo "#### onFinish ####".PHP_EOL;
        echo "Task {$task_id} 已完成".PHP_EOL;
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onClose($serv, $fd) {
        echo "#### onClose ####".PHP_EOL;
        echo "client {$fd} closed".PHP_EOL;
        echo "########".PHP_EOL.PHP_EOL;
    }
}

$server = new Server();

index.php

<!DOCTYPE html>
<html lang="zh-CN">
    <head>
        <meta charset="utf-8">
        <meta http-equiv="X-UA-Compatible" content="IE=edge">
        <meta name="viewport" content="width=device-width, initial-scale=1">
        <meta name="description" content="">
        <meta name="keywords" content="">
        <script src="js/canvasBarrage.js?v=17"></script>
        <title>視頻彈幕Demo</title>
        <style>
            .canvas-barrage {
                position: absolute;
                width: 960px;
                height: 540px;
                pointer-events: none;
                z-index: 1;
            }
            .ui-input {
                height: 20px;
                width: 856px;
                line-height: 20px;
                border: 1px solid #d0d0d5;
                border-radius: 4px;
                padding: 9px 8px;
            }
            .ui-button {
                display: inline-block;
                background-color: #2486ff;
                line-height: 28px;
                text-align: center;
                border-radius: 4px;
                color: #fff;
                font-size: 14px;
            }
        </style>
    </head>
    <body>
        <canvas id="canvasBarrage" class="canvas-barrage"></canvas>
        <video id="videoBarrage" width="960" height="540" src="./video/video.mp4" controls></video>
            <p>
                <input class="ui-input" id="msg" name="value" value="發送彈幕" required>
                <input class="ui-button" type="button" id="sendBtn" value="發送彈幕">
            </p>
        <script>
            if ("WebSocket" in window) {
                // 彈幕數據
                var dataBarrage = [{
                    value: '',
                    time: 0, // 單位秒
                    speed: 0,
                    fontSize: 0
                }];

                var itemsColor = ['#FFA54F','#FF4040','#EE1289', '#8E8E38', '#3A5FCD', '#00EE76', '#388E8E', '#76EEC6', '#87CEFF', '#7FFFD4'];

                var eleCanvas = document.getElementById('canvasBarrage');
                var eleVideo = document.getElementById('videoBarrage');

                var barrage = new CanvasBarrage(eleCanvas, eleVideo, {
                    data: dataBarrage
                });

                var wsServer = 'ws://10.211.55.3:9501';
                var ws = new WebSocket(wsServer);

                ws.onopen = function (evt) {
                    if (ws.readyState == 1) {
                        console.log('WebSocket 連接成功...');
                    } else {
                        console.log('WebSocket 連接失敗...');
                    }
                };

                ws.onmessage = function (evt) {

                    barrage.add({
                        value: evt.data,
                        time: eleVideo.currentTime,
                        speed: 5,
                        color: itemsColor[Math.floor(Math.random()*itemsColor.length)]
                        // 其它如 fontSize, opacity等可選
                    });
                    console.log('Retrieved data from server: ' + evt.data);
                };

                ws.onerror = function (evt) {
                    alert('WebSocket 發生錯誤');
                    console.log(evt);
                };

                ws.onclose = function() {
                    alert('WebSocket 連接關閉');
                    console.log('WebSocket 連接關閉...');
                };

                var msg;
                var sendBtn = document.getElementById('sendBtn');
                sendBtn.onclick = function(){
                    if (ws.readyState == 1) {
                        msg = document.getElementById('msg').value;
                        ws.send(msg);
                    } else {
                        alert('WebSocket 連接失敗');
                    }
                };
            } else {
                alert("您的瀏覽器不支持 WebSocket!");
            }
            </script>
    </body>
</html>

小結

一、單聊提供了方法，群聊提供方法了嗎？

官方沒有提供群聊的方法，使用迴圈實現的。

單聊：

$serv->push($fd, $msg);

群聊：

foreach ($serv->connections as $fd) {
    $serv->push($fd, $msg);
}

二、發送消息為什麼要放到Task中，封裝一個普通方法不行嗎？

不能封裝成一個普通的方法，要放在Task中使用多進程執行。

如果想瞭解 Swoole Task 的知識，請看： 第二篇：Swoole Timer 的應用。

三、如何模擬批量彈幕效果？

可以使用 swoole_timer_tick ，比如：

swoole_timer_tick(50, function () use($serv){
    $serv->task([
        'type' => 'login'
    ]);
});

四、前端使用的哪個彈幕插件？還有沒有其他的？

canvasBarrage.js：

http://www.zhangxinxu.com/wordpress/?p=6386

有其他的，比如：

  • Jquery.barrager.js
  • Jquery.danmu.js
  • DanMuer.js

根據自己喜歡風格，進行嘗試吧。

五、Demo 中視頻全屏後，還顯示彈幕嗎？

不顯示。

當點擊如上圖中的 “全屏” 時，彈幕就不顯示了，因為這時全屏的視頻已經脫離了HTML文檔，具體能否實現大家可以研究研究（記得考慮 PC、Android、iOS 等相容性）。

也可以用“偽全屏”進行實現，自定義一個全屏按鈕，點擊時讓當前頁面全屏，同時讓視頻尺寸變大。

六、看了這篇文章，單聊和群聊都會了，能實現一個線上IM嗎？

不能。

真正使用的線上IM系統，需求落地時比我們想象到要複雜的多，自己深入研究沒問題，想開發一套生產環境用的IM系統，需要慎重，特別是後端用PHP。

如果急需線上IM系統，可以使用市面上專業的IM系統。

七、彈幕有什麼應用場景？

比如，辦年會或活動開場時大家可以利用彈幕活躍氣氛，使用微信掃碼登錄後進行發送實時彈幕，還可以應用到直播，只要覺得合理都可以使用。

八、Swoole WebSocket 入門還可以實現什麼案例？

可以實現聊天室功能、直播功能、掃碼登錄功能等。

溫馨提示

本 Demo 僅僅是簡單的實現，如需應用到真實場景中還要多做優化。

需要Demo源碼的，關註公眾號，回覆“swoole 彈幕”即可。

本文歡迎轉發，轉發請註明作者和出處，謝謝！


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

-Advertisement-
Play Games
更多相關文章
  • 微服務治理
    微服務遠程調用可能有如下問題： 註冊中心宕機； 服務提供者B有節點宕機； 服務消費者A和註冊中心之間的網路不通； 服務提供者B和註冊中心之間的網路不通； 服務消費者A和服務提供者B之間的網路不通； 服務提供者B有些節點性能變慢； 服務提供者B短時間內出現問題。 註冊中心宕機； 服務提供者B有節點宕機 ...
  • NumPy 學習筆記（四）
    NumPy 算術函數： 1、numpy.reciprocal(arr) 返回參數逐個元素的倒數 2、numpy.power(one, two) 將第一個輸入數組中的元素作為底數，計算它與第二個輸入數組中相應元素的冪，即 one^two 3、numpy.mod(x1, x2) 計算輸入數組中相應元素的 ...
  • Python基礎之面向對象基本概念
    Python基礎之面向對象基本概念，包括了 面向過程和麵向對象概念，類和對象，面向對象基礎語法。其中， 面向過程和麵向對象概念 包括了 面向過程，面向對象；類和對象 包括 類和對象的概念，類的設計；面向對象基礎語法 包括 dir內置函數，定義簡單的類，方法中的self函數，初始化方法，內置方法和屬性... ...
  • 解決新版本R3.6.0不能載入devtools包問題
    首先是看到下麵這個文章想試著練習一下，結果第一步就卡住了，無法載入devtools包，繁體字都冒出來了......汗！（沒有截圖，但過程痛苦不堪~） https://www.sohu.com/a/122630261_468636 在網上遍尋不著此題的答案，但根據熱心網友的回答，我大概懂了一點裡面的門 ...
  • 一種簡單高效的音頻降噪演算法示例(附完整C代碼)
    近期比較忙, 抽空出來5.1開源獻禮. 但凡學習音頻降噪演算法的朋友,肯定看過一個演算法. <<語音增強-理論與實踐>> 中提及到基於對數的最小均方誤差的降噪演算法,也就是LogMMSE. 資料見: <<Speech enhancement using a minimum mean-square erro ...
  • Spring框架學習-Spring和IOC概述
    一：什麼是Spring框架？ spring是一個分層的javase/EEfull-stack（一站式）輕量級的java開源框架。是為瞭解決企業開發的複雜性而創建的。框架的主要優勢是分層架構，Spring的核心是控制反轉（IOC）和麵向切麵（AOP）。 二.學習Spring的好處？ 主要就是方便解耦， ...
  • java基礎語法1
    一：基礎語法之--標識符，修飾符，關鍵字 1.標識符： 定義：類名、變數名以及方法名都被稱為標識符。 註意: ·所有的標識符都應該以字母（A-Z或者a-z）,美元符（$）、或者下劃線（_）開始·首字元之後可以是字母（A-Z或者a-z）,美元符（$）、下劃線（_）或數字的任何字元組合·關鍵字不能用作標 ...
  • Python基礎之函數參數與返回值進階
    Python基礎之參數與返回值進階，包括 函數的返回值 進階，函數的參數進階，函數的遞歸。其中，函數的返回值 進階 包括 利用元組返回多個函數值，用多個變數接收函數的返回值；函數的參數進階 包括 函數內部變數和參數的關係，列表調用+=，預設參數，多值參數，元組和字典的拆包；函數的遞歸 僅包括 函數的... ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類