当前位置：首页 > PHP

php 实现聊天功能

2026-01-15 12:54:30PHP

PHP 实现聊天功能的方法

使用 WebSocket 和 Ratchet 库

WebSocket 是实现实时聊天的理想选择。Ratchet 是一个 PHP 库，用于处理 WebSocket 连接。

安装 Ratchet：

composer require cboden/ratchet

创建一个简单的聊天服务器：

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

前端 HTML/JavaScript 连接 WebSocket：

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

使用 AJAX 轮询

对于不支持 WebSocket 的环境，可以使用 AJAX 轮询模拟实时聊天。

后端 PHP 处理消息：

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

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

前端 JavaScript 轮询：

setInterval(() => {
  fetch('get_messages.php')
    .then(response => response.text())
    .then(data => {
      document.getElementById('chat').innerHTML = data;
    });
}, 1000);

document.getElementById('send').addEventListener('click', () => {
  fetch('save_message.php', {
    method: 'POST',
    body: new FormData(document.getElementById('chatForm'))
  });
});

使用数据库存储聊天记录

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

创建消息表：

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

使用现成的聊天解决方案

对于快速部署，可以考虑集成现成的聊天解决方案：

Twillio Chat API：提供完整的聊天 API
Pusher：实现实时消息推送
Firebase：Google 的实时数据库解决方案

集成 Pusher 的示例：

require __DIR__ . '/vendor/autoload.php';
$pusher = new Pusher\Pusher("APP_KEY", "APP_SECRET", "APP_ID");
$pusher->trigger('chat-channel', 'new-message', [
  'user' => $_POST['user'],
  'message' => $_POST['message']
]);