GatewayWorker + LayIM實現即時聊天

時間  2019-11-16
標籤 gatewayworker layim 實現 即時 聊天 简体版
原文   原文鏈接

1、程序目錄結構php

2、代碼展現css

附LayIM開發文檔：https://www.layui.com/doc/modules/layim.htmlhtml

一、前端代碼前端

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>websocket鏈接</title>
    <link rel="stylesheet" href="./layui/css/layui.css" media="all">
    <script src="./layui/jquery.min.js"></script>
    <script src="./layui/layui.js"></script>
</head>
<body style="background: url(./layui/images/irongrip.png) repeat">
    
</body>
<script>
    layui.use('layim', function(layim){
    //基礎配置
    layim.config({
        //獲取主面板列表信息
        init: {
          url: "./getUserList.php?id=<?php echo $_GET['id']?>" //接口地址（返回的數據格式見下文）
          ,type: 'get' //默認get，通常可不填
          ,data: {} //額外參數
        }
        //獲取羣員接口
        ,members: {
          url: "./getMembers.php" //接口地址（返回的數據格式見下文）
          ,type: 'get' //默認get，通常可不填
          ,data: {} //額外參數
        },
        uploadFile: {
            url: ""
        }
        ,uploadImage: {
            url: ""
        }
        ,brief: false //是否簡約模式（默認false，若是隻用到在線客服，且不想顯示主面板，能夠設置 true）
        ,title: '個人LayIM' //主面板最小化後顯示的名稱
        ,maxLength: 3000 //最長髮送的字符長度，默認3000
        ,isfriend: true //是否開啓好友（默認true，即開啓）
        ,isgroup: true //是否開啓羣組（默認true，即開啓）
        ,right: '0px' //默認0px，用於設定主面板右偏移量。該參數可避免遮蓋你頁面右下角已經的bar。
        ,chatLog: "" //聊天記錄地址（若是未填則不顯示）
        ,find: "" //查找好友/羣的地址（若是未填則不顯示）
        ,copyright: false //是否受權，若是經過官網捐贈得到LayIM，此處可填true
    });

    var socket = new WebSocket("ws://127.0.0.1:7272");
    socket.onopen = function(){
        <?php 

            $id = $_GET['id'];
            $conn = @mysql_connect("127.0.0.1", "root", "root") or die("鏈接數據庫失敗");
            mysql_select_db("layim");
            $rows = mysql_query("select * from snake_chatuser where id = $id");
            $info = array();
            while ($row = mysql_fetch_array($rows)) {
                $info = $row;
            }
        ?>
        var id = '<?php echo $info['id'];?>';
        var username = '<?php echo $info['username'];?>';
        var avatar = '<?php echo $info['avatar'];?>';
        var sign = '<?php echo $info['sign'];?>';
        //登陸
        var login_data = '{"type":"init","id":"'+id+'","username":"'+username+'","avatar":"'+avatar+'","sign":"'+sign+'"}';
        socket.send( login_data );
        console.log("websocket握手成功!"); 
    };

    //監聽收到的消息
    socket.onmessage = function(res){
        // console.log(res);
        var data = eval("("+res.data+")");
        switch(data['message_type']){
            // 服務端ping客戶端
            case 'ping':
                socket.send('{"type":"ping"}');
                break;
            // 登陸 更新用戶列表
            case 'init':
                //console.log(data['id']+"登陸成功");
                //layim.getMessage(res.data); //res.data即你發送消息傳遞的數據（閱讀：監聽發送的消息）
                break;
            //添加 用戶
            case 'addUser':
                //console.log(data.data);
                layim.addList(data.data);
                break;
            //刪除 用戶
            case 'delUser':
                layim.removeList({
                    type: 'friend'
                    ,id: data.data.id //好友或者羣組ID
                });
                break;
            // 添加 分組信息
            case 'addGroup':
               // console.log(data.data);
                layim.addList(data.data);
                break;
            case 'delGroup':
                layim.removeList({
                    type: 'group'
                    ,id: data.data.id //好友或者羣組ID
                });
                break;
            // 檢測聊天數據
            case 'chatMessage':
                //console.log(data.data);
                layim.getMessage(data.data);
                break;
            // 離線消息推送
            case 'logMessage':
            console.log(1);
                setTimeout(function(){layim.getMessage(data.data)}, 1000);
                break;
            // 用戶退出 更新用戶列表
            case 'logout':
                break;
            //聊天還有不在線
            case 'ctUserOutline':
                console.log('11111');
                //layer.msg('好友不在線', {'time' : 1000});
                break;
               
        }
    };

    //layim創建就緒
    layim.on('ready', function(res){

        layim.on('sendMessage', function(res){
            console.log(res);
            // 發送消息
            var mine = JSON.stringify(res.mine);
            var to = JSON.stringify(res.to);
            var login_data = '{"type":"chatMessage","data":{"mine":'+mine+', "to":'+to+'}}';
            socket.send( login_data );

        });
    });
});
    
</script>
</html>

二、後臺核心代碼mysql

<?php
use \GatewayWorker\Lib\Gateway;
use \GatewayWorker\Lib\Db;
/**
 * 主邏輯
 * 主要是處理 onConnect onMessage onClose 三個方法
 * onConnect 和 onClose 若是不須要能夠不用實現並刪除
 */
class Events
{
  public static function onConnect($client_id) {
    
  }
   /**
    * 當客戶端發來消息時觸發
    * @param int $client_id 鏈接id
    * @param mixed $message 具體消息
    */
   public static function onMessage($client_id, $data) {
       $message = json_decode($data, true);
       $message_type = $message['type'];
       switch($message_type) {
           case 'init':
               // uid
               $uid = $message['id'];
               // 設置session
               $_SESSION = [
                   'username' => $message['username'],
                   'avatar'   => $message['avatar'],
                   'id'       => $uid,
                   'sign'     => $message['sign']
               ];

               // 將當前連接與uid綁定
               Gateway::bindUid($client_id, $uid);
               // 通知當前客戶端初始化
               $init_message = array(
                   'message_type' => 'init',
                   'id'           => $uid,
               );
               Gateway::sendToClient($client_id, json_encode($init_message));

               //查詢最近1周有無須要推送的離線信息
               $db1 = Db::instance('db1');  //數據庫連接
               $time = time() - 7 * 3600 * 24;
               $resMsg = $db1->select('id,fromid,fromname,fromavatar,timeline,content')->from('snake_chatlog')
                   ->where("toid= {$uid} and timeline > {$time} and type = 'friend' and needsend = 1" )
                   ->query();
                //var_export($resMsg);
               if( !empty( $resMsg ) ){

                   foreach( $resMsg as $key=>$vo ){

                       $log_message = [
                           'message_type' => 'logMessage',
                           'data' => [
                               'username' => $vo['fromname'],
                               'avatar'   => $vo['fromavatar'],
                               'id'       => $vo['fromid'],
                               'type'     => 'friend',
                               'content'  => htmlspecialchars( $vo['content'] ),
                               'timestamp'=> $vo['timeline'] * 1000,
                           ]
                       ];

                       Gateway::sendToUid( $uid, json_encode($log_message) );

                       //設置推送狀態爲已經推送
                       $db1->query("UPDATE `snake_chatlog` SET `needsend` = '0' WHERE id=" . $vo['id']);

                   }
               }

               //查詢當前的用戶是在哪一個分組中,將當前的連接加入該分組
               $ret = $db1->query("select `groupid` from `snake_groupdetail` where `userid` = {$uid} group by `groupid`");
               if( !empty( $ret ) ){
                   foreach( $ret as $key=>$vo ){
                       Gateway::joinGroup($client_id, $vo['groupid']);  //將登陸用戶加入羣組
                   }
               }
               unset( $ret );
               return;
               break;
           case 'addUser' :
               //添加用戶
               $add_message = [
                   'message_type' => 'addUser',
                   'data' => [
                       'type' => 'friend',
                       'avatar'   => $message['data']['avatar'],
                       'username' => $message['data']['username'],
                       'groupid'  => $message['data']['groupid'],
                       'id'       => $message['data']['id'],
                       'sign'     => $message['data']['sign']
                   ]
               ];
               Gateway::sendToAll( json_encode($add_message), null, $client_id );
               return;
               break;
           case 'delUser' :
               //刪除用戶
               $del_message = [
                   'message_type' => 'delUser',
                   'data' => [
                       'type' => 'friend',
                       'id'       => $message['data']['id']
                   ]
               ];
               Gateway::sendToAll( json_encode($del_message), null, $client_id );
               return;
               break;
           case 'addGroup':
               //添加羣組
               $uids = explode( ',', $message['data']['uids'] );
               $client_id_array = [];
               foreach( $uids as $vo ){
                    $ret = Gateway::getClientIdByUid( $vo );  //當前組中在線的client_id
                    if( !empty( $ret ) ){
                        $client_id_array[] = $ret['0'];

                        Gateway::joinGroup($ret['0'], $message['data']['id']);  //將這些用戶加入羣組
                    }
               }
               unset( $ret, $uids );

               $add_message = [
                   'message_type' => 'addGroup',
                   'data' => [
                       'type' => 'group',
                       'avatar'   => $message['data']['avatar'],
                       'id'       => $message['data']['id'],
                       'groupname'     => $message['data']['groupname']
                   ]
               ];
               Gateway::sendToAll( json_encode($add_message), $client_id_array, $client_id );
               return;
               break;
           case 'joinGroup':
               //加入羣組
               $uid = $message['data']['uid'];
               $ret = Gateway::getClientIdByUid( $uid ); //若在線實時推送
               if( !empty( $ret ) ){
                   Gateway::joinGroup($ret['0'], $message['data']['id']);  //將該用戶加入羣組

                   $add_message = [
                       'message_type' => 'addGroup',
                       'data' => [
                           'type' => 'group',
                           'avatar'   => $message['data']['avatar'],
                           'id'       => $message['data']['id'],
                           'groupname'     => $message['data']['groupname']
                       ]
                   ];
                   Gateway::sendToAll( json_encode($add_message), [$ret['0']], $client_id );  //推送羣組信息
               }

               return;
               break;
           case 'addMember':
               //添加羣組成員
               $uids = explode( ',', $message['data']['uid'] );
               $client_id_array = [];
               foreach( $uids as $vo ){
                   $ret = Gateway::getClientIdByUid( $vo );  //當前組中在線的client_id
                   if( !empty( $ret ) ){
                       $client_id_array[] = $ret['0'];

                       Gateway::joinGroup($ret['0'], $message['data']['id']);  //將這些用戶加入羣組
                   }
               }
               unset( $ret, $uids );

               $add_message = [
                   'message_type' => 'addGroup',
                   'data' => [
                       'type' => 'group',
                       'avatar'   => $message['data']['avatar'],
                       'id'       => $message['data']['id'],
                       'groupname'     => $message['data']['groupname']
                   ]
               ];
               Gateway::sendToAll( json_encode($add_message), $client_id_array, $client_id );  //推送羣組信息
               return;
               break;
           case 'removeMember':
               //將移除羣組的成員的羣信息移除，並從討論組移除
               $ret = Gateway::getClientIdByUid( $message['data']['uid'] );
               if( !empty( $ret ) ){

                   Gateway::leaveGroup($ret['0'], $message['data']['id']);

                   $del_message = [
                       'message_type' => 'delGroup',
                       'data' => [
                           'type' => 'group',
                           'id'       => $message['data']['id']
                       ]
                   ];
                   Gateway::sendToAll( json_encode($del_message), [$ret['0']], $client_id );
               }

               return;
               break;
           case 'delGroup':
               //刪除羣組
               $del_message = [
                   'message_type' => 'delGroup',
                   'data' => [
                       'type' => 'group',
                       'id'       => $message['data']['id']
                   ]
               ];
               Gateway::sendToAll( json_encode($del_message), null, $client_id );
               return;
               break;
           case 'chatMessage':
               $db1 = Db::instance('db1');  //數據庫連接
               // 聊天消息
               $type = $message['data']['to']['type'];
               $to_id = $message['data']['to']['id'];
               $uid = $message['data']['mine']['id'];
 
               $chat_message = [
                    'message_type' => 'chatMessage',
                    'data' => [
                        'username' => $message['data']['mine']['username'],
                        'avatar'   => $message['data']['mine']['avatar'],
                        'id'       => $type === 'friend' ? $uid : $to_id,
                        'type'     => $type,
                        'content'  => htmlspecialchars($message['data']['mine']['content']),
                        'timestamp'=> time()*1000,
                    ]
               ];
               //聊天記錄數組
               $param = [
                   'fromid' => $uid,
                   'toid' => $to_id,
                   'fromname' => $message['data']['mine']['username'],
                   'fromavatar' => $message['data']['mine']['avatar'],
                   'content' => htmlspecialchars($message['data']['mine']['content']),
                   'timeline' => time(),
                   'needsend' => 0
               ];
               switch ($type) {
                   // 私聊
                   case 'friend':
                       // 插入
                       $param['type'] = 'friend';
                       if( empty( Gateway::getClientIdByUid( $to_id ) ) ){
                           $param['needsend'] = 1;  //用戶不在線,標記此消息推送
                       }
                       $db1->insert('snake_chatlog')->cols( $param )->query();
                       return Gateway::sendToUid($to_id, json_encode($chat_message));
                   // 羣聊
                   case 'group':
                       $param['type'] = 'group';
                       $db1->insert('snake_chatlog')->cols( $param )->query();
                       return Gateway::sendToGroup($to_id, json_encode($chat_message), $client_id);
               }
               return;
               break;
           case 'hide':
           case 'online':
               $status_message = [
                   'message_type' => $message_type,
                   'id'           => $_SESSION['id'],
               ];
               $_SESSION['online'] = $message_type;
               Gateway::sendToAll(json_encode($status_message));
               return;
               break;
           case 'ping':
               return;
           default:
               echo "unknown message $data" . PHP_EOL;
       }
   }
   
   /**
    * 當用戶斷開鏈接時觸發
    * @param int $client_id 鏈接id
    */
   public static function onClose($client_id) {
       $logout_message = [
           'message_type' => 'logout',
           'id'           => $_SESSION['id']
       ];
       Gateway::sendToAll(json_encode($logout_message));
   }
}

3、頁面效果圖jquery

 

有須要瞭解的加QQ：2575404985，能夠兼容linux與windowslinux

在linux下運行方式，在workerman目錄下建立start.sh，代碼以下：web

#!/bin/bash
php ./Applications/start_register.php start &
php ./Applications/start_gateway.php start &
php ./Applications/start_businessworker.php start &

 4、案例sql

 

 

 

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程