当前位置：首页 > PHP

php实现点对点聊天

2026-02-15 10:41:09PHP

PHP实现点对点聊天的方法

使用WebSocket协议

WebSocket是一种全双工通信协议，适合实时聊天应用。PHP可通过Ratchet库实现WebSocket服务器。

安装Ratchet库：

composer require cboden/ratchet

创建WebSocket服务器代码（server.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) {
            if ($from !== $client) {
                $client->send($msg);
            }
        }
    }

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

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

$app = new Ratchet\App('localhost', 8080);
$app->route('/chat', new Chat, ['*']);
$app->run();

前端HTML/JavaScript代码：

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

使用AJAX轮询

对于不支持WebSocket的环境，可采用轮询方式实现简单聊天功能。

服务端消息处理（message.php）：

session_start();
if ($_POST['action'] == 'send') {
    file_put_contents('chat.txt', $_POST['message'], FILE_APPEND);
} elseif ($_POST['action'] == 'receive') {
    echo file_get_contents('chat.txt');
}

前端轮询代码：

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

数据库存储消息

对于需要持久化的场景，可使用MySQL存储聊天记录。

数据库表结构：

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

PHP消息处理脚本：

$db = new PDO('mysql:host=localhost;dbname=chat', 'user', 'pass');
if ($_POST['action'] == 'send') {
    $stmt = $db->prepare("INSERT INTO messages (sender, receiver, message) VALUES (?, ?, ?)");
    $stmt->execute([$_POST['from'], $_POST['to'], $_POST['message']]);
}