Panduan Pembangunan Bilik Sembang ThinkPHP6: Melaksanakan Fungsi Komunikasi Masa Nyata-ThinkPHP-php.cn

Panduan Pembangunan Bilik Sembang ThinkPHP6: Melaksanakan Fungsi Komunikasi Masa Nyata

WBOY

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

asal

1302 orang telah melayarinya

Panduan Pembangunan Bilik Sembang ThinkPHP6: Melaksanakan Fungsi Komunikasi Masa Nyata

Pengenalan:
Dengan perkembangan pesat Internet, permintaan untuk komunikasi masa nyata juga semakin meningkat. Sebagai kaedah biasa komunikasi masa nyata, bilik sembang telah mendapat perhatian dan penggunaan yang meluas. Artikel ini akan memberikan anda kaedah yang mudah dan pantas untuk melaksanakan fungsi komunikasi masa nyata dengan menggunakan rangka kerja ThinkPHP6.

1. Konfigurasi persekitaran:
Sebelum kita mula, kita perlu mengkonfigurasi persekitaran pembangunan. Pastikan anda telah memasang rangka kerja PHP dan ThinkPHP6. Pada masa yang sama, artikel ini akan menggunakan pangkalan data MySQL, jadi anda juga perlu memastikan bahawa anda telah memasang dan mengkonfigurasi MySQL dengan betul.

2 Buat pangkalan data dan jadual:
Kami mula-mula mencipta pangkalan data bernama bilik sembang. Kemudian buat jadual bernama mesej untuk menyimpan mesej sembang. Struktur jadual adalah seperti berikut:

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;

Salin selepas log masuk

3. Tulis pengawal dan pandangan:
Seterusnya, kita perlu mencipta pengawal Bilik Sembang untuk mengendalikan logik berkaitan bilik sembang. Cipta Chatroom.php dalam direktori aplikasi/pengawal dan tambah kod berikut:

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

Salin selepas log masuk

Buat index.html dalam direktori app/view dan tambah kod berikut:

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

Salin selepas log masuk

4. Mulakan perkhidmatan WebSocket:
ThinkPHP6 tidak disepadukan secara lalai perkhidmatan WebSocket, kita perlu menggunakan sambungan GatewayWorker untuk melaksanakannya. Mula-mula, kita perlu memasang sambungan GatewayWorker:

composer require workerman/gatewayworker

Salin selepas log masuk

Seterusnya, buat start.php dalam direktori akar projek dan tambah kod berikut:

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

Salin selepas log masuk

Kemudian laksanakan arahan berikut dalam baris arahan untuk memulakan perkhidmatan WebSocket:

php start.php start

Salin selepas log masuk

5. Lengkap :
Kini, kita boleh menggunakan ruang sembang dengan melayari http://localhost/chatroom/index. Selepas memasukkan mesej, klik Hantar untuk menghantar dan menerima mesej dalam masa nyata.

Kesimpulan:
Melalui panduan artikel ini, kami berjaya melaksanakan ruang sembang mudah menggunakan rangka kerja ThinkPHP6 dan sambungan GatewayWorker. Saya harap artikel ini dapat memberikan pembaca beberapa rujukan berguna untuk membantu melaksanakan fungsi komunikasi masa nyata dengan cepat. Walau bagaimanapun, perlu diingatkan bahawa artikel ini hanya memberikan contoh mudah Dalam projek sebenar, ia perlu dikembangkan dan dioptimumkan mengikut keperluan tertentu.

Atas ialah kandungan terperinci Panduan Pembangunan Bilik Sembang ThinkPHP6: Melaksanakan Fungsi Komunikasi Masa Nyata. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!