消息推送系统

小明：最近我在学习PHP，想做一个消息管理系统，你能帮我设计一下吗？

小李：当然可以！消息管理系统是一个很实用的项目，我们可以从功能模块开始谈起。你对系统有什么具体需求吗？

小明：我想要一个能够让用户注册、登录，并且能发送和接收消息的系统。还要有消息列表显示功能。

小李：好的，那我们先来规划几个核心功能模块。第一个是用户管理模块，用于处理用户的注册、登录和权限控制。

小明：用户管理模块怎么实现呢？

小李：我们可以用PHP结合MySQL数据库来实现。首先创建一个用户表，包含用户名、密码、邮箱等字段。然后编写注册和登录的页面。

小明：那注册功能需要哪些步骤？

小李：注册功能包括：前端表单提交、后端验证、密码加密、数据库插入等步骤。比如，用户在注册页面输入信息后，点击提交按钮，PHP会接收到这些数据，进行验证（如用户名是否重复、密码强度等），然后将数据插入到数据库中。

小明：那登录功能呢？

小李：登录功能与注册类似，但需要验证用户输入的用户名和密码是否与数据库中的记录一致。这里需要注意的是，密码不能以明文存储，应该使用哈希函数进行加密，比如使用PHP内置的`password_hash()`和`password_verify()`函数。

小明：明白了，那接下来是什么模块？

小李：接下来是消息发送模块。用户登录后，可以发送消息给其他用户或群组。这个模块需要考虑消息的结构、发送方式以及安全性。

小明：消息的结构应该怎么设计呢？

小李：我们可以设计一个消息表，包含以下字段：消息ID、发送者ID、接收者ID、消息内容、发送时间、状态（已读/未读）等。这样就可以方便地管理和查询消息。

小明：那发送消息的功能怎么实现呢？

小李：前端可以提供一个表单，让用户输入消息内容和选择接收人，然后通过POST方法发送到后端。后端接收到数据后，进行验证，确保接收人存在，然后将消息插入到数据库中。

小明：那消息存储模块呢？

小李：消息存储模块其实就是数据库的设计和操作。我们需要确保消息能够被正确存储，并且可以快速检索。同时，还需要考虑消息的删除、更新等操作。

小明：那消息展示模块呢？

小李：消息展示模块主要负责将消息按照一定规则显示给用户，比如按时间排序、区分已读和未读消息等。前端可以通过AJAX请求获取消息数据，动态加载到页面上。

小明：那我可以写一些代码看看吗？

小李：当然可以，我们先从用户注册模块开始。下面是一个简单的注册页面代码示例：

<!-- register.php -->
<form action="register_process.php" method="post">
  <label>用户名:</label><input type="text" name="username"><br>
  <label>密码:</label><input type="password" name="password"><br>
  <label>邮箱:</label><input type="email" name="email"><br>
  <input type="submit" value="注册">
</form>

小明：那后端处理代码呢？

小李：这里是处理注册的PHP代码，保存为register_process.php：

<?php
// 数据库连接
$conn = new mysqli("localhost", "root", "", "message_system");

if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}

$username = $_POST['username'];
$password = password_hash($_POST['password'], PASSWORD_DEFAULT);
$email = $_POST['email'];

$sql = "INSERT INTO users (username, password, email) VALUES (?, ?, ?)";
$stmt = $conn->prepare($sql);
$stmt->bind_param("sss", $username, $password, $email);

if ($stmt->execute()) {
    echo "注册成功！";
} else {
    echo "注册失败: " . $stmt->error;
}

$stmt->close();
$conn->close();
?>

小明：这太棒了！那登录模块呢？

小李：登录模块的前端代码如下：

<!-- login.php -->
<form action="login_process.php" method="post">
  <label>用户名:</label><input type="text" name="username"><br>
  <label>密码:</label><input type="password" name="password"><br>
  <input type="submit" value="登录">
</form>

小明：那后端处理代码呢？

小李：这里是处理登录的PHP代码，保存为login_process.php：

<?php
session_start();

$conn = new mysqli("localhost", "root", "", "message_system");

if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}

$username = $_POST['username'];
$password = $_POST['password'];

$sql = "SELECT * FROM users WHERE username = ?";
$stmt = $conn->prepare($sql);
$stmt->bind_param("s", $username);
$stmt->execute();
$result = $stmt->get_result();

if ($result->num_rows > 0) {
    $user = $result->fetch_assoc();
    if (password_verify($password, $user['password'])) {
        $_SESSION['user_id'] = $user['id'];
        $_SESSION['username'] = $user['username'];
        echo "登录成功！";
    } else {
        echo "密码错误！";
    }
} else {
    echo "用户不存在！";
}

$stmt->close();
$conn->close();
?>

小明：那消息发送模块呢？

小李：消息发送模块的前端代码如下，用户可以在页面上输入消息内容并选择接收人：

<!-- send_message.php -->
<form action="send_message_process.php" method="post">
  <label>接收人ID:</label><input type="text" name="receiver_id"><br>
  <label>消息内容:</label><textarea name="message">

<?php
session_start();

$conn = new mysqli("localhost", "root", "", "message_system");

if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}

$sender_id = $_SESSION['user_id'];
$receiver_id = $_POST['receiver_id'];
$message = $_POST['message'];
$date = date('Y-m-d H:i:s');

$sql = "INSERT INTO messages (sender_id, receiver_id, message, sent_at) VALUES (?, ?, ?, ?)";
$stmt = $conn->prepare($sql);
$stmt->bind_param("iis s", $sender_id, $receiver_id, $message, $date);

if ($stmt->execute()) {
    echo "消息发送成功！";
} else {
    echo "消息发送失败: " . $stmt->error;
}

$stmt->close();
$conn->close();
?>

<!-- view_messages.php -->
<div id="messages"></div>

<script>
function loadMessages() {
    fetch('get_messages.php')
        .then(response => response.json())
        .then(data => {
            let html = '';
            data.forEach(msg => {
                html += '<p>' + msg.message + ' - ' + msg.sent_at + '</p>';
            });
            document.getElementById('messages').innerHTML = html;
        });
}

loadMessages();
setInterval(loadMessages, 5000); // 每5秒刷新一次
</script>

<?php
session_start();

$conn = new mysqli("localhost", "root", "", "message_system");

if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}

$sender_id = $_SESSION['user_id'];

$sql = "SELECT * FROM messages WHERE receiver_id = ?";
$stmt = $conn->prepare($sql);
$stmt->bind_param("i", $sender_id);
$stmt->execute();
$result = $stmt->get_result();

$messages = [];
while ($row = $result->fetch_assoc()) {
    $messages[] = $row;
}

echo json_encode($messages);

$stmt->close();
$conn->close();
?>