搜尋
首頁php框架Workermanworkerman怎麼實現分組群聊

workerman怎麼實現分組群聊

Dec 12, 2019 am 09:31 AM
workerman分組群聊

workerman怎麼實現分組群聊

#一、基礎

##1. workerman

workerman是國人開發的良心高效能的PHP socket 伺服器框架,在全球最大同性交友平台gayHub的star都4K多,可以想像是多麼的牛X。

可以單獨部署,也可以整合進MVC的框架(TP,laravel等),可以說非常實用,並發效果也好。

官網網址:http://www.workerman.net/workerman

#gayhub網址:

https://github.com/walkor /workerman/

2. gateway-worker

#gateway-worker(後面直接稱為gateway)是基於workerman開發的TCP長連結框架,用於快速開發TCP長連接應用。

線上聊天一般都是實用長連線保持通信,使用 workerman雖然能夠做到同樣的效果,但是gateway更加的方便快速。 (輪詢建置的聊天室已經OUT了,實在是太...)

gayhub位址:

https://github.com/walkor/GatewayWorker

3. gatewayClient

gateClient是用來輔助workerman或是gateway進行使用者分組以及傳送訊息給使用者的元件,同時,能夠快速便捷的將原有系統的uid和clientid綁定。 gayhub位址:

https://github.com/walkor/GatewayClient

二、理論:

1. 與MVC系統整合的原則:

現有mvc框架專案與GatewayWorker獨立部署互不干擾;·

所有的業務邏輯都由網站頁面post/get到mvc框架完成;##·

GatewayWorker不接受客戶端發送的數據,即GatewayWorker不處理任何業務邏輯,GatewayWorker僅僅當做一個單向的推送通道;

·

只有當mvc框架需要主動向瀏覽器推送資料時才在mvc框架中呼叫Gateway的API(GatewayClient)完成推送。

2. 實作步驟:

(1)網站頁面建立與GatewayWorker的websocket連接;

(2)GatewayWorker發現有頁面發起連接時,將對應連接的client_id發給網站頁面;

(3)網站頁面收到client_id後觸發一個ajax請求(假設是bind.php)將client_id發到mvc後端;

(4)mvc後端bind.php收到client_id後利用GatewayClient呼叫Gateway::bindUid($client_id, $uid)將client_id與目前uid(使用者id或客戶端唯一識別)綁定。如果有群組、群發功能,也可以利用Gateway::joinGroup($client_id, $group_id)將client_id加入對應分組;(5)頁面發起的所有請求都直接post/get到mvc框架統一處理,包括發送訊息;

(6)mvc框架處理業務過程中需要向某個uid或某個群組發送資料時,直接呼叫GatewayClient的介面Gateway::sendToUid Gateway::sendToGroup等發送即可。

三、實作—設定與開啟Gateway:

#1.下載並使用gateway

可以單獨使用,也可以放在框架的public目錄下。 2.編輯start.php

·

start.php是需要使用php命令列運行的。

·

注意require_once的路徑

ini_set('display_errors', 'on');
use Workerman\Worker;
if(strpos(strtolower(PHP_OS), 'win') === 0)
{
    exit("start.php not support windows, please use start_for_win.bat\n");
}
// 检查扩展
if(!extension_loaded('pcntl'))
{
    exit("Please install pcntl extension.See http://doc3.workerman.net/appendices/install-extension.html\n");
}
if(!extension_loaded('posix'))
{
    exit("Please install posix extension.See http://doc3.workerman.net/appendices/install-extension.html\n");
}
// 标记是全局启动
define('GLOBAL_START', 1);
// 注意这里的路径
require_once '../vendor/autoload.php';
// 加载所有Applications/*/start.php,以便启动所有服务
foreach(glob(__DIR__.'/Applications/*/start*.php') as $start_file)
{
    require_once $start_file;
}
// 运行所有服务
Worker::runAll();
3. start_gateway.php

·

在ApplicationsYourAppstart_gateway.php中可以編輯

// 部分文件内容
//将$gateway改成websocket协议,demo中是text协议
$gateway = new Gateway("websocket://0.0.0.0:8282");
4.start_register.php

##要注意start_register.php 中$register必須是text協定,同時需要注意連接埠

// register 服务必须是text协议
$register = new Register('text://192.168.124.125:1238');
5. 設定好後,開啟start.php

##
$ php start.php start

四、實作-服務端開發

上面提到了,使用者只有在觸發連線的時候才經過gateway的onConnect($client_id),而所有的業務操作都應該在web系統中實作。 因此我創建了一個GatewatServer.php的controller,負責處理這些業務

<?php
/**
 * Author: root
 * Date  : 17-3-27
 * time  : 上午12:32
 */
namespace app\index\controller;
use GatewayClient\Gateway;
use think\Cache;
use think\Controller;
use think\Request;
use think\Session;
class GatewayServer extends Controller
{
    public function _initialize(){
    }
    public function bind(Request $request)
    {
        // 用户连接websocket之后,绑定uid和clientid,同时进行分组,根据接收到的roomid进行分组操作
        $userGuid=Session::get(&#39;loginuser&#39;);
        $roomId=intval(trimAll($request->post(&#39;room&#39;)));
        $clientId=trimAll($request->post(&#39;client_id&#39;));
        // 接受到上面的三个参数,进行分组操作
        Gateway::$registerAddress = &#39;192.168.124.125:1238&#39;;
        // client_id与uid绑定
        // Gateway::bindUid($clientId, $userGuid);
        // 加入某个群组(可调用多次加入多个群组) 将clientid加入roomid分组中
        Gateway::joinGroup($clientId, $roomId);
        // 返回ajax json信息
        $dataArr=[
            &#39;code&#39;=>$userGuid,
            &#39;status&#39;=>true,
            &#39;message&#39;=>&#39;Group Success&#39;
        ];
        return json()->data($dataArr);
    }
    // 接受用户的信息 并且发送
    public function send(Request $request){
        Gateway::$registerAddress = &#39;192.168.124.125:1238&#39;;
        // 获得数据
        $userGuid=Session::get(&#39;loginuser&#39;);
        $roomId=intval(trimAll($request->post(&#39;room&#39;)));
        $message=trim($request->post(&#39;message&#39;));
        // 获得用户的称呼
        $userInfo=Cache::get($userGuid);
        // 将用户的昵称以及用户的message进行拼接
        $nickname=$userInfo[&#39;nickname&#39;];
        $message=$nickname." : ".$message;
        // 发送信息应当发送json数据,同时应该返回发送的用户的guid,用于客户端进行判断使用
        $dataArr=json_encode(array(
            &#39;message&#39; => $message,
            &#39;user&#39;=>$userGuid
        ));
        // 向roomId的分组发送数据
        Gateway::sendToGroup($roomId,$dataArr);
    }
}

五、實作-客戶端連線與發送/接收:

開啟了gateway之後,就可以監聽並且等待瀏覽器存取了。

客戶端這裡使用js監聽websocket:

1. 用來處理客戶端連線websocket以及接收訊息

// 这个示例和gateway官网的示例是一样的
    // 监听端口
    ws = new WebSocket("ws://192.168.124.125:8282");
    // 绑定分组的ajaxURL
    var ajaxUrl="{:url(&#39;/gateway/bind&#39;)}";
    // 发送消息的ajaxURL
    var ajaxMsgUrl="{:url(&#39;/gateway/send&#39;)}";
    // 通过房间号进行分组
    var roomId="{$roomInfo.guid}";
    // 获取当前登录用户的guid,用于标识是自己发送的信息
    var loginUser="{$userLoginInfo.guid}";
    // 获取当前房间号的主播的uid,用于标识是主播发送的信息
    var roomUser="{$roomInfo.uid}";
    // 服务端主动推送消息时会触发这里的onmessage
    ws.onmessage = function(e){
        // console.log(e.data);
        // json数据转换成js对象
        var data = eval("("+e.data+")");
        var type = data.type || &#39;&#39;;
        switch(type){
            // Events.php中返回的init类型的消息,将client_id发给后台进行uid绑定
            case &#39;init&#39;:
                // 利用jquery发起ajax请求,将client_id发给后端进行uid绑定
                $.post(ajaxUrl, {client_id: data.client_id,room:roomId}, function(data){
                    // console.log(data);
                }, &#39;json&#39;);
                break;
            // 当mvc框架调用GatewayClient发消息时直接alert出来
            default :
                // 如果登陆用户的guid和数据发送者的guid一样,则使用不同的颜色(只能自己看到)
                if(loginUser == data.user){
                    addMsgToHtml(data.message,&#39;#F37B1D&#39;);
                    break;
                // 如果发送者的guid和主播uid一样,则对所有的显示都增加一个[主播标识]
                }else if(data.user==roomUser){
                    addMsgToHtml("[主播] "+data.message,&#39;#0e90d2&#39;);
                    break;
                }else{
                // 其他的就正常发送消息
                    addMsgToHtml(data.message,&#39;#333&#39;);
                }
                break;
        }
    };

#2.用於將接收到的訊息新增至div中進行顯示

// 向面板中增加新接收到的消息
    // 其中message是消息,color是显示的颜色,主要为了区分主播以及自己发送的消息和系统提示
    function addMsgToHtml(message,color) {
        if(message.length==0){
            return false;
        }
        // 获取html,并且增加html
        var obj=$("#room-viedo-chat");
        var html=obj.html();
        // 
        html+=&#39;<p><font color="&#39;+color+&#39;">&#39;+message+&#39;</p>&#39;;
        obj.html(html);
        // 将滚动条滚动到底部
        obj.scrollTop(obj[0].scrollHeight);
    }

3.用於發送訊息######
// 发送聊天消息
    function sendMsg(){
        // 去掉onclick属性,使得3秒之内无法发送信息
        $("#sendMsgBox").attr(&#39;onclick&#39;,&#39;&#39;);
        var btnObj=$("#sendMsgBtn");
        var tmpNum=3;
        var tmpMsg=tmpNum+&#39; S&#39;;
        btnObj.text(tmpMsg);
        var int =setInterval(function () {
            // 3秒之内不能发送信息,3秒之后,回复onclick属性以及文字
            if(tmpNum==0){
                tmpMsg="发送";
                clearInterval(int);
                btnObj.text("发送");
                $("#sendMsgBox").attr(&#39;onclick&#39;,&#39;sendMsg()&#39;);
            }
            btnObj.text(tmpMsg);
            tmpNum-=1;
            tmpMsg=tmpNum+&#39; S&#39;;
        },1000);
        var message=$("#chattext").val().trim();
        var obj=$("#room-viedo-chat");
        var html=obj.html();
        if(message.length>=140){
            // 获取html,并且增加html
            addMsgToHtml("系统提示: 不能超过140个字符","#8b0000");
            return false;
        }
        if(message.length==0){
            // 获取html,并且增加html
            addMsgToHtml("系统提示: 不能发送空消息","#8b0000");
            return false;
        }
        // 向server端发送ajax请求
        $.post(ajaxMsgUrl,{room:roomId,message:message},function (data) {
        },&#39;json&#39;);
        return false;
    }
######4.一點兒html程式碼######
<!--chat box start -->
    <div class=" am-u-md-12 am-u-lg-12 room-viedo-chat" id="room-viedo-chat" style="font-size:14px;">
    </div>
    <div class="am-u-md-12 am-u-lg-12 room-viedo-chat-button-box">
        <div class="left-div">
            <textarea name="chattext" id="chattext" placeholder="输入聊天内容..."></textarea>
        </div>
        <div class="am-btn am-btn-default right-div am-text-center"onclick="sendMsg();"id="sendMsgBox">
            <span class="" id="sendMsgBtn">
                发送
            </span>
        </div>
    </div>
    <!--chat box end -->

六、效果:

效果很明显:

·系统提示是单独的颜色

·本人发布的,是自己能够分辨的橙色

·主播发布的是蓝色,同时前面有[主播]标识

·看其他人发布的就是普通的颜色

workerman怎麼實現分組群聊

PHP中文网,有大量免费的workerman入门教程,欢迎大家学习!

以上是workerman怎麼實現分組群聊的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
Workerman內置WebSocket客戶端的關鍵功能是什麼?Workerman內置WebSocket客戶端的關鍵功能是什麼?Mar 18, 2025 pm 04:20 PM

Workerman的Websocket客戶端可以通過異步通信,高性能,可伸縮性和安全性等功能增強實時通信,並可以輕鬆地與現有系統集成。

如何使用工作人員來構建實時協作工具?如何使用工作人員來構建實時協作工具?Mar 18, 2025 pm 04:15 PM

本文討論了使用高性能PHP服務器Workerman來構建實時協作工具。它涵蓋安裝,服務器設置,實時功能實現以及與現有系統集成,強調Workerman的密鑰F

為低延遲應用優化工作人員的最佳方法是什麼?為低延遲應用優化工作人員的最佳方法是什麼?Mar 18, 2025 pm 04:14 PM

本文討論了針對低延遲應用程序的優化工作人員,重點介紹異步編程,網絡配置,資源管理,數據傳輸最小化,負載平衡和常規更新。

如何與Workerman和MySQL實施實時數據同步?如何與Workerman和MySQL實施實時數據同步?Mar 18, 2025 pm 04:13 PM

本文討論了使用Workerman和MySQL實施實時數據同步的,重點是設置,最佳實踐,確保數據一致性以及解決共同挑戰。

在無服務器體系結構中使用Workerman的主要考慮因素是什麼?在無服務器體系結構中使用Workerman的主要考慮因素是什麼?Mar 18, 2025 pm 04:12 PM

本文討論了將工作人員集成到無服務器體系結構中,專注於可擴展性,無狀態,冷啟動,資源管理和集成複雜性。 Workerman通過高並發,降低冷STA來提高性能

如何使用Workerman建立高性能的電子商務平台?如何使用Workerman建立高性能的電子商務平台?Mar 18, 2025 pm 04:11 PM

文章討論了使用Workerman建立高性能的電子商務平台,重點關注其功能,例如Websocket支持和可擴展性,以提高實時交互和效率。

Workerman的Websocket服務器的高級功能是什麼?Workerman的Websocket服務器的高級功能是什麼?Mar 18, 2025 pm 04:08 PM

Workerman的Websocket服務器可以通過可擴展性,低延遲和針對常見威脅的安全措施等功能增強實時通信。

如何使用工作人員來構建實時分析儀表板?如何使用工作人員來構建實時分析儀表板?Mar 18, 2025 pm 04:07 PM

本文討論了使用高性能PHP服務器Workerman來構建實時分析儀表板。它涵蓋了與React,vue.js和Angular等框架的安裝,服務器設置,數據處理以及前端集成。關鍵功能

See all articles

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

AI Hentai Generator

AI Hentai Generator

免費產生 AI 無盡。

熱門文章

R.E.P.O.能量晶體解釋及其做什麼(黃色晶體)
3 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳圖形設置
3 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.如果您聽不到任何人,如何修復音頻
3 週前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25:如何解鎖Myrise中的所有內容
4 週前By尊渡假赌尊渡假赌尊渡假赌

熱工具

mPDF

mPDF

mPDF是一個PHP庫,可以從UTF-8編碼的HTML產生PDF檔案。原作者Ian Back編寫mPDF以從他的網站上「即時」輸出PDF文件,並處理不同的語言。與原始腳本如HTML2FPDF相比,它的速度較慢,並且在使用Unicode字體時產生的檔案較大,但支援CSS樣式等,並進行了大量增強。支援幾乎所有語言,包括RTL(阿拉伯語和希伯來語)和CJK(中日韓)。支援嵌套的區塊級元素(如P、DIV),

SecLists

SecLists

SecLists是最終安全測試人員的伙伴。它是一個包含各種類型清單的集合,這些清單在安全評估過程中經常使用,而且都在一個地方。 SecLists透過方便地提供安全測試人員可能需要的所有列表,幫助提高安全測試的效率和生產力。清單類型包括使用者名稱、密碼、URL、模糊測試有效載荷、敏感資料模式、Web shell等等。測試人員只需將此儲存庫拉到新的測試機上,他就可以存取所需的每種類型的清單。

EditPlus 中文破解版

EditPlus 中文破解版

體積小,語法高亮,不支援程式碼提示功能

SublimeText3 Linux新版

SublimeText3 Linux新版

SublimeText3 Linux最新版

Dreamweaver Mac版

Dreamweaver Mac版

視覺化網頁開發工具