Comment implémenter une simple boîte de discussion en utilisant PHP-Problème PHP-php.cn

在当今互联网时代，人们越来越注重即时通讯的重要性。无论是社交网络、电子商务、在线教育还是其他领域，都需要提供一个即时的聊天功能来满足用户需求。PHP作为一门Web开发语言，一般使用Ajax和Websocket来实现即时通讯功能。在本文中，我们将介绍如何使用PHP实现一个简单的聊天框。

一、前期准备

在开始之前，我们要确保拥有以下环境：

PHP
MySQL
运行Apache服务器的能力

这些环境是我们完成本文所需要的基础。

二、创建聊天框界面

首先我们需要创建一个简单的HTML页面，用于显示聊天框。该页面包括两部分：显示聊天记录的区域和输入聊天内容的区域。可以使用Bootstrap来美化网页。

例如，我们可以创建一个id为“chatbox”的Div元素包含两个子元素：id为“message”的div元素和id为“input”的form元素。其中“message”和“input”元素的CSS样式可以使用Bootstrap来美化。

三、实现聊天记录的显示

接下来，我们需要实现聊天记录的显示功能。我们需要将聊天记录存储在数据库中，并从数据库中检索消息，然后将其显示在“message”Div元素中。

在MySQL中，可以使用以下命令创建一个名为“chat”、包含“id”、 “name”、“message”和“time”四个字段的表。

CREATE TABLE `chat` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(50) NOT NULL,
  `message` text NOT NULL,
  `time` datetime NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

Copier après la connexion

为了在PHP中连接MySQL数据库，我们使用以下代码连接到数据库：

$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "chat";

// create connection
$conn = new mysqli($servername, $username, $password, $dbname);

// check connection
if ($conn->connect_error) {
    die("Connection failed: " . $conn->connect_error);
}

Copier après la connexion

接着，我们需要通过以下代码从数据库中检索聊天记录并将其显示在页面中：

$sql = "SELECT name, message, time FROM chat ORDER BY id ASC";
$result = $conn->query($sql);

// display chat history
if ($result->num_rows > 0) {
    while($row = $result->fetch_assoc()) {
        echo "<p><strong>" .$row["name"]. "</strong> " .$row["message"]. "</p>";
    }
} else {
    echo "No messages yet.";
}

Copier après la connexion

以上的代码使用select语句从数据库中检索聊天记录，然后使用“while”循环来将这些记录逐一显示在页面中。

四、实现聊天内容的发送

我们接下来需要实现用户输入聊天内容后以上部分就像qq聊天框一样实时地能够让其他用户收到聊天信息的功能。为了在网页上输入聊天内容，我们可以在“input”表单中添加一个输入框和一个提交按钮。当用户点击提交按钮时，聊天内容将被发送到我们的PHP代码，然后保存到MySQL数据库中。

PHP代码可以使用以下代码从表单获取聊天内容和用户名，并将其保存到MySQL数据库中：

if (isset($_POST['submit'])) { //check if form submitted
    $name = $_POST['name'];
    $message = $_POST['message'];
    
    //insert message into database
    $sql = "INSERT INTO chat (name, message) VALUES ('$name', '$message')";
    $result = $conn->query($sql);
}

Copier après la connexion

以上代码通过将用户提交的表单数据（即用户名和聊天内容）插入到位于MySQL数据库中的“chat”表中来实现聊天内容的保存。

五、使用Ajax更新聊天记录

聊天框的最后一个部分是实时更新聊天记录。为了实现这一点，我们可以使用Ajax来定期从数据库中检索新消息，并将其添加到“message”div中。以下是使用jQuery的代码演示：

$(document).ready(function(){
    updateChat();
});

function updateChat() {
    $.ajax({
        type: "GET",
        url: "getchat.php",
        success: function(data){
            $("#message").html(data); // replace message div with result
        }
    });

    setTimeout(updateChat, 3000); // update chat every 3 seconds
}

Copier après la connexion

以上代码使用Ajax周期性地调用getchat.php文件来从MySQL数据库中检索新消息。在该文件中，我们可以使用以下代码来检索消息：

$sql = "SELECT name, message, time FROM chat WHERE id > $last_id ORDER BY id ASC";
$result = $conn->query($sql);

// display chat history
if ($result->num_rows > 0) {
    while($row = $result->fetch_assoc()) {
        echo "<p><strong>" .$row["name"]. "</strong> " .$row["message"]. "</p>";
    }
}

mysqli_close($conn);

Copier après la connexion

以上代码使用select语句从数据库中检索新消息，并使用类似于前面所述的方法将其显示在页面中。

六、实现即时通讯

以上所有功能的实现都需要web页面刷新后才能实现，而实时通讯则可以带来更好的用户体验。接下来我们将会实现针对每一个用户能够实现即时通讯的web聊天框。

改造代码

首先，我们需要将以上的聊天框代码改造为多个聊天框。

我们需要在 MySQL 数据库中创建一个名为“chatrooms”的表，用于存储每个聊天室的信息。我们使用以下命令创建该表：

CREATE TABLE `chatrooms` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(50) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

Copier après la connexion

然后，我们需要添加一个表单，让用户输入新聊天室的名称。我们也应该添加一个按钮，使用户能够创建新聊天室。当用户提交表单时，新聊天室应添加到 chatrooms 表中。

创建新的聊天室后，要显示用户的所有聊天室。我们可以使用以下代码来获取所有聊天室：

$sql = "SELECT * FROM chatrooms";
$result = $conn->query($sql);

// display chat rooms
if ($result->num_rows > 0) {
    while($row = $result->fetch_assoc()) {
        echo "<a href=&#39;chatroom.php?id=" . $row["id"] . "&#39;>" . $row["name"] . "</a>";
    }
} else {
    echo "No chat rooms yet.";
}

Copier après la connexion

实现即时通讯

接下来，我们将会实现如何在 members.php 页面上加入一个即时通讯功能，使用户能够查看并加入正在进行的聊天室中的实时聊天记录。

我们首先需要在 MySQL 中的 spam 表中创建一个新的字段，用于记录正在进行的实时聊天室的最后构建时间。

ALTER TABLE `spam` ADD `last_build_time` TIMESTAMP NULL ON DELETE SET NULL;

Copier après la connexion

每当一个新消息发送到聊天室，我们需要更新 spam 表中的 last_build_time 字段以创建服务器上最新的构建版本。

为了实现即时通讯，我们使用 WebSocket 协议。首先，我们需要生成一个新的密钥并存储在 session 中。

if (!isset($_SESSION['chat_key'])) {
    $_SESSION['chat_key'] = bin2hex(random_bytes(16));
}

Copier après la connexion

接下来，我们需要使用 JavaScript 和类库来连接 WebSocket 服务器并获取最新的构建版本。

// Connect to WebSocket server
var ws = new WebSocket('wss://' + SERVER_HOST + ':' + WS_PORT + '/chat/' + key);

// Send a message to the server
ws.send('build');

// Handle incoming messages from the server
ws.onmessage = function(event) {
    var message = JSON.parse(event.data);

    if (message.action == 'build') {
        $('#chatbox').html(message.html);
    }

    if (message.action == 'addMessage') {
        addMessage(message);
    }

    if (message.action == 'removeMessage') {
        removeMessage(message);
    }
}

function addMessage(message) {
    // add new message to chatbox
    var html = '<div class="message">';
    html += '<span class="name">' + message.name + '</span>';
    html += '<span class="time">' + message.time + '</span>';
    html += '<div class="content">' + message.content + '</div>';
    html += '</div>';

    $('#chatbox .messages').append(html);
}

function removeMessage(message) {
    // remove message from chatbox
    $('#chatbox .messages .message[data-id="' + message.id + '"]').remove();
}

Copier après la connexion

以上代码使用 WebSocket 协议连接服务器，并从服务器接收最新的构建版本，然后更新会话中的 HTML 聊天记录以反映新的消息。

总结

通过这个实例，我们学习了如何使用 PHP 开发一个简单的即时聊天应用，理解了如何使用 Ajax、MySQL 和 WebSocket 等技术实现真正的实时聊天应用。此外，我们还涵盖了许多重要的主题，例如如何管理多个聊天室、如何存储并获取聊天记录等。希望这个例子能给你一个有意义的启示，并启发你在自己的项目中实现即时通讯的功能。

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!