当前位置：首页 > PHP

php 实现聊天功能

2026-04-02 22:53:37PHP

实现聊天功能的基本方法

使用PHP实现聊天功能通常需要结合前端技术（如HTML、JavaScript）和后端技术（如WebSocket或AJAX）。以下是几种常见的实现方式。

使用AJAX轮询

AJAX轮询是一种简单的方式，通过定期向服务器发送请求来检查新消息。

后端PHP代码（处理消息存储和获取）

<?php
// 存储消息
if ($_SERVER['REQUEST_METHOD'] === 'POST' && isset($_POST['message'])) {
    $message = $_POST['message'];
    file_put_contents('chat.txt', $message . PHP_EOL, FILE_APPEND);
    echo json_encode(['status' => 'success']);
    exit;
}

// 获取消息
if ($_SERVER['REQUEST_METHOD'] === 'GET') {
    $messages = file_get_contents('chat.txt');
    echo json_encode(['messages' => $messages]);
    exit;
}
?>

前端HTML和JavaScript代码

<div id="chat-box"></div>
<input type="text" id="message-input">
<button onclick="sendMessage()">Send</button>

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

function pollMessages() {
    fetch('chat.php')
        .then(response => response.json())
        .then(data => {
            document.getElementById('chat-box').innerText = data.messages;
        });
    setTimeout(pollMessages, 1000);
}

pollMessages();
</script>

使用WebSocket

WebSocket提供全双工通信，适合实时聊天应用。

后端PHP代码（使用Ratchet库）

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

启动WebSocket服务器

php bin/chat-server.php

前端JavaScript代码

const socket = new WebSocket('ws://localhost:8080');
socket.onmessage = function(event) {
    document.getElementById('chat-box').innerText += event.data + '\n';
};

function sendMessage() {
    const message = document.getElementById('message-input').value;
    socket.send(message);
}

使用数据库存储消息

对于更复杂的聊天系统，可以使用数据库（如MySQL）存储消息。

PHP代码（数据库操作）

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

if ($_SERVER['REQUEST_METHOD'] === 'POST' && isset($_POST['message'])) {
    $stmt = $db->prepare('INSERT INTO messages (content) VALUES (?)');
    $stmt->execute([$_POST['message']]);
    echo json_encode(['status' => 'success']);
    exit;
}

if ($_SERVER['REQUEST_METHOD'] === 'GET') {
    $stmt = $db->query('SELECT content FROM messages ORDER BY id DESC LIMIT 10');
    $messages = $stmt->fetchAll(PDO::FETCH_COLUMN);
    echo json_encode(['messages' => $messages]);
    exit;
}
?>