怎么用Swoole扩展结合Yii框架和layui实现聊天系统

这篇文章主要讲解了“怎么用Swoole扩展结合Yii框架和layui实现聊天系统”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“怎么用Swoole扩展结合Yii框架和layui实现聊天系统”吧！

创新互联是一家集网站建设,漳浦企业网站建设,漳浦品牌网站建设,网站定制,漳浦网站建设报价,网络营销,网络优化,漳浦网站推广为一体的创新建站企业，帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿，时刻以成就客户成长自我，坚持不断学习、思考、沉淀、净化自己，让我们为更多的企业打造出实用型网站。

一、功能描叙利用Swoole扩展结合Yii框架和layui 的聊天系统

1、完成了登录和注册功能

2、完成了群聊和单聊功能

二、预览效果展示

三、部分代码展示

1、socket 代码写在yii 的console下面 单独用了一个controller 来整理swoole扩展的功能

``set([ 'daemonize' =>true, //守护进程 'log_file' => '/usr/local/var/www/blog/logs/swoole_websocket_logs.log', //日志纪录 'heartbeat_check_interval' => 60,//60秒轮询连接数

    ]);
    $server->on('open', function (\swoole_websocket_server $server, $request) {
        echo "server: handshake success with fd{$request->fd}\n";
        $fd[] = $request->fd;
        $GLOBALS['fd'][] = $fd;
        //array_push($this->fdArr,$request->fd);//$request->fd;

    });
    $server->on('message', function (\swoole_websocket_server $server, $frame) {

        $message_data = json_decode($frame->data, true);
        echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";

        if(!$message_data)
        {
            return ;
        }
        switch($message_data['type'])
        {
            case 'pong':
                return;
            case 'login':
                $client_name = htmlspecialchars($message_data['client_name']);
                $new_message = array('type'=>$message_data['type'], 'client_id'=>$frame->fd, 'client_name'=>htmlspecialchars($client_name), 'time'=>date('Y-m-d H:i:s'));
                if(!isset($message_data['admin_id']) || empty($message_data['admin_id']))
                {
                    return ;
                }
                //绑定uid和fd
                User::BindFd($message_data['admin_id'],$frame->fd);


                //广播给所有在线用户
                foreach($server->connection_list() as $fd) {
                    $server->push($fd, Json::encode($new_message));
                }
                return;
            case 'say': //单人发送信息
                $client_name = htmlspecialchars($message_data['to_client_name']);

                if(!isset($message_data['to_client_id']) || empty($message_data['to_client_id']))
                {
                    return ;
                }
                //通过uid 获取fd
                $fd = User::getFdByUid($message_data['to_client_id']);
                $new_message = array(
                    'type'=>'say',
                    'from_client_id'=>isset($message_data['from_client_id']) ? $message_data['from_client_id'] : 0,
                    'from_client_name'=>isset($message_data['from_client_name']) ? $message_data['from_client_name'] : 0,
                    'to_client_name' =>$client_name,
                    'avatar' => 'http://tp2.sinaimg.cn/1783286485/180/5677568891/1',
                    'to_client_id'=>$message_data['to_client_id'],
                    'content'=>nl2br(htmlspecialchars($message_data['content'])),
                    'time'=>date('Y-m-d H:i:s'),
                );
                $server->push($fd, Json::encode($new_message));
                return;
            case 'group'://群组发送
                $client_name = htmlspecialchars($message_data['to_client_name']);

                if(!isset($message_data['to_client_id']) || empty($message_data['to_client_id']))
                {
                    return ;
                }
                $new_message = array(
                    'type'=>'group',
                    'from_client_id'=>isset($message_data['from_client_id']) ? $message_data['from_client_id'] : 0,
                    'from_client_name'=>isset($message_data['from_client_name']) ? $message_data['from_client_name'] : 0,
                    'to_client_name' =>$client_name,
                    'avatar' => 'http://tp2.sinaimg.cn/1783286485/180/5677568891/1',
                    'to_client_id'=>$message_data['to_client_id'],
                    'content'=>nl2br(htmlspecialchars($message_data['content'])),
                    'time'=>date('Y-m-d H:i:s'),
                );
                //暂时将所有信息都广播给除自己之外的所有用户 后期再做这部分的优化信息
                foreach($server->connection_list() as $fd) {

                    if($fd == $frame->fd) continue;
                    $server->push($fd, Json::encode($new_message));
                }
                return;
            default:
                return;
        }

    });

    $server->on('close', function ($server, $fd) {

        $userInfo = User::getUidByFd($fd);
        $new_message = [
            'type' =>'logout',
            'name' => $userInfo->username,
        ];
        foreach($server->connection_list() as $_fd) {

            if($fd == $_fd) continue;
            $server->push($_fd, Json::encode($new_message));
        }
        echo "client {$fd} closed\n";
    });

    $server->start();
}

}

感谢各位的阅读，以上就是“怎么用Swoole扩展结合Yii框架和layui实现聊天系统”的内容了，经过本文的学习后，相信大家对怎么用Swoole扩展结合Yii框架和layui实现聊天系统这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是创新互联，小编将为大家推送更多相关知识点的文章，欢迎关注！