php实现群聊

PHP 实现群聊功能

群聊功能可以通过 PHP 结合 WebSocket 或 Ajax 轮询实现。以下是两种常见的方法：

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();

实现聊天逻辑：

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) {
            if ($from !== $client) {
                $client->send($msg);
            }
        }
    }

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

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

前端连接 WebSocket：

const conn = new WebSocket('ws://localhost:8080');
conn.onmessage = e => {
    document.getElementById('messages').innerHTML += `<div>${e.data}</div>`;
};
function sendMessage() {
    conn.send(document.getElementById('message').value);
}

Ajax 轮询实现

对于不支持 WebSocket 的环境，可以使用 Ajax 轮询模拟实时聊天。

数据库表结构：

CREATE TABLE messages (
    id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(50),
    message TEXT,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

发送消息：

if ($_SERVER['REQUEST_METHOD'] === 'POST') {
    $username = $_POST['username'];
    $message = $_POST['message'];

    $stmt = $pdo->prepare("INSERT INTO messages (username, message) VALUES (?, ?)");
    $stmt->execute([$username, $message]);

    echo json_encode(['status' => 'success']);
    exit;
}

获取新消息：

$lastId = $_GET['last_id'] ?? 0;

$stmt = $pdo->prepare("SELECT * FROM messages WHERE id > ? ORDER BY created_at DESC LIMIT 10");
$stmt->execute([$lastId]);
$messages = $stmt->fetchAll(PDO::FETCH_ASSOC);

echo json_encode($messages);

前端轮询：

let lastId = 0;
function pollMessages() {
    fetch(`get_messages.php?last_id=${lastId}`)
        .then(res => res.json())
        .then(messages => {
            if (messages.length) {
                lastId = messages[0].id;
                messages.reverse().forEach(msg => {
                    document.getElementById('messages').innerHTML += 
                        `<div><strong>${msg.username}:</strong> ${msg.message}</div>`;
                });
            }
            setTimeout(pollMessages, 2000);
        });
}
pollMessages();

安全注意事项

实现群聊系统时需考虑以下安全措施：

验证用户输入，防止 XSS 攻击

$message = htmlspecialchars($_POST['message'], ENT_QUOTES, 'UTF-8');

使用 HTTPS 加密通信

server {
    listen 443 ssl;
    ssl_certificate /path/to/cert.pem;
    ssl_certificate_key /path/to/key.pem;
}

限制消息频率防止滥用

$lastMessageTime = $_SESSION['last_message_time'] ?? 0;
if (time() - $lastMessageTime < 2) {
    http_response_code(429);
    die('Message rate limit exceeded');
}
$_SESSION['last_message_time'] = time();

扩展功能

用户列表展示

// WebSocket 版本
public function onOpen(ConnectionInterface $conn) {
    $this->clients->attach($conn);
    $userList = array_map(fn($c) => $c->resourceId, iterator_to_array($this->clients));
    foreach ($this->clients as $client) {
        $client->send(json_encode(['type' => 'user_list', 'data' => $userList]));
    }
}

消息持久化存储

public function onMessage(ConnectionInterface $from, $msg) {
    $data = json_decode($msg, true);
    $stmt = $pdo->prepare("INSERT INTO messages (username, message) VALUES (?, ?)");
    $stmt->execute([$data['username'], $data['message']]);

    foreach ($this->clients as $client) {
        $client->send($msg);
    }
}

私聊功能

if ($data['type'] === 'private') {
    foreach ($this->clients as $client) {
        if ($client->resourceId === $data['to']) {
            $client->send(json_encode([
                'type' => 'private',
                'from' => $from->resourceId,
                'message' => $data['message']
            ]));
        }
    }
}