ThinkPHP5 集成使用 GatewayWorker 进行即时通信的配置操作

- 环境
	框架：	ThinkPHP 5.1.2
	系统：	Windows10、CentOS7.2

【提示：】
	此处的代码开发，就是针对自己的业务，说的越多感觉会更糊涂，所以，此处建议参考官方文档

/**
     * 当客户端连接时触发
     * 如果业务不需此回调可以删除onConnect
     * @param int $client_id 连接id
     */
    public static function onConnect($client_id)
    {
        // 向当前 client_id 发送数据
        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 = '{"type":"send_to_uid","uid":"xxxxx", "message":"...."}'
       $message_data = json_decode($message,true);
       if ($message_data){
           //TODO 方便区分信息传递类型
           $type = $message_data['type'];
           // 发送人ID,此处为数据库中管理员的ID
           $from_id = $message_data['from_id'];
           // 接收人ID
           $to_id = isset($message_data['to_id'])?$message_data['to_id']:0;
           switch ($type){
               case 'bind':
                   //将client_id与uid绑定，用来唯一确定一个客户端用户或者设备
                   Gateway::bindUid($client_id,$from_id);
                   return;
               case 'online':
                   //判断接收人是否在线
                   $onlineStatus = Gateway::isUidOnline($to_id);
                   Gateway::sendToUid($from_id, json_encode(['type'=>'online','to_id'=>$to_id,'status'=>$onlineStatus]));
                   return;
               case 'say':
                   //发送文字
                   $text = nl2br(htmlspecialchars($message_data['content']));
                   $sayData = [
                       'type' => 'say',
                       'content' => $text,
                       'from_id' => $from_id,
                       'to_id' => $to_id,
                       'log_time' => time()
                   ];
                   if (Gateway::isUidOnline($to_id)){
                       $sayData['is_read'] = 1;
                       Gateway::sendToUid($to_id, json_encode($sayData));
                   }else{
                       $sayData['is_read'] = 0;
                   }
                   Gateway::sendToUid($from_id,json_encode($sayData));
                   return;
               case "say_img":
                   //发送图片
                   $img_name = $message_data['data'];
                   $sayData=[
                       'type'=>'say_img',
                       'from_id'=>$from_id,
                       'to_id'=>$to_id,
                       'content'=>$img_name,
                       'log_time' => time()
                   ];
                   if (Gateway::isUidOnline($to_id)){
                       Gateway::sendToUid($to_id,json_encode($sayData));
                   }
                   Gateway::sendToUid($from_id,json_encode($sayData));
                   return;
           }
       }else{
           return;
       }
   }

/**
 * 与 GatewayWorker 建立websocket连接，域名和端口改为你实际的域名端口，
 * 其中端口为 Gateway 端口，即 start_gateway.php 指定的端口。
 * start_gateway.php 中需要指定 websocket协议，像这样
 * $gateway = new Gateway(websocket://0.0.0.0:8282);
 */
var ws =  new WebSocket("ws://127.0.0.1:8282");
    ws.onmessage = function (e) {
        var message = eval('(' + e.data + ')');
        console.log('message', message);
        switch (message.type) {
            case 'init':
                changeNoReadLogs();
                var bind = '{"type":"bind","from_id":"' + from_id + '","to_id":"' + to_id + '"}';
                ws.send(bind);
                message_load();
                var online = '{"type":"online","from_id":"' + from_id + '","to_id":"' + to_id + '"}';
                ws.send(online);
                break;
            case 'online':
                if (message.status == 1) {
                    set_online_status(true);
                } else {
                    set_online_status(false);
                }
                return;
            case "say":
                if (to_id == message.from_id) {
                    var messagexx = '{"tag":"left","content":"' + message.content + '","type":"say","from_id":"' + from_id + '","to_id":"' + to_id + '"}';
                    To_send_message(messagexx, 'left',message.content);
                    if (message.is_read == 1) {
                        set_online_status(true);
                    } else {
                        set_online_status(false);
                    }
                    changeNoReadLogs();
                }
                save_message(message);
                return;
            case "say_img":
                if(from_id == message.to_id){
                    $(".chat-content").append(' <div class="chat-text section-left flex"><span class="char-img" style="background-image: url('+to_head+')"></span> <span class="text"><i class="icon icon-sanjiao4 t-32"></i><img width="120em" height="auto" src="'+message.content+'"></span> </div>');
                    $(".chat-content").scrollTop(3000);
                    changeNoReadLogs();
                }
                if (to_id == message.to_id) {
                    if (message.is_read == 1) {
                        set_online_status(true);
                    } else {
                        set_online_status(false);
                    }
                }
                save_message(message);
                return;
        }
    };

	对于上述的前端页面中，会出现大量的处理方法；
	注意，形如 "ws.send(message)" 的代码就是客户端向 GatewayWorker 服务端发送信息的操作；
	
	而出现的其他自定义方法，
	比如 "changeNoReadLogs()、message_load（）、save_message（）"
	一般都是向后台服务发送的业务异步处理请求操作；
	比如获取当前用户和一级管理员的聊天记录、处理发送人的未读消息、保存聊天记录 ...

Mixed Content: 
The page at 'https://www.fetow.com/cmsx.html' was loaded over HTTPS,
but attempted to connect to the insecure WebSocket endpoint
'ws://139.224.1.31:8283/'. 
This request has been blocked; this endpoint must be available over WSS.