PHP développe des fonctions de groupe d'utilisateurs et d'abonnement pour un système de chat en temps réel

Développement PHP de groupes d'utilisateurs et de fonctions d'abonnement du système de chat en temps réel

À l'ère de l'Internet social d'aujourd'hui, le système de chat en temps réel est devenu un outil important pour la communication quotidienne des gens. Afin d'offrir une meilleure expérience utilisateur, nous devons mettre en œuvre des fonctions de groupe d'utilisateurs et d'abonnement afin que les utilisateurs puissent facilement créer et rejoindre des groupes et s'abonner au contenu qui les intéresse.

Cet article expliquera comment utiliser PHP pour développer des groupes d'utilisateurs et des fonctions d'abonnement d'un système de chat en temps réel. Nous utiliserons WebSocket pour implémenter des fonctions de communication en temps réel et le combinerons avec une base de données MySQL pour gérer les informations sur les utilisateurs et les groupes.

Tout d’abord, nous devons créer un cadre de base pour un système de chat en temps réel. Voici un exemple simple de serveur WebSocket, implémenté à l'aide de la bibliothèque Ratchet :

require 'vendor/autoload.php';

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetServerIoServer;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;

class Chat implements MessageComponentInterface {
    protected $clients;
    protected $groups;

    public function __construct() {
        $this->clients = new SplObjectStorage;
        $this->groups = array();
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New connection: ({$conn->resourceId})
";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        // 处理收到的消息
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        echo "Connection {$conn->resourceId} has disconnected
";
    }

    public function onError(ConnectionInterface $conn, Exception $e) {
        echo "An error has occurred: {$e->getMessage()}
";
        $conn->close();
    }
}

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

$server->run();

L'exemple ci-dessus crée une classe WebSocket nommée Chat pour gérer les événements d'ouverture, de messagerie et de fermeture de la connexion. Où $this->clients est un objet SplObjectStorage qui enregistre toutes les connexions client, et $this->groups est un tableau de groupe de sauvegarde. d'informations. $this->clients是一个保存所有客户端连接的SplObjectStorage对象，$this->groups是一个保存群组信息的数组。

接下来，我们需要添加一些方法来实现用户加入群组和订阅功能。在Chat类中添加以下代码：

public function joinGroup(ConnectionInterface $conn, $groupId) {
    // 将用户加入群组
    $this->groups[$groupId][] = $conn;
    echo "User ({$conn->resourceId}) joined group {$groupId}
";
}

public function leaveGroup(ConnectionInterface $conn, $groupId) {
    // 将用户从群组中移除
    $index = array_search($conn, $this->groups[$groupId]);
    if ($index !== false) {
        unset($this->groups[$groupId][$index]);
        echo "User ({$conn->resourceId}) left group {$groupId}
";
    }
}

public function subscribe(ConnectionInterface $conn, $topic) {
    // 订阅某个主题
    $conn->topics[] = $topic;
    echo "User ({$conn->resourceId}) subscribed to {$topic}
";
}

public function unsubscribe(ConnectionInterface $conn, $topic) {
    // 取消订阅某个主题
    $index = array_search($topic, $conn->topics);
    if ($index !== false) {
        unset($conn->topics[$index]);
        echo "User ({$conn->resourceId}) unsubscribed from {$topic}
";
    }
}

以上代码中，joinGroup方法将用户加入指定的群组，leaveGroup方法将用户从群组中移除，subscribe方法将用户订阅指定的主题，unsubscribe

Ensuite, nous devons ajouter quelques méthodes pour implémenter les fonctions d'adhésion et d'abonnement des utilisateurs. Ajoutez le code suivant à la classe Chat :

CREATE TABLE `users` (
  `id` int(11) UNSIGNED AUTO_INCREMENT PRIMARY KEY,
  `name` varchar(255) NOT NULL,
  `email` varchar(255) NOT NULL
);

CREATE TABLE `groups` (
  `id` int(11) UNSIGNED AUTO_INCREMENT PRIMARY KEY,
  `name` varchar(255) NOT NULL
);

CREATE TABLE `group_user` (
  `group_id` int(11) UNSIGNED NOT NULL,
  `user_id` int(11) UNSIGNED NOT NULL,
  PRIMARY KEY (`group_id`, `user_id`),
  FOREIGN KEY (`group_id`) REFERENCES `groups`(`id`),
  FOREIGN KEY (`user_id`) REFERENCES `users`(`id`)
);

Dans le code ci-dessus, la méthode joinGroup ajoute l'utilisateur au groupe spécifié et la méthode leaveGroup supprime l'utilisateur de le groupe. La méthode subscribe abonne l'utilisateur à un sujet spécifié et la méthode unsubscribe annule l'abonnement de l'utilisateur à un sujet. Lorsqu'un utilisateur rejoint un groupe ou s'abonne à un sujet, nous devons enregistrer les informations pertinentes dans la base de données.

Ce qui suit est un exemple de structure de table de base de données pour enregistrer les informations sur les utilisateurs et les groupes :

public function joinGroup(ConnectionInterface $conn, $groupId) {
    // 将用户加入群组
    // ...

    // 将用户加入数据库
    $userId = $_SESSION['user_id']; // 假设用户登录时已经保存用户ID到session中
    $query = "INSERT INTO group_user (group_id, user_id) VALUES (?, ?)";
    $stmt = $mysqli->prepare($query);
    $stmt->bind_param("ii", $groupId, $userId);
    $stmt->execute();
}

public function subscribe(ConnectionInterface $conn, $topic) {
    // 订阅某个主题
    // ...

    // 将订阅信息保存到数据库
    $userId = $_SESSION['user_id'];
    $query = "INSERT INTO subscriptions (user_id, topic) VALUES (?, ?)";
    $stmt = $mysqli->prepare($query);
    $stmt->bind_param("is", $userId, $topic);
    $stmt->execute();
}

Lorsqu'un utilisateur rejoint un groupe ou s'abonne à un sujet, nous pouvons utiliser le code suivant pour insérer des informations pertinentes dans la base de données. être basé sur des modifications basées sur les besoins réels :

rrreee

Nous pouvons également implémenter d'autres fonctions, telles que récupérer le groupe de l'utilisateur ou le sujet abonné à partir de la base de données et envoyer le message reçu à la connexion appropriée. 🎜🎜Grâce à l'implémentation ci-dessus, nous avons implémenté avec succès des groupes d'utilisateurs et des fonctions d'abonnement dans le système de chat en temps réel développé en PHP. De cette manière, les utilisateurs peuvent facilement créer et rejoindre des groupes, s'abonner au contenu qui les intéresse et bénéficier d'une meilleure expérience de communication dans le système de discussion en temps réel. 🎜

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!