当前位置：首页 > PHP

php 实现聊天

2026-01-29 20:44:56PHP

PHP 实现聊天功能的方法

使用 WebSocket 实现实时聊天

WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议，适合实现实时聊天功能。PHP 可以通过库如 Ratchet 实现 WebSocket 服务器。

安装 Ratchet：

composer require cboden/ratchet

创建 WebSocket 服务器：

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

$app = new Ratchet\App('localhost', 8080);
$app->route('/chat', new Chat, ['*']);
$app->run();

前端连接 WebSocket：

const conn = new WebSocket('ws://localhost:8080/chat');
conn.onmessage = e => console.log(e.data);
conn.send('Hello!');

使用 AJAX 轮询实现简单聊天

如果不支持 WebSocket，可以使用 AJAX 轮询模拟实时聊天。

后端 PHP 处理消息：

php 实现聊天

// save_message.php
file_put_contents('messages.txt', $_POST['message'] . PHP_EOL, FILE_APPEND);

// get_messages.php
echo file_get_contents('messages.txt');

前端轮询和发送消息：

setInterval(() => {
    fetch('get_messages.php')
        .then(res => res.text())
        .then(console.log);
}, 1000);

document.querySelector('button').addEventListener('click', () => {
    fetch('save_message.php', {
        method: 'POST',
        body: new FormData(document.querySelector('form'))
    });
});

使用数据库存储聊天记录

对于需要持久化存储的聊天系统，可以使用 MySQL 或其他数据库。

创建消息表：

php 实现聊天

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

PHP 处理数据库消息：

// 保存消息
$stmt = $pdo->prepare("INSERT INTO messages (user, message) VALUES (?, ?)");
$stmt->execute([$_POST['user'], $_POST['message']]);

// 获取消息
$stmt = $pdo->query("SELECT * FROM messages ORDER BY created_at DESC LIMIT 50");
$messages = $stmt->fetchAll(PDO::FETCH_ASSOC);
echo json_encode($messages);