当前位置：首页 > PHP

php mysql实现聊天

2026-02-16 13:54:46PHP

PHP与MySQL实现聊天功能

数据库设计

创建MySQL数据库表存储聊天消息，表结构可包含以下字段：

id：自增主键
sender_id：发送者ID
receiver_id：接收者ID
message：消息内容
timestamp：发送时间戳

CREATE TABLE chat_messages (
    id INT AUTO_INCREMENT PRIMARY KEY,
    sender_id INT NOT NULL,
    receiver_id INT NOT NULL,
    message TEXT NOT NULL,
    timestamp TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

发送消息功能

通过PHP处理表单提交，将消息存入数据库：

<?php
$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "chat_db";

$conn = new mysqli($servername, $username, $password, $dbname);

if ($_SERVER["REQUEST_METHOD"] == "POST") {
    $sender_id = $_POST['sender_id'];
    $receiver_id = $_POST['receiver_id'];
    $message = $_POST['message'];

    $sql = "INSERT INTO chat_messages (sender_id, receiver_id, message) 
            VALUES ('$sender_id', '$receiver_id', '$message')";

    if ($conn->query($sql) === TRUE) {
        echo "Message sent successfully";
    } else {
        echo "Error: " . $sql . "<br>" . $conn->error;
    }
}
$conn->close();
?>

获取聊天记录

从数据库检索并显示特定用户间的消息：

<?php
$conn = new mysqli($servername, $username, $password, $dbname);

$user1_id = 1; // 用户1ID
$user2_id = 2; // 用户2ID

$sql = "SELECT * FROM chat_messages 
        WHERE (sender_id = $user1_id AND receiver_id = $user2_id) 
        OR (sender_id = $user2_id AND receiver_id = $user1_id) 
        ORDER BY timestamp ASC";

$result = $conn->query($sql);

if ($result->num_rows > 0) {
    while($row = $result->fetch_assoc()) {
        echo "<p><strong>User ".$row["sender_id"].":</strong> ";
        echo $row["message"]."</p>";
        echo "<small>".$row["timestamp"]."</small><br>";
    }
} else {
    echo "No messages yet";
}
$conn->close();
?>

实时更新实现

使用AJAX定期检查新消息：

function getMessages() {
    $.ajax({
        url: 'get_messages.php',
        type: 'GET',
        success: function(data) {
            $('#chat-container').html(data);
        }
    });
}

// 每5秒刷新一次
setInterval(getMessages, 5000);

安全性增强

对用户输入进行过滤和预处理：

$message = htmlspecialchars($_POST['message']);
$sender_id = intval($_POST['sender_id']);

使用预处理语句防止SQL注入：

$stmt = $conn->prepare("INSERT INTO chat_messages (sender_id, receiver_id, message) VALUES (?, ?, ?)");
$stmt->bind_param("iis", $sender_id, $receiver_id, $message);
$stmt->execute();

界面设计建议

HTML聊天界面可包含：

php mysql实现聊天

消息显示区域
消息输入框
发送按钮
用户选择下拉菜单

<div id="chat-container">
    <!-- 消息将在这里动态加载 -->
</div>

<form method="post" action="send_message.php">
    <input type="hidden" name="sender_id" value="1">
    <select name="receiver_id">
        <option value="2">User 2</option>
        <option value="3">User 3</option>
    </select>
    <textarea name="message"></textarea>
    <button type="submit">Send</button>
</form>