当前位置：首页 > PHP

php实现聊天

2026-04-02 20:39:40PHP

PHP 实现聊天功能的方法

使用 PHP 实现聊天功能可以通过多种方式实现，以下是几种常见的方法：

使用 WebSocket 实现实时聊天

WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议，适合实现实时聊天功能。PHP 可以通过 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：

var conn = new WebSocket('ws://localhost:8080');
conn.onmessage = function(e) {
    console.log(e.data);
};
conn.send('Hello');

使用 AJAX 轮询实现聊天

如果无法使用 WebSocket，可以通过 AJAX 轮询实现简单的聊天功能。

后端 PHP 处理消息：

$messages = [];
if ($_SERVER['REQUEST_METHOD'] === 'POST') {
    $message = $_POST['message'];
    file_put_contents('messages.txt', $message . PHP_EOL, FILE_APPEND);
} else {
    $messages = file('messages.txt', FILE_IGNORE_NEW_LINES);
    echo json_encode($messages);
}

前端 AJAX 轮询：

function pollMessages() {
    fetch('chat.php')
        .then(response => response.json())
        .then(messages => {
            console.log(messages);
            setTimeout(pollMessages, 1000);
        });
}
pollMessages();

使用数据库存储聊天记录

为了持久化聊天记录，可以使用数据库存储消息。

创建消息表：

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

PHP 处理消息：

$db = new PDO('mysql:host=localhost;dbname=chat', 'username', 'password');

if ($_SERVER['REQUEST_METHOD'] === 'POST') {
    $stmt = $db->prepare("INSERT INTO messages (username, message) VALUES (?, ?)");
    $stmt->execute([$_POST['username'], $_POST['message']]);
} else {
    $stmt = $db->query("SELECT * FROM messages ORDER BY created_at DESC LIMIT 50");
    echo json_encode($stmt->fetchAll(PDO::FETCH_ASSOC));
}