简单的php+mysql聊天室实现方法(附源码)

下面详细讲解“简单的php+mysql聊天室实现方法(附源码)”的完整攻略。

简述

本文所介绍的方法是一种使用php和mysql实现聊天室功能的方法。实现的核心是通过Ajax技术实现实时聊天。

环境要求

服务器需支持php和mysql；
推荐使用XAMPP或WAMP等本地服务器环境；
推荐使用最新版本的Chrome浏览器。

实现步骤

1. 创建数据库和表

首先需要创建一个名为chat的数据库，在该数据库下创建名为message的表。message表包含三个字段：id、name和content。其中，id为自增主键，name和content分别为varchar类型，分别用来存储聊天时用户的名字和聊天内容。

示例代码：

CREATE DATABASE chat;

USE chat;

CREATE TABLE message (
    id int(11) NOT NULL auto_increment,
    name varchar(50) NOT NULL,
    content varchar(255) NOT NULL,
    PRIMARY KEY (id)
) ENGINE=MyISAM DEFAULT CHARSET=utf8;

2. 创建聊天界面

为了方便起见，我们可以把聊天室页面和输入框放在同一个页面中。聊天室页面负责展示历史聊天记录，输入框负责发送当前用户的聊天内容。我们可以在聊天室页面中使用Ajax来实现实时刷新聊天记录。

示例代码：

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>聊天室</title>
    <script src="https://cdn.bootcss.com/jquery/3.2.1/jquery.min.js"></script>
</head>
<body>
    <div id="chat-content"></div>
    <input id="username" type="text" placeholder="请输入用户名">
    <input id="content" type="text" placeholder="请输入聊天内容">
    <button id="send">发送</button>
    <script>
        $(function() {
            setInterval(function() {
                $.get("get_message.php", function(data) {
                    $("#chat-content").html(data);
                });
            }, 1000);
            $("#send").click(function() {
                var name = $("#username").val();
                var content = $("#content").val();
                if (name !== "" && content !== "") {
                    $.post("send_message.php", {name: name, content:content});
                    $("#content").val("");
                }
            });
        });
    </script>
</body>
</html>

3. 实现发送和接收消息的PHP文件

接下来，我们需要实现发送和接收消息的PHP文件，这两个文件对应的是上面我们在聊天界面中Ajax请求的地址。

send_message.php：这个文件负责向数据库中插入聊天记录。首先我们需要获取到发送消息的用户的名字和聊天内容，然后插入到message表中。插入成功后，返回insert字符串以告诉前端插入成功。

示例代码：

<?php
    $name = $_POST['name'];
    $content = $_POST['content'];

    $mysqli = new mysqli("localhost", "root", "", "chat");
    if ($mysqli->connect_error) {
        die("连接数据库失败：".$mysqli->connect_error);
    }

    $sql = "INSERT INTO message (name, content) VALUES ('$name', '$content')";
    if ($mysqli->query($sql) === TRUE) {
        echo "insert";
    } else {
        echo "Error: " . $sql . "<br>" . $mysqli->error;
    }
    $mysqli->close();
?>

get_message.php：这个文件负责从数据库中读取聊天记录。我们可以通过查询message表，将之前所有的聊天记录都取出来返回给前端组成聊天室的历史消息。

示例代码：

<?php
    $mysqli = new mysqli("localhost", "root", "", "chat");
    if ($mysqli->connect_error) {
        die("连接数据库失败：".$mysqli->connect_error);
    }

    $sql = "SELECT * FROM message";
    $result = $mysqli->query($sql);

    if ($result->num_rows > 0) {
        while($row = $result->fetch_assoc()) {
            echo $row["name"]."：".$row["content"]."<br>";
        }
    }
    $mysqli->close();
?>