Maison > Article > développement back-end > Comment implémenter la fonction de communication en ligne en php

Comment implémenter la fonction de communication en ligne en php

PHPzoriginal: 2023-04-19 09:18:35557parcourir

À l'ère actuelle d'Internet, la communication en ligne est devenue un élément indispensable de notre vie quotidienne. Que ce soit au travail ou dans la vie, nous avons tous besoin de communiquer et d'interagir avec les autres en ligne. Par conséquent, la mise en œuvre d’une fonction de communication en ligne devient de plus en plus importante dans le développement de sites Web d’aujourd’hui. Cet article explique comment utiliser PHP pour implémenter une fonction de communication en ligne de base et fournit des exemples de code complets.

1. Conception de la table MySQL

Avant de commencer à écrire du code PHP, veuillez concevoir la structure de la table de la base de données en fonction de vos besoins. Par exemple, concevez une structure de table nommée chat_message. ID de l'expéditeur ;

Contenu du message ;
Heure d'envoi.
Sur la base des exigences ci-dessus, nous devons concevoir la structure de table suivante :

CREATE TABLE `chat_message` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `from_user_id` int(11) unsigned NOT NULL,
  `to_user_id` int(11) unsigned NOT NULL,
  `message` varchar(255) DEFAULT '',
  `send_time` datetime DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

2. Connectez-vous à la base de données MySQL

En PHP, la connexion à la base de données MySQL est très simple. Il suffit d'utiliser la fonction mysqli_connect() pour se connecter à MySQL.

Ce qui suit est un exemple de connexion à une base de données MySQL :

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

// 创建连接
$conn = mysqli_connect($servername, $username, $password, $dbname);

// 检查连接是否成功
if (!$conn) {
    die("Connection failed: " . mysqli_connect_error());
}

3. Insérer un message de discussion

Lorsqu'un utilisateur envoie un message de discussion sur le site Web, nous devons insérer le message dans la base de données.

Ce qui suit est un exemple de code pour insérer un message de chat :

// 获取发送人ID和接收人ID
$from_user_id = $_SESSION['user_id'];
$to_user_id = $_POST['to_user_id'];
$message = $_POST['message'];

// 获取当前时间
$send_time = date('Y-m-d H:i:s');

// 将数据插入到 chat_message 表中
$sql = "INSERT INTO chat_message (from_user_id, to_user_id, message, send_time)
VALUES ('$from_user_id', '$to_user_id', '$message', '$send_time')";

if (mysqli_query($conn, $sql)) {
    echo "New record created successfully";
} else {
    echo "Error: " . $sql . "<br>" . mysqli_error($conn);
}

4. Obtenir l'historique du chat

Lorsque l'utilisateur consulte l'historique du chat sur le site Web, nous devons obtenir les messages historiques de la base de données.

Ce qui suit est un exemple de code pour obtenir l'historique des discussions :

// 获取对话双方的ID
$user1_id = $_GET['user1_id'];
$user2_id = $_GET['user2_id'];

// 查询消息记录
$sql = "SELECT * FROM chat_message WHERE
        (from_user_id = '$user1_id' AND to_user_id = '$user2_id') OR
        (from_user_id = '$user2_id' AND to_user_id = '$user1_id')
        ORDER BY send_time ASC";
$result = mysqli_query($conn, $sql);

// 输出消息记录
while($row = mysqli_fetch_assoc($result)) {
    echo $row['send_time'] . " - " . $row['message'] . "<br>";
}

Le code ci-dessus interrogera les enregistrements de discussion liés à l'utilisateur actuel à partir de la table chat_message et affichera les enregistrements de messages dans l'ordre de l'heure d'envoi.

5. Implémenter l'interface utilisateur Web

Enfin, nous devons écrire une interface utilisateur Web pour permettre aux utilisateurs d'envoyer et de recevoir des messages de discussion dans le navigateur.

Ce qui suit est un exemple de code pour implémenter une interface utilisateur Web :

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>网上交流功能</title>
</head>
<body>
    <h1>网上交流功能</h1>
    <div id="chat_box" style="border: 1px solid black; height: 500px; overflow: auto;"></div>
    <br>
    <form id="message_form" action="" method="POST">
        接收人ID：<input type="text" name="to_user_id"><br><br>
        消息内容：<input type="text" name="message"><br><br>
        <input type="submit" value="发送">
    </form>

    <script>
        // 获取聊天记录
        setInterval(function() {
            var xmlhttp = new XMLHttpRequest();
            xmlhttp.onreadystatechange = function() {
                if (this.readyState == 4 && this.status == 200) {
                    document.getElementById("chat_box").innerHTML = this.responseText;
                }
            };
            xmlhttp.open("GET", "get_chat_history.php?user1_id="+user1_id+"&user2_id="+user2_id, true);
            xmlhttp.send();
        }, 1000);

        // 发送消息
        document.getElementById("message_form").addEventListener("submit", function(event) {
            event.preventDefault();
            var xmlhttp = new XMLHttpRequest();
            xmlhttp.onreadystatechange = function() {
                if (this.readyState == 4 && this.status == 200) {
                    console.log(this.responseText);
                }
            };
            var data = new FormData(document.getElementById("message_form"));
            xmlhttp.open("POST", "insert_chat_message.php", true);
            xmlhttp.send(data);
            document.getElementById("message_form").reset();
        });
    </script>
</body>
</html>

Le code ci-dessus créera une interface utilisateur Web et permettra aux utilisateurs d'envoyer et de recevoir des messages en remplissant des formulaires. En utilisant la fonction setInterval() pour interroger périodiquement les enregistrements de discussion et en utilisant l'objet XMLHttpRequest pour envoyer des données au serveur, nous pouvons vérifier les nouveaux enregistrements de discussion en temps réel. Dans le même temps, en ajoutant un écouteur d'événements au formulaire à l'aide de la fonction addEventListener(), nous pouvons capturer les messages soumis par l'utilisateur et les insérer dans la base de données.

6. Code complet

Ce qui suit est un exemple de code PHP pour se connecter à la base de données MySQL, insérer des messages de discussion et obtenir l'historique des discussions.

connect_db.php

<?php
$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "chat_db";

// 创建连接
$conn = mysqli_connect($servername, $username, $password, $dbname);

// 检查连接是否成功
if (!$conn) {
    die("Connection failed: " . mysqli_connect_error());
}
?>

insert_chat_message.php

get_chat_history.php

Ce qui précède est un exemple de code complet d'utilisation de PHP pour implémenter des fonctions de communication en ligne. Étant donné que cet exemple de code ne prend pas en compte d'autres aspects tels que la sécurité, veuillez prêter attention aux améliorations et optimisations lors de son utilisation.

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!

Déclaration：

Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn

Article précédent：Comment attribuer des valeurs clés au tableau phpArticle suivant：Comment attribuer des valeurs clés au tableau php

Articles Liés

Voir plus