当前位置：首页 > PHP

php实现站内通信

2026-02-15 16:26:56PHP

PHP 实现站内通信的方法

站内通信可以通过多种方式实现，包括数据库、文件存储、WebSocket、消息队列等。以下是几种常见的实现方法：

数据库存储消息

使用数据库是最简单的方法之一，可以创建一个消息表存储用户之间的通信内容。

CREATE TABLE messages (
    id INT AUTO_INCREMENT PRIMARY KEY,
    sender_id INT NOT NULL,
    receiver_id INT NOT NULL,
    message TEXT NOT NULL,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    is_read BOOLEAN DEFAULT FALSE
);

在 PHP 中，可以通过以下代码插入和查询消息：

// 插入消息
$stmt = $pdo->prepare("INSERT INTO messages (sender_id, receiver_id, message) VALUES (?, ?, ?)");
$stmt->execute([$senderId, $receiverId, $message]);

// 查询未读消息
$stmt = $pdo->prepare("SELECT * FROM messages WHERE receiver_id = ? AND is_read = FALSE");
$stmt->execute([$receiverId]);
$messages = $stmt->fetchAll();

使用文件存储消息

对于小型应用，可以使用文件存储消息。每个用户有一个单独的文件存储其接收的消息。

// 发送消息
file_put_contents("messages_$receiverId.txt", "$senderId: $message\n", FILE_APPEND);

// 接收消息
$messages = file_get_contents("messages_$userId.txt");

WebSocket 实时通信

WebSocket 可以实现实时通信，适合需要即时反馈的场景。可以使用 Ratchet 库实现 WebSocket 服务器。

安装 Ratchet：

composer require cboden/ratchet

创建 WebSocket 服务器：

use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use MyApp\Chat;

require dirname(__DIR__) . '/vendor/autoload.php';

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new Chat()
        )
    ),
    8080
);

$server->run();

实现 Chat 类：

namespace MyApp;

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class Chat implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new \SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        foreach ($this->clients as $client) {
            $client->send($msg);
        }
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        $conn->close();
    }
}

使用消息队列

对于高并发场景，可以使用消息队列如 Redis 或 RabbitMQ 实现站内通信。

使用 Redis 发布/订阅：

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 发布消息
$redis->publish('channel', json_encode(['sender' => $senderId, 'message' => $message]));

// 订阅消息（需要在另一个进程运行）
$redis->subscribe(['channel'], function ($redis, $channel, $message) {
    $data = json_decode($message, true);
    echo "Received message from {$data['sender']}: {$data['message']}\n";
});

AJAX 轮询

对于不支持 WebSocket 的环境，可以使用 AJAX 轮询检查新消息。

前端代码：

setInterval(function() {
    fetch('check_messages.php?user_id=123')
        .then(response => response.json())
        .then(messages => {
            messages.forEach(msg => {
                console.log(msg);
            });
        });
}, 5000);

后端 PHP 代码：

$userId = $_GET['user_id'];
$stmt = $pdo->prepare("SELECT * FROM messages WHERE receiver_id = ? AND is_read = FALSE");
$stmt->execute([$userId]);
$messages = $stmt->fetchAll(PDO::FETCH_ASSOC);

header('Content-Type: application/json');
echo json_encode($messages);

// 标记为已读
$pdo->prepare("UPDATE messages SET is_read = TRUE WHERE receiver_id = ? AND is_read = FALSE")->execute([$userId]);