使用workerman實如今線聊天-初版

時間 2019-12-10

標籤使用 workerman 如今聊天初版简体版

原文原文鏈接

workerman 是一個php編寫的通信服務。以前的項目都是用它作數據接口服務javascript

此次用它作一個簡單的在線聊天室~php

1.下載最新版本的workermanhtml

能夠去 http://www.workerman.net 去下載java

我這裏將service 和 client 分開了兩個文件夾，方便管理mysql

大體的項目結構以下。web

客戶端：sql

客戶端就簡單了。一個簡單的html代碼。嵌入了一個 websocket 監聽服務數據庫

var ws, name, client_list={};

function connect() {
       // 建立websocket
       ws = new WebSocket("ws://192.168.0.88:2345");
       // 當socket鏈接打開時，輸入用戶名
       ws.onopen = onopen;
       // 當有消息時根據消息類型顯示不一樣信息
       ws.onmessage = onmessage; 
       ws.onclose = function() {
    	  console.log("鏈接關閉，定時重連");
          connect();
       };
       ws.onerror = function() {
     	  console.log("出現錯誤");
       };
    }

實現websocket的打開，message的監聽，以及close json

一、當打開一個客戶端，則立馬彈出一個輸入姓名的對話框數組

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);
    }

並將數據推送給服務端。type =1 表明登錄。

二、當收到消息時，判斷消息類型，是羣發消息仍是私聊消息。進而處理。

另外，每次用戶有新用戶登錄上來，都會給各個客戶端推送，用戶列表。進行渲染

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

而後另外就是每一個用戶發送消息的代碼了。能夠是私聊，也能夠是羣發

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

客戶端差很少就是這樣的了。

客戶端，有幾個坑，

坑一、變量名是 name 則刷新網頁不會被重置，不然就會被重置。（後面查資料發現，這個name變量是 window.name 。因此刷新網頁該值也不會被刷新掉）

坑二、js組數組，變量要用"" 最外層爲'' 如：data='{"type":"1","user":"'+name+'"}'; 不然解析出問題。不能倒過來！

服務端：

服務端主要是workerman 組件以及使用 Channel分佈式通信組件實現訂閱和集羣推送分組推送以及私聊。

首先，固然是監聽，啓用一個worker的websocket監聽

// 建立一個Worker監聽2346端口，使用websocket協議通信
$ws_worker = new Worker("websocket://0.0.0.0:2345");

　　$channel_server = new Channel\Server('0.0.0.0', 2206);

// 啓動4個進程對外提供服務
$ws_worker->count = 4;

$ws_worker->name="kinmoschat";

在workerman 監聽啓用的時候，進行 channel通信的註冊。

$ws_worker->onWorkerStart=function($ws_worker)
{
    // channel 客戶端連接上 服務器
    Channel\Client::connect('127.0.0.1',2206);
    $event_name='私聊';
    // 訂閱 worker-<id 事件，並註冊事件處理函數
    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['to_connection_id'];
        $message=$event_data['content'];

        foreach ($ws_worker->connections as $connection) {

            if($connection->id==$to_connect_id)
            {
                $connection->send($message);
            }
                
        }

        // if(!isset($ws_worker->connections[$to_connect_id]))
        // {
        //     echo 'connect is not exist\n';
        //     return;
        // }
        // $to_connection=$ws_worker->connections[$to_connect_id];
        // $to_connection->send($message);
    });

    // 訂閱廣播事件
    $event_name = '廣播';
    // 收到廣播 向全部客戶端發送消息
    Channel\Client::on($event_name,function($event_data)use($ws_worker){
        //print_r($event_data);
        $message=$event_data['content'];
        foreach ($ws_worker->connections as $connection) {
            $connection->send($message);
        }
    });
};

註冊兩個事件，一個廣播事件，一個私聊事件，用以上線通知的廣播，以及羣發消息。私聊就是私聊了。。這裏，還能夠作分組的羣發。不過，這個版本還未實現。

而後是針對，客戶端連接的回調。

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

　　這裏，客戶端回調，我會將客戶端的 connectid修改掉。一個簡單的md5 主要是爲了防止流水id太容易被利用吧。。

而後，整個項目的主體，服務端消息的處理回調。

針對每一個進來的客戶端，分配一個惟一 id
維護一個 connectid=>user 的關係表
因爲開啓了多個進程致使存到 session中無效，故而打算存到數據庫中
斷開連接的時候，刪除數據

$ws_worker->onMessage = function($connection, $data)
{
    $res=array('code'=>200, 'msg'=>'ok', 'data'=>null,'type'=>1);
    // 向客戶端發送hello $data
    //print_r($data);
    $data=json_decode($data,true);
    //print_r($data);
    if(!isset($data['type'])||empty($data['type']))// type 1  2
    {
        $res=array('code'=>301, 'msg'=>'消息包格式錯誤', 'data'=>null);
    }else{
        switch ($data['type']) {
            case '1': // 客戶端上線消息
                //print_r($connection->id);
                
                if(!isset($data['user'])||empty($data['user']))
                {
                    $res=array('code'=>301, 'msg'=>'消息包格式錯誤', 'data'=>null);
                    break;
                }
                // 維護一個數組 保存 用戶 connection_id => user

                $dsn='mysql:host=127.0.0.1;dbname=kinmoschat;';
                $pdo=new PDO($dsn,'root','123456');
                //準備SQL語句
                $sql = "INSERT INTO `user`(`connect_id`,`username`) VALUES (:connect_id,:username)";

                //調用prepare方法準備查詢
                $stmt = $pdo->prepare($sql);

                //傳遞一個數組爲預處理查詢中的命名參數綁定值，並執行SQL
                $stmt->execute(array(':connect_id' => $connection->id,':username' => $data['user']));
                //獲取最後一個插入數據的ID值
                //echo $pdo->lastInsertId() . '<br />';

                // 向本身推送一條消息
                $res2['type']=3;// 系統信息
                $res2['data']=array('userinfo' =>$data['user']);// 系統信息
                $connection->send(json_encode($res2));

                $msg="用戶 ".$data['user']." 上線了~~";
                $res['data']=$msg;
                break;
            case '2': // 客戶端羣發送消息
                if(!isset($data['user'])||empty($data['user'])||!isset($data['msg'])||empty($data['msg']))
                {
                    $res=array('code'=>301, 'msg'=>'消息包格式錯誤', 'data'=>null);
                    break;
                }
                $msg="用戶 ".$data['user']."說：".$data['msg'];
                $res['data']=$msg;
                break;
            case '3': // 客戶端私聊
                if(!isset($data['user'])||empty($data['user'])||!isset($data['msg'])||empty($data['msg'])||!isset($data['friend_id'])||empty($data['friend_id']))
                {
                    $res=array('code'=>301, 'msg'=>'消息包格式錯誤', 'data'=>null);
                    break;
                }
                $msg="用戶 ".$data['user']."對您說：".$data['msg'];
                $res['data']=$msg;
                $res['type']=1;// 聊天消息
                $res1=json_encode($res);
                // 推送給單個用戶
                $event_name = '私聊';
                Channel\Client::publish($event_name, array(
                    'content'          => $res1,
                    'to_connection_id' =>$data['friend_id']
                ));
                // 另外還要給本身推條消息
                $msg="您對 ".$data['friendname']."說：".$data['msg'];
                $res['data']=$msg;
                $res['type']=1;// 聊天消息
                $res2=json_encode($res);
                Channel\Client::publish($event_name, array(
                    'content'          => $res2,
                    'to_connection_id' =>$connection->id
                ));
                return;
                break;
            
            default:
                # code...
                break;
        }
    }
    $res['type']=1;// 聊天消息
    $res=json_encode($res);
    // 廣播給全部客戶端
    $event_name = '廣播';
    Channel\Client::publish($event_name, array(
        'content'          => $res
    ));

    $dsn='mysql:host=127.0.0.1;dbname=kinmoschat;';
    $dbh=new PDO($dsn,'root','123456');
    $stmt=$dbh->query('SELECT connect_id,username FROM user');
    $row=$stmt->fetchAll();
    $uerHtml="";
    foreach ($row as $key => $value) {

        $uerHtml.='<a class="user" onclick="userclick(\''.$value['username'].'\',\''.$value['connect_id'].'\');" value="'.$value['connect_id'].'" href="javascript:void(0);">'.$value['username'].'</a><br/>';
    }
    //print_r($row);
    $res1['type']=2;// 用戶消息
    $res1['data']=$uerHtml;
    $res1=json_encode($res1);
    

    $event_name = '廣播';
    Channel\Client::publish($event_name, array(
        'content'          => $res1
    ));
};

這裏會將每一個用戶的 connectid=>name 存入數據庫。。

當收到一條上線消息的時候，廣播給全部用戶。

收到一條羣發消息。。廣播給全部客戶端。

收到一條私聊消息。則單個推送給本身以及發送的人。

監聽客戶端關閉事件，當客戶端關閉，刪除用戶表相關記錄

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

簡單版 demo http://chat.kinmos.cn/

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。