ThinkPHP6聊天室開發指南：實現實時通訊功能-魔扣目錄

ThinkPHP6聊天室開發指南：實現實時通訊功能

引言：
隨著互聯網的快速發展，實時通訊的需求也越來越大。聊天室作為一種常見的實時通訊方式，受到了廣泛的關注和使用。本文將通過使用ThinkPHP6框架，為大家提供一種簡單、快速實現實時通訊功能的方法。

一、環境配置：
在開始之前，我們需要配置好開發環境。確保你已經安裝了PHP和ThinkPHP6框架。同時，本文將使用MySQL數據庫，因此也需要確保你已經正確安裝并配置了MySQL。

二、創建數據庫和表：
我們首先創建一個名為chatroom的數據庫。然后創建一個名為messages的表，用于存儲聊天消息。表結構如下：

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;

登錄后復制

三、編寫控制器和視圖：
接下來，我們需要創建一個Chatroom控制器，用于處理聊天室相關的邏輯。在app/controller目錄下創建Chatroom.php，并添加以下代碼：

<?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));
    }
}

登錄后復制

在app/view目錄下創建index.html，并添加以下代碼：

<!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>

登錄后復制

四、啟動WebSocket服務：
ThinkPHP6默認并沒有集成WebSocket服務，我們需要借助GatewayWorker擴展來實現。首先，我們要安裝GatewayWorker擴展：

composer require workerman/gatewayworker

登錄后復制

接下來，在項目根目錄下創建start.php，并添加以下代碼：

<?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();

登錄后復制

然后在命令行中執行以下命令啟動WebSocket服務：