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

背景 首先，最近鄙人想在后台管理系统中添加一个； 可以跟其他管理员交流的即时通讯的小窗口； 同时也是一种学习积累； 在资源比较中我认为

GatewayWorker

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

GatewayWorker 手册 (推荐详细阅读哦！)

Workerman

TCP长连接

app 推送服务端、即时IM服务端、游戏服务端、物联网、智能家居

官方下载地址

【百度网盘备份 (提取码：ahn3)】

"extend"

官方 — 与 ThinkPHP 框架的结合

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

"\extend\GatewayWorker\Applications\YourApp\Events.php"

/**     * 当客户端连接时触发     * 如果业务不需此回调可以删除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('  @@##@@ ');                    $(".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（）"一般都是向后台服务发送的业务异步处理请求操作；比如获取当前用户和一级管理员的聊天记录、处理发送人的未读消息、保存聊天记录 ...

【注意】:

ws://127.0.0.1:8282

ws://139.xxx.x.xx:8282

wss://www.wenjiehorse.com/wss

Linux 环境或者是 macOS

php start.php start

php start.php start -d

php start.php stop

php start.php restart

php start.php reload

php start.php status

【附录】

【报错信息】

https

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.

截图如下：

此时，根据在实际操作中遇到的情况，最需掌握的就是 【

创建wss服务的技巧

深入理解 GatewayWorker 框架

HTTPS站点使用WebSocket的常见错误及解决方案