简体中文(ZH-CN) English(EN) 繁体中文(ZH-TW) 日本語(JA) 한국어(KO) Melayu(MS) Français(FR) Deutsch(DE)
首页 > 后端开发 > php教程 > 正文

一个简单QQ群聊案例代码解析(PHP实现)

易达
发布： 2023-04-08 18:12:02
原创
3567 人浏览过

问题：

使用面向对象编程的方式实现以下业务逻辑：

1.       张三使用账号a,密码b登录了qq

2.       显示出张三最后的登录的时间

3.       张三查看了 1小时内的行政部门群的信息（这个群里有张三，李四，王五，其中张三是群主）

4.       输出张三看到的这些信息

5.       突然张三收到好友李四的信息：信息叫：张三，我是李四，你在干嘛（张三创建了一个好友组，里面有好友李四）

6.       张三回复李四：我在想你呀

首先我们来分析一下

1、流程分析

1.张三使用账号a,密码b登录了qq

2.显示出张三最后的登录的时间

3.张三查看了 1个小时内的行政部门群的信息（这个群里有张三，李四，王五，其中张三是群主）

4.输出张三看到的这些信息

5.李四发送消息给张三，信息为：张三，我是李四，你在干嘛

6.张三发送消息给李四，信息为：我在想你呀

2、功能分析：

1.识别对象

 QQ会员，QQ会员登录信息，QQ会员消息，QQ会员群， QQ会员和群的关系（一对多）

2.识别对象的属性

 QQ会员： 

     属性：id,姓名，账号，密码

 QQ会员登录信息：（一个会员可以多次登录，有多条登录记录）

      属性：id,会员id,登录时间

QQ会员消息：属性：id,内容，发送时间，发送人，接收人，状态(已读,未读),查看时间

QQ会员群： 属性：id,创建会员,群名称，群的创建时间

QQ会员和群的关系:(这种关系也是一个类，也可以产生很多的实例)

       属性：id,user_id,group_id,create_time

3.识别对象的方法

QQ会员：

方法：

    1.登录 ,

    2.查看消息

    3.发送消息

QQ会员登录信息：

    1.保存会员的登录信息

    2.获取用户最后的登录信息

QQ会员消息：

    方法：修改状态（可以被修改为已读），获取会员消息，添加会员消息

QQ会员群：

方法：1.获取所有的群  2.创建群(张三查看行政部门群,说明这个群肯定是被某个人创建的)

QQ会员和群的关系：

方法：1.根据会员查看她所有的群 = 获取会员所有的群

          2.根据一个群，可以查看这个群里的所有成员

 3、数据库分析：

1.QQ会员：其中属性对应的就是表中的字段

2.QQ会员消息：其中属性对应的就是表中的字段

3.QQ会员群：其中属性对应的就是表中的字段

4.QQ会员和群的中间表 :因为一个会员可以从属于多个会员群，所以需要有张这个表

       字段：id,会员id,群id,入群时间

5.QQ会员登录信息列表

分析完成后，我们来具体的操作

1、创建数据库,初始化数据

创建数据库，名字我们尽量通俗易懂点好，就叫做qq

一个简单QQ群聊案例代码解析(PHP实现)

创建表qq_group表 会员组 

一个简单QQ群聊案例代码解析(PHP实现)

创建表qq_msg 消息表

一个简单QQ群聊案例代码解析(PHP实现)

创建表qq_user 会员表

一个简单QQ群聊案例代码解析(PHP实现)

创建表qq_user_group_relation会员和组的关系表

一个简单QQ群聊案例代码解析(PHP实现)

创建表 qq_user_login_record 会员登录信息记录表

一个简单QQ群聊案例代码解析(PHP实现)

初始化数据，哪些是项目的启动数据呢

1、会员有张三，李四，王五，他们分别有账号密码

2、有2个组 行政部门群组，好友组

3、张三创建了行政部门群，张三，李四，王五都在该群里

4、张三还创建了好友组，里面有李四

接下里我们把这些数据填入数据库中

1、会员有张三，李四，王五，他们分别有账号密码（qq_user）

1一个简单QQ群聊案例代码解析(PHP实现)

2、有2个组 行政部门群组，好友组(qq_group)

2一个简单QQ群聊案例代码解析(PHP实现)

3、张三创建了行政部门群，张三，李四，王五都在该群里

4、张三还创建了好友组，里面有李四 (qq_user_group_relation)

3一个简单QQ群聊案例代码解析(PHP实现)

为了让行政群里能有消息，我们先试着在消息表里添加一条记录

4一个简单QQ群聊案例代码解析(PHP实现)

2、创建类，实现类

根据分析，我们应该至少要创建5个类，但是所有的类都需要数据库连接，所以我们可以单独创建一个数据库类，所以有6个类需要创建

为了方便管理，我们把这些类都放到model目录中

model/Mysql.class.php

<?php
//数据库连接类
class Mysql{
    //属性：id,姓名，账号，密码，登录时间
    public $link = "";//id
   
    public function __construct(){
        //创建连接
        $this->init();
    }
    public function __destruct(){
        //销毁数据库连接
        if( $this->link ){
            mysqli_close($this->link);
        }
    }
    //创建连接，初始化连接
    public function init(  ){
       //创建连接
       $config = Array(
           "type"=>&#39;mysql&#39;,
           "hostname"=>"127.0.0.1",
           "database"=>"qq",
           "username"=>"root",
           "password"=>"root"
       );
       $this->link = mysqli_connect($config[&#39;hostname&#39;],$config[&#39;username&#39;],
        $config[&#39;password&#39;],$config[&#39;database&#39;]);
       
    }
}
?>
登录后复制

model/Group.class.php

<?php
require_once "MySql.class.php";
class Group{
    // 属性：id,创建会员,群名称，群的创建时间
    public $id = "";
    public $userid = "";
    public $groupName = "";
    public $createTime = "";
    public $mySql = "";
    public $tableName = "qq_user_group";
    public function __construct(){
        $this->mySql = new MySql();
    }
    //1.获取所有的群 
    //如果不指定具体的创建人，可以获取所有的群
    public function getAll($creatorUserId=&#39;&#39;){
        //创建连接
        $conn = $this->Mysql->link;
        //写sql,执行sql
        $where = "";
        if( !empty($userid) ){
            $where .= " creator_user_id=".$creatorUserId;
        }
        $sql = "select * from {$this->tableName} where 1=1 and {$where}";
        //执行sql
        $result = mysqli_query($conn,$sql);

        //获取数据
        // $list = mysqli_fetch_all($result);
        $list = Array();
        while( $row=mysqli_fetch_assoc($result) ){
            $list[] = $row;
        }
        //end
        //返回数据
        return $list;
    }
    //2.创建群 留给同学些，课上就不写了，因为目前的最终效果不需要呈现，默认已经是张三创建好了
    public function create(){
        echo "创建了群";
    }
    
}
?>
登录后复制

Message.class.php

<?php
require_once  dirname(__FILE__)."/MySql.class.php";

// 会员消息类
class Message{
    //属性：id,内容，发送时间，发送人，接收人，状态(已读,未读),查看时间
    public $id = "";
    public $content = "";
    public $sendTime = "";
    public $sendUserId = "";
    public $toUserId = "";
    public $status = "";
    public $readTime = "";
    public $mySql = "";
    public $tableName = "qq_msg";
    public function __construct(){
        $this->mySql = new MySql();
    }
    

    // 方法：修改状态（可以被修改为已读），查看消息，发送消息
    public function updateStatus($id,$status){
        //创建连接
        $conn = $this->mySql->link;
        //写sql，执行sql
        $sql = "update {$this->tableName} set status={$status} where id={$id}";
        //执行
        $result = mysqli_query($conn,$sql);
        if( $result ){
            return true;
        }else{
            return false;
        }

    }
    //查看会员消息列表
    public function getMsgList($userid,$type,$startTime,$endTime,$groupId){
        //创建连接
        $conn = $this->mySql->link;
        //写sql，执行sql
        $where = " to_user_id={$userid} ";
        if( $type !=""){//这里特别注意不能直接写!empty，会导致0的情况考虑不进来 而0表示未读
            $where .= " and status=".$type;
        }
        if( !empty($startTime) && !empty($endTime) ){
            //判断时间
            $where .= " and create_time between {$startTime} and  {$endTime}";
        }
        if( $groupId ){
            $where .= " and group_id = ".$groupId;
        }
        $sql = "select * from {$this->tableName} where {$where}";
        
        //执行

        $result = mysqli_query($conn,$sql);
        //获取数据
        // return mysqli_fetch_all($result);
        $list = Array();
        while( $row=mysqli_fetch_assoc($result) ){
            $list[] = $row;
        }
        return $list;
    }
    //添加消息
    public function add($userid,$content,$toUserId,$groupId){
        
        //创建连接
        $conn = $this->mySql->link;
        //写sql，执行sql
        $sql = "insert into {$this->tableName} (content,create_time,send_user_id,
            to_user_id,status,read_time,group_id) values (&#39;{$content}&#39;,".time().",{$userid},
                {$toUserId},0,0,".$groupId.") ";
        //执行
        $result = mysqli_query($conn,$sql);
        if( $result ){
            return true;
        }else{
            return false;
        }
        
        
    }

}
?>
登录后复制

model/User.class.php

<?php
//引入UserLoginInfo
require_once  "MySql.class.php";
require_once "UserLoginInfo.class.php";
require_once "Message.class.php";
class User{
    //属性：id,姓名，账号，密码，登录时间
    public $id = "";//id
    public $name = "";//姓名
    public $username = "";//账号
    public $password = "";//密码
    public $mySql = "";
    public $tableName = "qq_msg";
   
    public function __construct($id,$name,$username,$password){
        //初始化对象
        $this->id = $id;
        $this->name = $name;
        $this->username = $username;
        $this->password = $password;
        $this->mySql = new MySql();
    }
   

    public function login( $inputUsername,$inputPassword ){
        //登录逻辑
        //判断用户名和密码是否正确
        if( $inputUsername != $this->username ||
            $inputPassword !=$this->password){
            return array("msg"=>"用户名或者账号错误");
        }
        //登录成功
        $logintime = time();
        // echo $this->name."使用账号：{$inputUsername}和密码{$inputPassword}登录了，
        //     登录时间为:".date(&#39;Y-m-d H:i:s&#39;,$logintime);
        //将登录信息保存到数据库
        $logininfo = new UserLoginInfo();
        $result = $logininfo->save($this->id);
        return $result;
    }
    //查看消息 
    public function getMessage($startTime,$endTime,$groupId){
        //查看消息相当于通过查看这个动作和消息进行了互动
        //所以通过方法的调用来执行
        $messageModel = new Message();
        return $messageModel->getMsgList($this->id,&#39;&#39;,$startTime,$endTime,$groupId);
        
    }
    //发送消息相当于通过查看这个动作和消息进行了互动
    public function sendMessage($content,$toUserId,$groupId){
         //所以通过方法的调用来执行
        $messageModel = new Message();
        return $messageModel->add($this->id,$content,$toUserId,$groupId);
    }
    
}
?>
登录后复制

model/UserGroupRelation.class.php

<?php
require_once "Mysql.class.php";
class UserGroupRelation{
    // 属性：id,创建会员,群名称，群的创建时间
    public $id = "";
    public $userid = "";
    public $groupName = "";
    public $createTime = "";
    public $mySql = "";
    public $tableName = "qq_user_group_relation";
    public function __construct(){
        $this->mySql = new MySql();
    }
    
    //1.获取一个群里所有的会员 根据群获取会员
    public function getUserList($groupid){
        //创建连接
        $conn = $this->mySql->link;
        //写sql，执行sql
       
        $sql = "select * from {$this->tableName }  where group_id={$groupid}";
        //执行
        $result = mysqli_query($conn,$sql);
        //获取数据
        // return mysqli_fetch_all($result);
        $list = Array();
        while( $row=mysqli_fetch_assoc($result) ){
            $list[] = $row;
        }
        return $list;
    }
    //2.根据某个会员获取他所有的群
    public function getGroupList($userid){
        //创建连接
        $conn = $this->mySql->link;
        //写sql，执行sql
       
        $sql = "select * from {$this->tableName }  where user_id={$userid}";
        //执行
        $result = mysqli_query($conn,$sql);
        //获取数据
        // return mysqli_fetch_all($result);
        $list = Array();
        while( $row=mysqli_fetch_assoc($result) ){
            $list[] = $row;
        }
        return $list;
    }
    
}
?>
登录后复制

model/UserLoginInfo.class.php

<?php
require_once "Mysql.class.php";

class UserLoginInfo{
    //属性：id,会员id,登录时间
    public $id = "";//id
    public $userid = "";//姓名
    public $loginTime = "";//登录时间
    public $mySql = "";
    public $tableName = "qq_user_login_record";
    public function __construct(){
        $this->mySql = new MySql();
    }
    //方法：
    public function save( $userid ){
        //添加用户登录记录
        $logintime = time();
        //保存到数据库
        //创建连接
        $conn = $this->mySql->link;
        //写sql执行sql
        $sql = "insert into ".$this->tableName.
            "(user_id,login_time) values({$userid}, {$logintime} )";
      
        //执行
        $result = mysqli_query($conn,$sql);
        //这种增，删，改的动作返回的结果是一个数字 1表示成功
        if( $result ){
            return true;
        }else{
            return false;
        }
        
    }
    //获取用户最后登录信息
    public function getLastLoginInfo($userid){
        //创建连接
        $conn = $this->mySql->link;
        //写sql执行sql
        $sql = "select * from ".$this->tableName.
            " where user_id={$userid} order by id desc limit 2";
   
        //执行
        $result = mysqli_query($conn,$sql);
        //获取数据
        $lastLoginInfo = mysqli_fetch_assoc($result);
        
        return $lastLoginInfo;
    }
}
?>
登录后复制

3、写流程

创建index.php

<?php
//业务代码
require_once "model/Message.class.php";
require_once "model/User.class.php";
require_once "model/UserGroupRelation.class.php";
require_once "model/UserLoginInfo.class.php";

//张三登录
$zhangsan = new User(1,"张三","a","b");
// //登录
$zhangsan->login("a","b");
echo $zhangsan->name."使用账号a和密码b 登录了<br/><br/>";
//输出最后登录时间
$logininfoModel = new UserLoginInfo();
//获取最后登录信息
$lastLoginInfo = $logininfoModel->getLastLoginInfo($zhangsan->id);
$lastLoginTime = date("Y-m-d H:i:s",$lastLoginInfo[&#39;login_time&#39;]);

echo $zhangsan->name."最后登录时间为".$lastLoginTime."<br/><br/>";
// 2.张三查看了 1个小时内的行政部门群的信息（这个群里有张三，李四，王五，其中张三是群主）
$startTime= strtotime("-1 hour");
$endTime = time();
$msglist = $zhangsan->getMessage($startTime,$endTime,1);//查看行为
echo "张三查看了 1小时内的行政部门群的信息<br/><br/>";
echo "<b>张三看到的信息是</b></br/><br/>";
//3.输出张三看到的这些信息
// print_r($msglist);
foreach( $msglist as $msg ){
       echo "【发送人id】:".$msg["send_user_id"]."【内容】：".$msg["content"]."<br/>";
}
echo "<br/><br/>";
//4.突然张三收到好友李四的信息：信息叫：张三，你在干嘛
//相当于是李四给张三发送了消息
$lisi = new User(2,"李四","lisi","123456");
$lisi->sendMessage("张三,我是李四，你在干嘛",$zhangsan->id,2);
echo "李四发了信息给张三，说“张三,我是李四，你在干嘛”<br/><br/>";
//5.张三回复李四：我在想你呀
$zhangsan->sendMessage("我在想你呀",$lisi->id,2);
echo "张三回复了李四，说“我在想你呀”";
?>
登录后复制

运行结果如下：

张三使用账号a和密码b 登录了

张三最后登录时间为2020-06-01 12:40:20

张三查看了 1小时内的行政部门群的信息

张三看到的信息是

【发送人id】:3【内容】：张三，我是王五


李四发了信息给张三，说“张三,我是李四，你在干嘛”

张三回复了李四，说“我在想你呀”

我们再来看数据库里的表有哪些变化

登录信息表数据增加了

222一个简单QQ群聊案例代码解析(PHP实现)

消息表数据增加了

111一个简单QQ群聊案例代码解析(PHP实现)

总结：

1、讲解了一个简单的qq会员登录聊天的场景

以上是一个简单QQ群聊案例代码解析(PHP实现)的详细内容。更多信息请关注PHP中文网其他相关文章！

相关标签：
php
来源：php.cn
上一篇：一个简单的部门案例详解(PHP代码实例) 下一篇：【设计模式】PHP单例模式的应用场景和实现
本站声明
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
作者最新文章
最新问题
PHP数组从URL参数中获取的行为不如预期 我有一个包含类别ID的URL参数，我想将其视为一个数组，如下所示：http://example.com?cat[]=3,9,13在PHP中，我使用它从URL参数获取数组：$catI...
来自于 2024-04-06 22:09:02
0
1
1428
我应该在 apache 中哪里放置 CustomLog 指令 我正在使用php:7.2-apachedocker。我需要禁用运行状况检查url登录访问日志。基于此链接，他们提到了有关修改Customlog指令的信息。我不是关于需要更改Cust...
来自于 2024-04-06 22:03:59
0
1
990
返回值中变量的格式是什么？ 我是php的新学习者。我发现有一段代码：if($x<time()){return[false,'error'];}逻辑或变量并不重要，但我不明白[false,'error']...
来自于 2024-04-06 21:55:20
0
1
778
使用opentbs生成odt文件时遇到的问题：相同key的值显示在同一行而不是单独的列中。 我正在使用一个名为OpenTbs的库来使用PHP创建odt，我使用它是因为动态生成列和行。我知道如何创建行和列，但我不知道如何组织它们。让我添加一个例子：所以首先我会将其添加到我的...
来自于 2024-04-06 20:18:18
0
1
483
按照ID对MySQL结果进行分组以便循环遍历 我有一个表，其中有mysql中的航班数据。我正在编写一个php代码，它将使用codeigniter3对数据进行分组和显示journey_idair_idFlightDuration...
来自于 2024-04-06 17:27:56
0
1
406
相关专题
更多>
热门推荐
热门教程
更多>
相关教程
热门推荐
最新课程
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责声明 Sitemap
PHP中文网：公益在线PHP培训，帮助PHP学习者快速成长！