ThinkPHP6 Chatroom-Entwicklungshandbuch: Implementierung von Echtzeit-Kommunikationsfunktionen-Denken Sie an PHP-php.cn

ThinkPHP6 Chatroom-Entwicklungshandbuch: Implementierung von Echtzeit-Kommunikationsfunktionen

WBOY

Freigeben： 2023-08-12 14:31:47

Original

1268 Leute haben es durchsucht

ThinkPHP6 Chatroom-Entwicklungshandbuch: Implementierung von Echtzeit-Kommunikationsfunktionen

ThinkPHP6 Chatroom-Entwicklungsleitfaden: Implementierung von Echtzeit-Kommunikationsfunktionen

Einführung:
Mit der rasanten Entwicklung des Internets steigt auch die Nachfrage nach Echtzeitkommunikation. Als gängige Methode der Echtzeitkommunikation haben Chatrooms große Aufmerksamkeit und Nutzung erfahren. Dieser Artikel bietet Ihnen eine einfache und schnelle Methode zur Implementierung von Echtzeit-Kommunikationsfunktionen mithilfe des ThinkPHP6-Frameworks.

1. Umgebungskonfiguration:
Bevor wir beginnen, müssen wir die Entwicklungsumgebung konfigurieren. Stellen Sie sicher, dass PHP und das ThinkPHP6-Framework installiert sind. Gleichzeitig wird in diesem Artikel die MySQL-Datenbank verwendet. Sie müssen daher auch sicherstellen, dass Sie MySQL korrekt installiert und konfiguriert haben.

2. Datenbank und Tabellen erstellen:
Wir erstellen zunächst eine Datenbank namens Chatroom. Erstellen Sie dann eine Tabelle mit dem Namen „Nachrichten“, um Chat-Nachrichten zu speichern. Die Tabellenstruktur ist wie folgt:

CREATE TABLE `messages` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `content` text COLLATE utf8mb4_unicode_ci NOT NULL,
  `created_at` timestamp NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;

Nach dem Login kopieren

3. Schreiben Sie Controller und Ansichten:
Als nächstes müssen wir einen Chatroom-Controller erstellen, um die Chatroom-bezogene Logik zu verwalten. Erstellen Sie Chatroom.php im Verzeichnis app/controller und fügen Sie den folgenden Code hinzu:

<?php
namespace appcontroller;

use thinkacadeView;
use GatewayWorkerLibGateway;

class Chatroom
{
    public function index()
    {
        return View::fetch('index');
    }

    public function sendMessage()
    {
        $content = input('post.content');
        $data = [
            'content' => $content,
            'created_at' => date('Y-m-d H:i:s')
        ];
            hinkacadeDb::name('messages')->insert($data);
        Gateway::sendToAll(json_encode($data));
    }
}

Nach dem Login kopieren

Erstellen Sie index.html im Verzeichnis app/view und fügen Sie den folgenden Code hinzu:

<!DOCTYPE html>
<html>
<head>
    <title>聊天室</title>
    <script src="https://cdn.bootcdn.net/ajax/libs/jquery/3.6.0/jquery.min.js"></script>
</head>
<body>
    <div>
        <textarea id="message" style="width: 300px; height: 100px;"></textarea>
        <button onclick="sendMessage()">发送</button>
    </div>
    <div id="chatContent"></div>
</body>
<script>
    var websocket = new WebSocket('ws://localhost:8282');
    websocket.onopen = function () {
        console.log('连接成功');
    };
    websocket.onmessage = function (evt) {
        var message = JSON.parse(evt.data);
        $('#chatContent').append('<p>' + message.content + ' - ' + message.created_at + '</p>');
    };
    websocket.onerror = function () {
        console.log('连接失败');
    };
    websocket.onclose = function () {
        console.log('断开连接');
    };

    function sendMessage() {
        var content = $('#message').val();
        $.ajax({
            type: 'POST',
            url: '<?php echo url("Chatroom/sendMessage"); ?>',
            data: {content: content},
            success: function () {
                $('#message').val('');
            },
            error: function () {
                alert('发送失败');
            }
        });
    }
</script>
</html>

Nach dem Login kopieren

4. Starten Sie den WebSocket-Dienst:
ThinkPHP6 ist nicht integriert Als Standard-WebSocket-Dienst müssen wir die GatewayWorker-Erweiterung verwenden, um ihn zu implementieren. Zuerst müssen wir die GatewayWorker-Erweiterung installieren:

composer require workerman/gatewayworker

Nach dem Login kopieren

Als nächstes erstellen wir start.php im Stammverzeichnis des Projekts und fügen den folgenden Code hinzu:

<?php
use thinkacadeDb;
use WorkermanWorker;
use GatewayWorkerGateway;

require __DIR__ . '/vendor/autoload.php';

$worker = new Worker('websocket://0.0.0.0:8282');
$worker->name = 'ChatroomGateway';
$worker->count = 1;

$worker->onWorkerStart = function () {
    Gateway::$registerAddress = '127.0.0.1:1238';
    Gateway::onConnect(function ($connection) {
        $messages = Db::name('messages')->select();
        Gateway::sendToCurrentClient(json_encode($messages));
    });
    Gateway::onMessage(function ($connection, $data) {
        Gateway::sendToAll($data);
    });
};

Worker::runAll();

Nach dem Login kopieren

Führen Sie dann den folgenden Befehl in der Befehlszeile aus, um den WebSocket-Dienst zu starten:

php start.php start

Nach dem Login kopieren

5. Abschließen:
Jetzt können wir den Chatroom nutzen, indem wir http://localhost/chatroom/index besuchen. Nachdem Sie die Nachricht eingegeben und auf Senden geklickt haben, können Sie Nachrichten in Echtzeit senden und empfangen.

Fazit:
Durch die Anleitung dieses Artikels haben wir erfolgreich einen einfachen Chatroom mit dem ThinkPHP6-Framework und der GatewayWorker-Erweiterung implementiert. Ich hoffe, dass dieser Artikel den Lesern einige nützliche Referenzen liefern kann, die dabei helfen, Echtzeit-Kommunikationsfunktionen schnell zu implementieren. Es ist jedoch zu beachten, dass dieser Artikel nur ein einfaches Beispiel darstellt. In tatsächlichen Projekten muss er entsprechend den spezifischen Anforderungen erweitert und optimiert werden.

Das obige ist der detaillierte Inhalt vonThinkPHP6 Chatroom-Entwicklungshandbuch: Implementierung von Echtzeit-Kommunikationsfunktionen. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!