当前位置：首页 > PHP

php实现聊天室

2026-01-28 19:42:36PHP

PHP 实现聊天室的基本方法

使用 PHP 实现聊天室可以结合前端技术（如 HTML、JavaScript）和后端技术（如 MySQL 数据库或文件存储）。以下是几种常见的实现方式：

使用 Ajax 轮询技术

创建一个简单的聊天室可以通过 Ajax 轮询实现。客户端定期向服务器发送请求，获取最新的聊天消息。

前端代码示例 (HTML/JavaScript):

<div id="chatbox"></div>
<input type="text" id="message" />
<button onclick="sendMessage()">发送</button>

<script>
function sendMessage() {
    const message = document.getElementById('message').value;
    fetch('send_message.php', {
        method: 'POST',
        body: new URLSearchParams({ message: message })
    });
}

function fetchMessages() {
    fetch('get_messages.php')
        .then(response => response.text())
        .then(data => {
            document.getElementById('chatbox').innerHTML = data;
        });
}

setInterval(fetchMessages, 1000); // 每秒轮询一次
</script>

后端代码示例 (send_message.php):

<?php
$message = $_POST['message'];
file_put_contents('chat.txt', $message . PHP_EOL, FILE_APPEND);
?>

后端代码示例 (get_messages.php):

<?php
echo file_get_contents('chat.txt');
?>

使用 WebSocket 技术

WebSocket 提供了全双工通信，比轮询更高效。PHP 可以通过 Ratchet 库实现 WebSocket 服务器。

安装 Ratchet:

php实现聊天室

composer require cboden/ratchet

WebSocket 服务器代码 (server.php):

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

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

class Chat implements \Ratchet\MessageComponentInterface {
    protected $clients;

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

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

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

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

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

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

$server->run();
?>

前端代码示例:

<script>
const conn = new WebSocket('ws://localhost:8080');
conn.onmessage = e => {
    document.getElementById('chatbox').innerHTML += e.data + '<br>';
};

function sendMessage() {
    const message = document.getElementById('message').value;
    conn.send(message);
}
</script>

使用数据库存储消息

对于更复杂的聊天室，可以使用 MySQL 数据库存储消息。

数据库表结构:

php实现聊天室

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

PHP 代码示例 (存储消息):

<?php
$db = new PDO('mysql:host=localhost;dbname=chat', 'username', 'password');
$stmt = $db->prepare('INSERT INTO messages (username, message) VALUES (?, ?)');
$stmt->execute([$_POST['username'], $_POST['message']]);
?>

PHP 代码示例 (获取消息):

<?php
$db = new PDO('mysql:host=localhost;dbname=chat', 'username', 'password');
$stmt = $db->query('SELECT * FROM messages ORDER BY created_at DESC LIMIT 50');
echo json_encode($stmt->fetchAll(PDO::FETCH_ASSOC));
?>