Cara melaksanakan storan rekod tolak dan sembang mesej masa nyata melalui Workerman

Cara melaksanakan storan rekod tolak dan sembang mesej masa nyata melalui Workerman

Dengan perkembangan pesat Internet, fungsi push dan sembang mesej masa nyata telah menjadi fungsi asas yang diperlukan oleh banyak aplikasi. Workerman, sebagai rangka kerja perkhidmatan Soket PHP berprestasi tinggi, menyediakan kami kaedah yang mudah dan berkesan untuk melaksanakan storan rekod tolak dan sembang mesej masa nyata. Artikel ini akan memperkenalkan cara melaksanakan fungsi ini melalui pekerja pekerja.

Pertama sekali, kami perlu menjelaskan dengan jelas bahawa matlamat kami adalah untuk melaksanakan sistem tolak mesej masa nyata dan sistem storan rekod sembang. Matlamat sistem tolak mesej masa nyata adalah untuk menolak mesej kepada pengguna tertentu dalam masa nyata selepas pengguna menghantar mesej manakala matlamat sistem storan rekod sembang adalah untuk menyimpan rekod sembang pengguna secara berterusan untuk rujukan masa hadapan;

Seterusnya, kita perlu menyediakan persekitaran pekerja. Pertama, kita perlu memasang kebergantungan workererman, yang boleh dilakukan melalui komposer. Jalankan arahan berikut dalam baris arahan:

composer require workerman/workerman

Selepas pemasangan selesai, kita boleh mencipta fail permulaan pekerja, contohnya, bernama start.php. Dalam fail ini, kita perlu memperkenalkan kelas Workerman's Autoloader dan Worker, dan kemudian mencipta objek Worker. Kod sampel adalah seperti berikut: start.php。在这个文件中，我们需要引入workerman的Autoloader和Worker类，然后创建一个Worker对象。示例代码如下：

<?php
require_once __DIR__ . '/vendor/autoload.php';
use WorkermanWorker;

$worker = new Worker();
// 设置监听的端口
$worker->listen('websocket://0.0.0.0:2346');

Worker::runAll();

在这个示例中，我们创建了一个Worker对象，并设置监听的端口为2346

$worker->onConnect = function($connection) {
    // 当用户连接时执行的逻辑，比如记录用户信息等
};

$worker->onClose = function($connection) {
    // 当用户断开时执行的逻辑，比如更新用户在线状态等
};

Dalam contoh ini, kami mencipta objek Worker dan menetapkan port pendengaran kepada 2346. Protokol WebSocket digunakan di sini untuk komunikasi, kerana protokol WebSocket boleh mencapai komunikasi masa nyata dua hala. Sudah tentu, anda juga boleh memilih protokol lain, seperti sambungan panjang HTTP atau Soket TCP.

Seterusnya, kita perlu menulis kod logik perniagaan tertentu. Pertama, kita perlu mengendalikan sambungan dan pemutusan sambungan pengguna. Ini boleh dicapai menggunakan kaedah onConnect dan onClose objek Worker. Kod sampel adalah seperti berikut:

$worker->onMessage = function($connection, $data) {
    // 当收到用户的消息时执行的逻辑，比如向特定用户推送消息等
};

Dalam contoh ini, apabila pengguna disambungkan, kaedah onConnect akan dipanggil apabila pengguna memutuskan sambungan, kaedah onClose akan dipanggil. Kami boleh melakukan beberapa logik di sini, seperti merekod maklumat pengguna atau mengemas kini status dalam talian pengguna.

Seterusnya, kita perlu mengendalikan desakan mesej pengguna. Ini boleh dicapai menggunakan kaedah onMessage objek Pekerja. Kod sampel adalah seperti berikut:

$worker->onMessage = function($connection, $data) {
    // 解析用户的消息
    $message = json_decode($data, true);
    // 将消息存储到数据库中
    // ...
    // 向特定用户推送消息
    // ...
};

Dalam contoh ini, kaedah onMessage dipanggil apabila mesej daripada pengguna diterima. Kami boleh melakukan beberapa logik di sini, seperti menolak mesej kepada pengguna tertentu.

Pada masa yang sama, untuk melaksanakan fungsi penyimpanan rekod sembang, kita perlu menggunakan pangkalan data untuk menyimpan rekod sembang pengguna. Anda boleh memilih MySQL atau pangkalan data lain. Selepas menerima mesej daripada pengguna, kami menyimpan mesej tersebut ke dalam pangkalan data. Kod sampel adalah seperti berikut:

$worker->onMessage = function($connection, $data) {
    // 解析用户的消息
    $message = json_decode($data, true);
    // 向特定用户推送消息
    $uid = $message['uid'];
    Gateway::sendToUid($uid, $data);
};

Dalam contoh ini, kami menggunakan fungsi json_decode untuk menghuraikan mesej pengguna ke dalam tatasusunan, dan kemudian menyimpan mesej ke dalam pangkalan data. Pelaksanaan khusus di sini perlu dikodkan dengan sewajarnya mengikut pangkalan data yang anda pilih.

Apabila menolak mesej kepada pengguna tertentu, kami boleh menggunakan pelaksanaan Gerbang pekerja. Gateway boleh menolak mesej ke sambungan atau kumpulan tertentu. Kod sampel adalah seperti berikut:

var socket = new WebSocket('ws://localhost:2346');

socket.onopen = function() {
    // 连接成功时执行的逻辑
};

socket.onmessage = function(event) {
    var data = JSON.parse(event.data);
    // 收到消息时执行的逻辑
};

socket.onclose = function() {
    // 连接断开时执行的逻辑
};

// 发送消息
function sendMsg(message) {
    socket.send(JSON.stringify(message));
}

Dalam contoh ini, kami menggunakan kaedah Gateway::sendToUid untuk menolak mesej kepada pengguna tertentu. $uid di sini ialah pengecam unik pengguna, yang boleh dijana mengikut keperluan apabila pengguna menyambung.

Akhir sekali, untuk membolehkan bahagian hadapan berkomunikasi dengan pelayan, kita perlu menulis beberapa kod bahagian hadapan. Anda boleh menggunakan API WebSocket untuk berkomunikasi dengan pelayan. Kod sampel adalah seperti berikut:

rrreee

Dalam contoh ini, kami menggunakan API WebSocket untuk mencipta objek WebSocket dan menentukan alamat sambungan dan port. Kemudian, acara onopen, onmessage dan onclose boleh digunakan untuk mengendalikan kejayaan sambungan, penerimaan mesej dan pemutusan sambungan. Pada masa yang sama, mesej boleh dihantar ke pelayan melalui kaedah socket.send.

Ringkasnya, melalui Workerman kita boleh dengan mudah melaksanakan fungsi tolak mesej masa nyata dan storan rekod sembang. Perlu diingatkan bahawa ini hanyalah contoh mudah, dan pelaksanaan sebenar mungkin memerlukan lebih banyak butiran untuk dipertimbangkan, seperti pengesahan identiti pengguna, pengurusan kumpulan, strategi push mesej, dsb. Tetapi melalui rangka kerja perkhidmatan Soket berprestasi tinggi yang disediakan oleh Workerman, kami boleh melaksanakan fungsi ini dengan mudah dan mengembangkan serta mengoptimumkan secara fleksibel mengikut keperluan. 🎜

Atas ialah kandungan terperinci Cara melaksanakan storan rekod tolak dan sembang mesej masa nyata melalui Workerman. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!