当前位置：首页 > PHP

php实现网络聊天

2026-02-16 01:20:04PHP

PHP 实现网络聊天功能

PHP 可以通过多种方式实现网络聊天功能，常见方法包括使用 WebSocket、AJAX 轮询或长轮询（Comet）。以下是几种实现方案：

使用 WebSocket 实现实时聊天

WebSocket 是实现实时双向通信的最佳选择。PHP 本身不支持 WebSocket 服务端，但可以通过以下方式实现：

安装 Ratchet 库
Ratchet 是一个 PHP WebSocket 库，可通过 Composer 安装：
```
composer require cboden/ratchet
```

创建 WebSocket 服务器
示例代码实现一个简单的聊天服务器：

<?php
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;

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

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

前端连接 WebSocket
前端通过 JavaScript 连接服务器：

const socket = new WebSocket('ws://localhost:8080');
socket.onmessage = function(e) {
    console.log('Message:', e.data);
};

使用 AJAX 轮询实现简单聊天

如果无法使用 WebSocket，可以通过 AJAX 轮询模拟实时聊天：

数据库存储消息
创建数据库表存储聊天消息：

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

PHP 发送消息接口

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

PHP 获取消息接口

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

前端轮询实现

function pollMessages() {
    fetch('/get_messages.php')
        .then(response => response.json())
        .then(messages => {
            // 更新聊天界面
            setTimeout(pollMessages, 1000); // 每秒轮询一次
        });
}
pollMessages();

使用长轮询（Comet）优化性能

长轮询比普通轮询更高效，服务器在有新消息时才响应：

PHP 长轮询接口

<?php
$pdo = new PDO('mysql:host=localhost;dbname=chat', 'username', 'password');
$lastId = $_GET['last_id'] ?? 0;

// 等待新消息（最多30秒）
$startTime = time();
while (time() - $startTime < 30) {
    $stmt = $pdo->prepare('SELECT * FROM messages WHERE id > ? ORDER BY id ASC LIMIT 1');
    $stmt->execute([$lastId]);
    $message = $stmt->fetch(PDO::FETCH_ASSOC);

    if ($message) {
        echo json_encode($message);
        exit;
    }
    usleep(100000); // 暂停100毫秒
}
echo json_encode([]);

前端实现长轮询

function longPoll(lastId) {
    fetch(`/long_poll.php?last_id=${lastId}`)
        .then(response => response.json())
        .then(message => {
            if (message.id) {
                // 处理新消息
                longPoll(message.id);
            } else {
                longPoll(lastId); // 继续轮询
            }
        });
}
longPoll(0);