当前位置：首页 > PHP

php实现私信

2026-02-14 10:35:13PHP

实现私信功能的基本思路

私信功能通常涉及用户之间的消息发送、接收和存储。在PHP中实现私信功能需要结合数据库操作、用户认证和前端交互。

数据库设计

创建两个主要表来存储私信数据：

users 表存储用户信息
private_messages 表存储私信内容

CREATE TABLE users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(50) NOT NULL,
    -- 其他用户字段
);

CREATE TABLE private_messages (
    id INT AUTO_INCREMENT PRIMARY KEY,
    sender_id INT NOT NULL,
    recipient_id INT NOT NULL,
    message TEXT NOT NULL,
    is_read BOOLEAN DEFAULT FALSE,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    FOREIGN KEY (sender_id) REFERENCES users(id),
    FOREIGN KEY (recipient_id) REFERENCES users(id)
);

发送私信功能

创建发送私信的PHP处理脚本：

<?php
session_start();
require 'db_connection.php'; // 数据库连接文件

if ($_SERVER['REQUEST_METHOD'] === 'POST' && isset($_SESSION['user_id'])) {
    $senderId = $_SESSION['user_id'];
    $recipientId = filter_input(INPUT_POST, 'recipient_id', FILTER_VALIDATE_INT);
    $message = trim(filter_input(INPUT_POST, 'message', FILTER_SANITIZE_STRING));

    if ($recipientId && $message) {
        $stmt = $pdo->prepare("INSERT INTO private_messages (sender_id, recipient_id, message) VALUES (?, ?, ?)");
        $stmt->execute([$senderId, $recipientId, $message]);

        header('Location: messages.php?success=1');
        exit;
    }
}

header('Location: messages.php?error=1');
exit;
?>

显示私信列表

创建显示用户私信列表的页面：

<?php
session_start();
require 'db_connection.php';

if (!isset($_SESSION['user_id'])) {
    header('Location: login.php');
    exit;
}

$userId = $_SESSION['user_id'];

// 获取收到的私信
$receivedMessages = $pdo->prepare("
    SELECT pm.*, u.username as sender_name 
    FROM private_messages pm
    JOIN users u ON pm.sender_id = u.id
    WHERE pm.recipient_id = ?
    ORDER BY pm.created_at DESC
");
$receivedMessages->execute([$userId]);

// 获取发送的私信
$sentMessages = $pdo->prepare("
    SELECT pm.*, u.username as recipient_name 
    FROM private_messages pm
    JOIN users u ON pm.recipient_id = u.id
    WHERE pm.sender_id = ?
    ORDER BY pm.created_at DESC
");
$sentMessages->execute([$userId]);
?>

<!-- HTML显示部分 -->
<div class="message-list">
    <h3>收到的消息</h3>
    <?php while ($message = $receivedMessages->fetch()): ?>
        <div class="message <?= $message['is_read'] ? '' : 'unread' ?>">
            <p>来自: <?= htmlspecialchars($message['sender_name']) ?></p>
            <p><?= nl2br(htmlspecialchars($message['message'])) ?></p>
            <small><?= $message['created_at'] ?></small>
        </div>
    <?php endwhile; ?>
</div>

<div class="message-list">
    <h3>发送的消息</h3>
    <?php while ($message = $sentMessages->fetch()): ?>
        <div class="message">
            <p>发送给: <?= htmlspecialchars($message['recipient_name']) ?></p>
            <p><?= nl2br(htmlspecialchars($message['message'])) ?></p>
            <small><?= $message['created_at'] ?></small>
        </div>
    <?php endwhile; ?>
</div>

标记消息为已读

当用户查看消息时，可以将其标记为已读：

<?php
session_start();
require 'db_connection.php';

if (isset($_GET['message_id']) && isset($_SESSION['user_id'])) {
    $messageId = filter_input(INPUT_GET, 'message_id', FILTER_VALIDATE_INT);
    $userId = $_SESSION['user_id'];

    // 验证消息属于当前用户
    $stmt = $pdo->prepare("UPDATE private_messages SET is_read = TRUE WHERE id = ? AND recipient_id = ?");
    $stmt->execute([$messageId, $userId]);
}
?>