Workerman之GatewayWorker框架 - 在线客服，实时通信

谁践踏了优雅 2022-02-28 01:58 288阅读 0赞

# 一、绑定用户id实现一对一客服聊天 #

[相关文档：LibGateway类提供的接口][LibGateway]

**JS：**

![clipboard.png][]

/**
         * 当客户端连接时触发
         * 如果业务不需此回调可以删除onConnect
         * 
         * @param int $client_id 连接id
         */
        public static function onConnect($client_id)
        {
            global $num;
            // 向当前client_id发送数据
            //Gateway::sendToClient($client_id, "Hello $client_id\r\n");
            // 向所有人发送
           // Gateway::sendToAll("$client_id login\r\n");
    
            echo "connect".++$num.":".$client_id."\n";
    
            Gateway::sendToClient($client_id,json_encode([
               'type'=>'init',
               'client_id'=>$client_id
           ]));
    
        }
        
       /**
        * 当客户端发来消息时触发
        * @param int $client_id 连接id
        * @param mixed $message 具体消息
        */
       public static function onMessage($client_id, $message)
       {
           $message_data = json_decode($message,true);
           if(!$message_data){
               return;
           }
           switch($message_data['type']){
               case "bind":
                   $fromid = $message_data['fromid'];
                   Gateway::bindUid($client_id, $fromid);
                   return;
               case "say":
    
                   $text = nl2br(htmlspecialchars($message_data['data']));
                   $fromid = $message_data['fromid'];
                   $toid = $message_data['toid'];
    
                   $date=[
                       'type'=>'text',
                       'data'=>$text,
                       'fromid'=>$fromid,
                       'toid'=>$toid,
                       'time'=>time()
                   ];
                    Gateway::sendToUid($toid, json_encode($date));
    //               Gateway::sendToAll(json_encode($date));
                   return;
           }
       }

**Test：**

![clipboard.png][clipboard.png 1]

![clipboard.png][clipboard.png 2]

# 二、数据持久化与优化两个聊天对象的唯一性 #

public static function onMessage($client_id, $message)
       {
           $message_data = json_decode($message,true);
           if(!$message_data){
               return;
           }
           switch($message_data['type']){
               case "bind":
                   $fromid = $message_data['fromid'];
                   Gateway::bindUid($client_id, $fromid);
                   return;
               case "say":
                   $text = nl2br(htmlspecialchars($message_data['data']));
                   $fromid = $message_data['fromid'];
                   $toid = $message_data['toid'];
    
                   $date=[
                       'type'=>'text',
                       'data'=>$text,
                       'fromid'=>$fromid,
                       'toid'=>$toid,
                       'time'=>time()
                   ];
    
                   if(Gateway::isUidOnline($toid)){
                       Gateway::sendToUid($toid, json_encode($date));
                       $date['isread']= 1;
                   }else{
                       $date['isread']=0;
                   }
    
                   $date['type']="save";
                   Gateway::sendToUid($fromid,json_encode($date));
    
                   return;
           }
       }

ws.onmessage = function(e){
    
           var message =  eval("("+e.data+")");
              switch (message.type){
                  case "init":
                       var bild = '{"type":"bind","fromid":"'+fromid+'"}';
                       ws.send(bild);
    
                      return;
                  case "text":
                      //指定两个聊天对象聊天
                          if(toid==message.fromid) {
    
                              $(".chat-content").append(' <div class="chat-text section-left flex"> <span class="text"><i class="icon icon-sanjiao4 t-32"></i>' + message.data + '</span> </div>');
                          }
                      return;
                  case "save":
                      //数据持久化
                      save_message(message);
                      return;
              }
        }

# 三、发图片、QQ表情、聊天列表、所有页面websocket，消息推送、实时更新 #

![clipboard.png][clipboard.png 3]

![clipboard.png][clipboard.png 4]

![clipboard.png][clipboard.png 5]

**相关代码：**[https://github.com/tcyfree/ch...][https_github.com_tcyfree_ch...]

[**参考教程：**workerman实战之PHP在线客服][workerman_PHP]

[LibGateway]: http://doc2.workerman.net/lib-gateway-functions.html
[clipboard.png]: /images/20220228/d55f77076e654f42b7a402ee924a9051.png
[clipboard.png 1]: /images/20220228/63935da84b584306b0eb093e651b14aa.png
[clipboard.png 2]: /images/20220228/90cad9abf33d40cab4e62beb20531eb8.png
[clipboard.png 3]: /images/20220228/ae6a358f804d42a5898edf57c2067c67.png
[clipboard.png 4]: /images/20220228/c8dcc084b40a4c8d88acb423fcc834cf.png
[clipboard.png 5]: /images/20220228/78742d0681f24e818527b7f0ac82702a.png
[https_github.com_tcyfree_ch...]: https://github.com/tcyfree/chat_gateway_tp
[workerman_PHP]: http://study.163.com/course/courseMain.htm?courseId=1005015012