亚洲国产日韩欧美一区二区三区,精品亚洲国产成人av在线,国产99视频精品免视看7,99国产精品久久久久久久成人热,欧美日韩亚洲国产综合乱

首頁 php框架 Workerman 使用workerman實(shí)現(xiàn)線上聊天的方法

使用workerman實(shí)現(xiàn)線上聊天的方法

Dec 26, 2019 pm 05:00 PM
workerman

使用workerman實(shí)現(xiàn)線上聊天的方法

workerman 是一個(gè)用php編寫的通訊服務(wù)。之前的專案都是用它來做資料介面服務(wù)

這次用它做一個(gè)簡單的線上聊天室~

1.下載最新版本的workerman

可以去http://www.workerman.net 去下載

我這裡將service 和client 分開了兩個(gè)資料夾，方便管理

大致的專案架構(gòu)如下。

使用workerman實(shí)現(xiàn)線上聊天的方法

客戶端：

客戶端就簡單了。一個(gè)簡單的html程式碼。嵌入了一個(gè)websocket 監(jiān)聽服務(wù)

var ws, name, client_list={};
function connect() {
       // 創(chuàng)建websocket
       ws = new WebSocket("ws://192.168.0.88:2345");
       // 當(dāng)socket連接打開時(shí)，輸入用戶名
       ws.onopen = onopen;
       // 當(dāng)有消息時(shí)根據(jù)消息類型顯示不同信息
       ws.onmessage = onmessage;
       ws.onclose = function() {
          console.log("連接關(guān)閉，定時(shí)重連");
          connect();
       };
       ws.onerror = function() {
          console.log("出現(xiàn)錯(cuò)誤");
       };
    }

實(shí)現(xiàn)websocket的打開，message的監(jiān)聽，以及close?

1、當(dāng)打開一個(gè)客戶端，則立刻彈出一個(gè)輸入姓名的對話框

function onopen(){
        //console.log(name);
        //var username=connect_id="";
        if(!name)
        {
            name=prompt("請輸入您的名字","");
            if(!name || name=='null'){ 
                name = '咕噠子';
            }
        }
 
        $('#curuser').text(name);
 
         data='{"type":"1","user":"'+name+'"}';
         
        ws.send(data);
    }

並將資料推送給服務(wù)端。 type =1 代表登陸。

2、收到訊息時(shí)，判斷訊息類型，是群發(fā)訊息 還是私聊訊息。進(jìn)而處理。

另外，每次使用者有新使用者登陸上來，都會(huì) 給各個(gè)客戶端推送，使用者清單。進(jìn)行渲染

function onmessage(e){
        //console.log(e.data);
        var data = eval("("+e.data+")");
        var info=$('#chatinfo').html();
        if(data.type==1)
            $(&#39;#chatinfo&#39;).html(info+&#39;<br/>&#39;+data.data);
        else if(data.type==2)
        {
            // 在線用戶列表 userinfo
            $(&#39;#userinfo&#39;).html(data.data);
        }
        else if(data.type==3)
        {
            // 在線用戶列表 個(gè)人信息
            name=data.data.userinfo;
            //console.log(data.data);
        }
    }

?然後另外就是 每個(gè)使用者傳送訊息的程式碼了。可以是私聊 ，也可以是群發(fā)

$(&#39;#send&#39;).click(function(e){
        var msg=$(&#39;#msg&#39;).val();
        var tofriend=$(&#39;#tofriend&#39;).val();
        var tofriendname=$(&#39;#tofriendname&#39;).val();
        if(tofriend!="")
        {
            data=&#39;{"type":"3","user":"&#39;+name+&#39;","msg":"&#39;+msg+&#39;","friend_id":"&#39;+tofriend+&#39;","friendname":"&#39;+tofriendname+&#39;"}&#39;;
        }else{
            data=&#39;{"type":"2","user":"&#39;+name+&#39;","msg":"&#39;+msg+&#39;"}&#39;;
        }
        ws.send(data);
        $(&#39;#msg&#39;).attr("value",&#39;&#39;);
    });

客戶端差不多就是這樣的了。

客戶端，有幾個(gè)坑 ，

坑1、變數(shù)名稱是 name ?則刷新網(wǎng)頁不會(huì)重置，否則就會(huì)被重置。 （後面查資料發(fā)現(xiàn)，這個(gè)name變數(shù)?是window.name 。所以刷新網(wǎng)頁該值也不會(huì)被刷新掉）

坑2、js組數(shù)組，變數(shù)要用"" 最外層為''如：data='{"type":"1","user":"' name '"}'; ?否則解析出問題。不能倒過來！

服務(wù)端：

服務(wù)端主要是workerman 元件 以及?使用 Channel分散式通訊元件 實(shí)作訂閱 和叢集推送 分組推送 以及私聊。

首先，當(dāng)然是監(jiān)聽，啟用一個(gè)worker的websocket監(jiān)聽

// 創(chuàng)建一個(gè)Worker監(jiān)聽2346端口，使用websocket協(xié)議通訊
$ws_worker = new Worker("websocket://0.0.0.0:2345");
$channel_server = new Channel\Server(&#39;0.0.0.0&#39;, 2206);
// 啟動(dòng)4個(gè)進(jìn)程對外提供服務(wù)
$ws_worker->count = 4;
$ws_worker->name="kinmoschat";

在workerman 監(jiān)聽啟用的時(shí)候，進(jìn)行 channel通訊的註冊。 

$ws_worker->onWorkerStart=function($ws_worker)
{
    // channel 客戶端鏈接上 服務(wù)器
    Channel\Client::connect(&#39;127.0.0.1&#39;,2206);
    $event_name=&#39;私聊&#39;;
    // 訂閱 worker-<id 事件，并注冊事件處理函數(shù)
    Channel\Client::on($event_name,function($event_data)use($ws_worker){
 
        //print_r($event_data);
        //print_r($ws_worker->connections);
        $to_connect_id=$event_data[&#39;to_connection_id&#39;];
        $message=$event_data[&#39;content&#39;];
 
        foreach ($ws_worker->connections as $connection) {
 
            if($connection->id==$to_connect_id)
            {
                $connection->send($message);
            }
                 
        }
 
        // if(!isset($ws_worker->connections[$to_connect_id]))
        // {
        //     echo &#39;connect is not exist\n&#39;;
        //     return;
        // }
        // $to_connection=$ws_worker->connections[$to_connect_id];
        // $to_connection->send($message);
    });
 
    // 訂閱廣播事件
    $event_name = &#39;廣播&#39;;
    // 收到廣播 向所有客戶端發(fā)送消息
    Channel\Client::on($event_name,function($event_data)use($ws_worker){
        //print_r($event_data);
        $message=$event_data[&#39;content&#39;];
        foreach ($ws_worker->connections as $connection) {
            $connection->send($message);
        }
    });
};

註冊兩個(gè)事件，一個(gè)廣播事件，一個(gè)私聊事件，用以上線通知的廣播，以及群發(fā)訊息。私聊 就是私聊了。 。這裡，還可以做 分組的群發(fā)。不過，這個(gè)版本還未實(shí)現(xiàn)。

然後是針對，客戶端連結(jié)的回呼。 

$ws_worker->onConnect=function($connection){
    $connection->id = md5($connection->id."_".time()."_".rand(10000,99999));
};

這裡，客戶端回呼，我會(huì)將客戶端的 ?connectid修改掉。一個(gè)簡單的md5 主要是為了防止 流水id太容易被利用吧。 。

然後，整個(gè)專案的主體，服務(wù)端訊息的處理回呼。

針對每個(gè)進(jìn)來的客戶端，分配一個(gè)唯一id

維護(hù)一個(gè)connectid=>user 的關(guān)係表

由於開啟了多個(gè)進(jìn)程導(dǎo)致存到session中無效，故而打算存到資料庫中

斷開連結(jié)的時(shí)候，刪除資料

$ws_worker->onMessage = function($connection, $data)
{
    $res=array(&#39;code&#39;=>200, &#39;msg&#39;=>&#39;ok&#39;, &#39;data&#39;=>null,&#39;type&#39;=>1);
    // 向客戶端發(fā)送hello $data
    //print_r($data);
    $data=json_decode($data,true);
    //print_r($data);
    if(!isset($data[&#39;type&#39;])||empty($data[&#39;type&#39;]))// type 1  2
    {
        $res=array(&#39;code&#39;=>301, &#39;msg&#39;=>&#39;消息包格式錯(cuò)誤&#39;, &#39;data&#39;=>null);
    }else{
        switch ($data[&#39;type&#39;]) {
            case &#39;1&#39;: // 客戶端上線消息
                //print_r($connection->id);
                 
                if(!isset($data[&#39;user&#39;])||empty($data[&#39;user&#39;]))
                {
                    $res=array(&#39;code&#39;=>301, &#39;msg&#39;=>&#39;消息包格式錯(cuò)誤&#39;, &#39;data&#39;=>null);
                    break;
                }
                // 維護(hù)一個(gè)數(shù)組 保存 用戶 connection_id => user
 
                $dsn=&#39;mysql:host=127.0.0.1;dbname=kinmoschat;&#39;;
                $pdo=new PDO($dsn,&#39;root&#39;,&#39;123456&#39;);
                //準(zhǔn)備SQL語句
                $sql = "INSERT INTO `user`(`connect_id`,`username`) VALUES (:connect_id,:username)";
 
                //調(diào)用prepare方法準(zhǔn)備查詢
                $stmt = $pdo->prepare($sql);
 
                //傳遞一個(gè)數(shù)組為預(yù)處理查詢中的命名參數(shù)綁定值，并執(zhí)行SQL
                $stmt->execute(array(&#39;:connect_id&#39; => $connection->id,&#39;:username&#39; => $data[&#39;user&#39;]));
                //獲取最后一個(gè)插入數(shù)據(jù)的ID值
                //echo $pdo->lastInsertId() . &#39;<br />&#39;;
 
                // 向自己推送一條消息
                $res2[&#39;type&#39;]=3;// 系統(tǒng)信息
                $res2[&#39;data&#39;]=array(&#39;userinfo&#39; =>$data[&#39;user&#39;]);// 系統(tǒng)信息
                $connection->send(json_encode($res2));
 
                $msg="用戶 ".$data[&#39;user&#39;]." 上線了~~";
                $res[&#39;data&#39;]=$msg;
                break;
            case &#39;2&#39;: // 客戶端群發(fā)送消息
                if(!isset($data[&#39;user&#39;])||empty($data[&#39;user&#39;])||!isset($data[&#39;msg&#39;])||empty($data[&#39;msg&#39;]))
                {
                    $res=array(&#39;code&#39;=>301, &#39;msg&#39;=>&#39;消息包格式錯(cuò)誤&#39;, &#39;data&#39;=>null);
                    break;
                }
                $msg="用戶 ".$data[&#39;user&#39;]."說：".$data[&#39;msg&#39;];
                $res[&#39;data&#39;]=$msg;
                break;
            case &#39;3&#39;: // 客戶端私聊
                if(!isset($data[&#39;user&#39;])||empty($data[&#39;user&#39;])||!isset($data[&#39;msg&#39;])||empty($data[&#39;msg&#39;])||!isset($data[&#39;friend_id&#39;])||empty($data[&#39;friend_id&#39;]))
                {
                    $res=array(&#39;code&#39;=>301, &#39;msg&#39;=>&#39;消息包格式錯(cuò)誤&#39;, &#39;data&#39;=>null);
                    break;
                }
                $msg="用戶 ".$data[&#39;user&#39;]."對您說：".$data[&#39;msg&#39;];
                $res[&#39;data&#39;]=$msg;
                $res[&#39;type&#39;]=1;// 聊天消息
                $res1=json_encode($res);
                // 推送給單個(gè)用戶
                $event_name = &#39;私聊&#39;;
                Channel\Client::publish($event_name, array(
                    &#39;content&#39;          => $res1,
                    &#39;to_connection_id&#39; =>$data[&#39;friend_id&#39;]
                ));
                // 另外還要給自己推條消息
                $msg="您對 ".$data[&#39;friendname&#39;]."說：".$data[&#39;msg&#39;];
                $res[&#39;data&#39;]=$msg;
                $res[&#39;type&#39;]=1;// 聊天消息
                $res2=json_encode($res);
                Channel\Client::publish($event_name, array(
                    &#39;content&#39;          => $res2,
                    &#39;to_connection_id&#39; =>$connection->id
                ));
                return;
                break;
             
            default:
                # code...
                break;
        }
    }
    $res[&#39;type&#39;]=1;// 聊天消息
    $res=json_encode($res);
    // 廣播給所有客戶端
    $event_name = &#39;廣播&#39;;
    Channel\Client::publish($event_name, array(
        &#39;content&#39;          => $res
    ));
 
    $dsn=&#39;mysql:host=127.0.0.1;dbname=kinmoschat;&#39;;
    $dbh=new PDO($dsn,&#39;root&#39;,&#39;123456&#39;);
    $stmt=$dbh->query(&#39;SELECT connect_id,username FROM user&#39;);
    $row=$stmt->fetchAll();
    $uerHtml="";
    foreach ($row as $key => $value) {
 
        $uerHtml.=&#39;<a class="user" onclick="userclick(\&#39;&#39;.$value[&#39;username&#39;].&#39;\&#39;,\&#39;&#39;.$value[&#39;connect_id&#39;].&#39;\&#39;);" value="&#39;.$value[&#39;connect_id&#39;].&#39;" href="javascript:void(0);">&#39;.$value[&#39;username&#39;].&#39;</a><br/>&#39;;
    }
    //print_r($row);
    $res1[&#39;type&#39;]=2;// 用戶消息
    $res1[&#39;data&#39;]=$uerHtml;
    $res1=json_encode($res1);
     
 
    $event_name = &#39;廣播&#39;;
    Channel\Client::publish($event_name, array(
        &#39;content&#39;          => $res1
    ));
};

這裡會(huì)將每個(gè)使用者的?connectid=>name 存入資料庫。 。

當(dāng)收到一則 上線訊息的時(shí)候，廣播給所有使用者。

收到一則群發(fā)訊息。 。廣播給所有客戶端。

收到一封私聊訊息。則單一推送給自己以及發(fā)送的人。

監(jiān)聽 用戶端關(guān)閉事件，當(dāng)客戶端關(guān)閉，刪除用戶表相關(guān)記錄

// 關(guān)閉鏈接 將數(shù)據(jù)庫中的該數(shù)據(jù)刪除
$ws_worker->onClose=function($connection)
{
    //echo 3233;
    $dsn=&#39;mysql:host=127.0.0.1;dbname=kinmoschat;&#39;;
    $pdo=new PDO($dsn,&#39;root&#39;,&#39;123456&#39;);
    $sql="delete from user where connect_id=&#39;".$connection->id."&#39;";
    //print_r($sql);
    $pdo->exec($sql);
};

更多workerman知識(shí)請關(guān)注workerman教程欄目。

以上是使用workerman實(shí)現(xiàn)線上聊天的方法的詳細(xì)內(nèi)容。更多資訊請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！

本網(wǎng)站聲明
本文內(nèi)容由網(wǎng)友自願(yuàn)投稿，版權(quán)歸原作者所有。本站不承擔(dān)相應(yīng)的法律責(zé)任。如發(fā)現(xiàn)涉嫌抄襲或侵權(quán)的內(nèi)容，請聯(lián)絡(luò)admin@php.cn

熱AI工具

Undress AI Tool

Undress AI Tool

免費(fèi)脫衣圖片

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅(qū)動(dòng)的應(yīng)用程序，用於創(chuàng)建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

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

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費(fèi)的人工智慧換臉工具，輕鬆在任何影片中換臉！

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費(fèi)的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版，非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強(qiáng)大的PHP整合開發(fā)環(huán)境

Dreamweaver CS6

Dreamweaver CS6

視覺化網(wǎng)頁開發(fā)工具

SublimeText3 Mac版

SublimeText3 Mac版

神級(jí)程式碼編輯軟體(SublimeText3)

熱門話題

Laravel 教程
1597
29
PHP教程
1488
72
實(shí)作Workerman文件中的文件上傳與下載 實(shí)作Workerman文件中的文件上傳與下載 Nov 08, 2023 pm 06:02 PM

實(shí)現(xiàn)Workerman文件中的文件上傳與下載，需要具體程式碼範(fàn)例引言：Workerman是一款高效能的PHP非同步網(wǎng)路通訊框架，具備簡潔、高效、易用等特點(diǎn)。在實(shí)際開發(fā)中，文件上傳和下載是常見的功能需求，本文將介紹如何使用Workerman框架實(shí)現(xiàn)文件的上傳和下載，並給出具體的程式碼範(fàn)例。一、檔案上傳：檔案上傳是指將本機(jī)上的檔案傳輸至伺服器端的操作。下面是使用

swoole和workerman哪個(gè)好 swoole和workerman哪個(gè)好 Apr 09, 2024 pm 07:00 PM

Swoole 和 Workerman 都是高效能 PHP 伺服器框架。 Swoole 以其非同步處理、出色的效能和可擴(kuò)展性而聞名，適用於需要處理大量並發(fā)請求和高吞吐量的專案。 Workerman 提供了非同步和同步模式的靈活性，具有直覺的 API，更適合易用性和處理較低並發(fā)量的專案。

如何實(shí)作Workerman文件的基本使用方法 如何實(shí)作Workerman文件的基本使用方法 Nov 08, 2023 am 11:46 AM

如何實(shí)現(xiàn)Workerman文件的基本使用方法簡介：Workerman是一個(gè)高效能的PHP開發(fā)框架，它可以幫助開發(fā)者輕鬆建立高並發(fā)的網(wǎng)路應(yīng)用程式。本文將介紹Workerman的基本使用方法，包括安裝和設(shè)定、建立服務(wù)和監(jiān)聽連接埠、處理客戶端請求等。並給出相應(yīng)的程式碼範(fàn)例。一、安裝並設(shè)定Workerman在命令列中輸入以下命令來安裝Workerman：c

如何實(shí)作Workerman文件中的定時(shí)器功能 如何實(shí)作Workerman文件中的定時(shí)器功能 Nov 08, 2023 pm 05:06 PM

如何實(shí)現(xiàn)Workerman文件中的定時(shí)器功能Workerman是一款強(qiáng)大的PHP非同步網(wǎng)路通訊框架，它提供了豐富的功能，其中就包括定時(shí)器功能。使用定時(shí)器可以在指定的時(shí)間間隔內(nèi)執(zhí)行程式碼，非常適合定時(shí)任務(wù)、輪詢等應(yīng)用程式場景。接下來，我將詳細(xì)介紹如何在Workerman中實(shí)現(xiàn)定時(shí)器功能，並提供具體的程式碼範(fàn)例。第一步：安裝Workerman首先，我們需要安裝Worker

Workerman開發(fā)：如何實(shí)現(xiàn)基於UDP協(xié)定的即時(shí)視訊通話 Workerman開發(fā)：如何實(shí)現(xiàn)基於UDP協(xié)定的即時(shí)視訊通話 Nov 08, 2023 am 08:03 AM

Workerman開發(fā)：基於UDP協(xié)議的即時(shí)視訊通話摘要：本文將介紹如何使用Workerman框架實(shí)現(xiàn)基於UDP協(xié)議的即時(shí)視訊通話功能。我們將深入了解UDP協(xié)議的特點(diǎn)，並透過程式碼範(fàn)例展示如何建立一個(gè)簡單但完整的即時(shí)視訊通話應(yīng)用程式。引言：在網(wǎng)路通訊中，即時(shí)視訊通話是一項(xiàng)非常重要的功能。傳統(tǒng)的TCP協(xié)定在實(shí)現(xiàn)即時(shí)性較高的視訊通話時(shí)，可能會(huì)有傳輸延遲等問題。而UDP

如何實(shí)現(xiàn)Workerman文件中的反向代理功能 如何實(shí)現(xiàn)Workerman文件中的反向代理功能 Nov 08, 2023 pm 03:46 PM

如何實(shí)現(xiàn)Workerman文件中的反向代理功能，需要具體程式碼範(fàn)例簡介：Workerman是一款高效能的PHP多進(jìn)程網(wǎng)路通訊框架，提供了豐富的功能和強(qiáng)大的效能，廣泛應(yīng)用於Web即時(shí)通訊、長連接服務(wù)等場景。其中，Workerman也支援反向代理功能，可實(shí)現(xiàn)伺服器對外提供服務(wù)時(shí)的負(fù)載平衡和靜態(tài)資源快取等功能。本篇文章將介紹如何使用Workerman實(shí)現(xiàn)反向代理功

如何使用Workerman建構(gòu)高可用性負(fù)載平衡系統(tǒng) 如何使用Workerman建構(gòu)高可用性負(fù)載平衡系統(tǒng) Nov 07, 2023 pm 01:16 PM

如何使用Workerman建立高可用性負(fù)載平衡系統(tǒng)，需要具體程式碼範(fàn)例在現(xiàn)代技術(shù)領(lǐng)域中，隨著網(wǎng)路的快速發(fā)展，越來越多的網(wǎng)站和應(yīng)用程式需要處理大量的並發(fā)請求。為了實(shí)現(xiàn)高可用性和高效能，負(fù)載平衡系統(tǒng)成為了必不可少的組件之一。本文將介紹如何使用PHP開源框架Workerman建構(gòu)一個(gè)高可用性的負(fù)載平衡系統(tǒng)，並提供具體的程式碼範(fàn)例。一、Workerman簡介Worke

實(shí)現(xiàn)Workerman文件中的文件傳輸功能 實(shí)現(xiàn)Workerman文件中的文件傳輸功能 Nov 08, 2023 pm 03:39 PM

Workerman是基於PHP開發(fā)的高效能非同步事件驅(qū)動(dòng)框架，它可以輕鬆實(shí)現(xiàn)TCP/UDP協(xié)定下的長連線開發(fā)。除此之外，Workerman也提供了實(shí)現(xiàn)檔案傳輸?shù)墓δ?，可以用於大檔案傳輸、資料備份等場景。本文將介紹如何在Workerman中實(shí)現(xiàn)檔案傳輸功能，並提供具體的程式碼範(fàn)例。一、文件上傳功能實(shí)現(xiàn)文件上傳功能需要客戶端將要上傳的文件傳送給服務(wù)端，服務(wù)端驗(yàn)證

See all articles