位置：首页-资讯-后端开发

workerman webman+GatewayWorker实现聊天室demo实例

2023-09-07 11:08

短信预约 -IT技能 免费直播动态提醒

workerman webman+GatewayWorker实现聊天室demo实例

说明

最近先来无事发现workerman的webman作为web框架很不错，想着写一个demo。于是就动手了，本人前端不太好，所以页面较丑，不要介意哈哈哈。

官方文档

https://www.workerman.net/

workerman 真的很不错，社区环境也不错，基本上有问题都有答复。有时间我也会多研究下，后面也会分享出来

重磅

demo地址: https://gitee.com/xiaoqiaoniubi/my-webman-chat

先下载下项目，将根目录下的webman-chat.sql 导入至数据库，数据库名称为：webman-chat。可在数据库配置文件中修改
执行 composer install
windows环境：直接双击根目录下的windows.bat的文件，并在网站中访问localhost:8787
linux环境：防火墙等开放7272端口（websocket），在根目录上执行 php start.php start

代码片段

服务端监听websocket：
位置：根目录/plugin/webman/gateway/Events.php

    public static function onWebSocketConnect($client_id, $data)    {        // 拿到连接时携带的token 查询uid        $getData = $data['get'];        $userModel = new User();        $userInfo = $userModel -> getUserInfoByToken($getData['token']);        if (empty($userInfo)) { // token过期            send($client_id,'账号信息错误，请重新登录',[                'type' => MsgType::LOGIN_ERROR,            ]);            sleep(1); // 延迟一秒断开链接            return Gateway::closeClient($client_id);        }        $uid = $userInfo -> id;        // 重复上线验证        if (count(Gateway::getClientIdByUid($uid)) > 0) {            send($client_id,'当前账号已在线,请换个账号',[                'type' => MsgType::ERROR,            ]);            sleep(1); // 延迟一秒断开链接            return Gateway::closeClient($client_id);        }        // uid 绑定 client_id        Gateway::bindUid($client_id,$uid);        // 用户是否创建过房间，是否显示创建房间 or 我的房间 按钮        $roomModel = new Room();        $roomInfo = $roomModel -> getUserRoom($uid);        $roomList = $roomModel -> getRoomListByIds();        send($client_id,'连接成功',[            'client_id' => $client_id,            'type' => MsgType::LOGIN,            'room_id' => empty($roomInfo) ? 0 : $roomInfo -> id,            'room_list' => $roomList,        ]);    }    public static function onMessage($client_id, $message)    {        $message = json_decode($message,true);        $data = $message['data'] ?? [];        switch ($message['type']) {            case MsgType::JOIN: // 加入房间                $userModel = new User();                $userInfo = $userModel -> getUserInfoByToken($data['token']);                // 加入房间                Gateway::joinGroup($client_id,$data['room_id']);                // 获取房间列表                $roomUserList = Gateway::getUidListByGroup($data['room_id']);                $finalUserList = [];                foreach ($roomUserList as $key => $val) {                    // 查询用户昵称                    $userInfo = $userModel -> getUserInfoByUid($val);                    $finalUserList[] = ['user_id' => $val,'nickname' => empty($userInfo) ? '未知用户' : $userInfo -> nickname];                }                // 向房间广播                send_to_group($data['room_id'],'请求成功',[                    'type' => MsgType::JOIN,                    'nickname' => $userInfo -> nickname,                    'online_num' => count($finalUserList),                    'online_list' => $finalUserList,                ]);                break;            case MsgType::SEND_MSG:                $userModel = new User();                $userInfo = $userModel -> getUserInfoByToken($data['token']);                // 广播到房间                send_to_group($data['room_id'],'请求成功',[                    'type' => MsgType::SEND_MSG,                    'send_user_nickname' => $userInfo -> nickname,                    'send_user_id' => $userInfo -> id,                    'send_content' => $data['content'],                ]);                break;            default:                send($client_id,'请求成功',['client_id' => $client_id]);                break;        }    }

客户端监听服务端websocket:
位置：根目录/public/static/chat_js/base.js

function onmessage(e) {    var data = JSON.parse(e.data);    var fullData = data;    data = data.data;    switch(data.type){        case 'login':            // 当前用户有房间则显示进入入口，否则显示创建入口            if (data.room_id > 0) {                $('.create_room .join_room').attr('data-room-id',data.room_id);                $('.create_room .join_room').show();                $('.do_create_room').hide();            } else {                $('.create_room .join_room').hide();                $('.do_create_room').show();            }            client_id = data.client_id;            // 房间列表更新            $('.room_list').empty();            var roomDom = '';            $.each(data.room_list,function(i,val) {                roomDom += '+val.id+'">'+val.room_name+'

';            });            $('.room_list').append(roomDom);            break;        case 'join':            $('.onlineNum').text(data.online_num);            // 重新渲染房间列表            $('.online_user_list').empty();            var onlineUserDom = '';            $.each(data.online_list, function(i,val){                onlineUserDom += '' +                    '用户'+(i+1)+'：' +                    ''+val.nickname+' 已加入' +                    '
'            });            $('.online_user_list').append(onlineUserDom);            break;        case 'send_msg':            var msgDom = '';            msgDom += ''+data.send_user_nickname+' 说：'+data.send_content+'
';            $('.msg_content').append(msgDom);            break;        case 'login_error':            showLogin();            break;        default:            break;    }}