当前位置：首页 > PHP

php实现简单聊天

2026-03-13 07:14:25PHP

PHP实现简单聊天功能

通过PHP结合前端技术可以实现基础的聊天功能，以下是一种常见实现方式：

基础实现方案（无数据库）

// chat.php
<?php
session_start();
if (!isset($_SESSION['messages'])) {
    $_SESSION['messages'] = [];
}

if ($_SERVER['REQUEST_METHOD'] === 'POST' && isset($_POST['message'])) {
    $message = htmlspecialchars($_POST['message']);
    $_SESSION['messages'][] = [
        'text' => $message,
        'time' => date('H:i:s')
    ];
}

header('Content-Type: application/json');
echo json_encode($_SESSION['messages']);
?>

<!-- index.html -->
<!DOCTYPE html>
<html>
<head>
    <title>简易聊天室</title>
    <script src="https://code.jquery.com/jquery-3.6.0.min.js"></script>
</head>
<body>
    <div id="chat-box" style="height:300px; overflow-y:scroll; border:1px solid #ccc;"></div>
    <input type="text" id="message-input">
    <button id="send-btn">发送</button>

    <script>
        function loadMessages() {
            $.get('chat.php', function(messages) {
                $('#chat-box').empty();
                messages.forEach(msg => {
                    $('#chat-box').append(`<p>[${msg.time}] ${msg.text}</p>`);
                });
            });
        }

        $('#send-btn').click(function() {
            const message = $('#message-input').val();
            if (message) {
                $.post('chat.php', {message: message}, function() {
                    $('#message-input').val('');
                    loadMessages();
                });
            }
        });

        setInterval(loadMessages, 1000);
    </script>
</body>
</html>

数据库增强版方案

使用MySQL存储聊天记录更持久：

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

if ($_SERVER['REQUEST_METHOD'] === 'POST' && isset($_POST['message'])) {
    $stmt = $db->prepare("INSERT INTO messages (text, created_at) VALUES (?, NOW())");
    $stmt->execute([htmlspecialchars($_POST['message'])]);
}

$stmt = $db->query("SELECT * FROM messages ORDER BY created_at DESC LIMIT 50");
$messages = $stmt->fetchAll(PDO::FETCH_ASSOC);

header('Content-Type: application/json');
echo json_encode($messages);
?>

实时通信改进方案

使用WebSocket实现更实时的聊天体验：

php实现简单聊天

// websocket_server.php
require __DIR__ . '/vendor/autoload.php';
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use MyApp\Chat;

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

$server->run();

// MyApp/Chat.php
namespace MyApp;
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();
    }
}