Swoole melaksanakan fungsi sosial berprestasi tinggi-Swoole-php.cn

Dengan perkembangan pesat media sosial, semakin banyak syarikat dan individu perlu melaksanakan fungsi sosial dalam laman web atau aplikasi mereka untuk berinteraksi dan berkomunikasi dengan lebih baik dengan pengguna. Untuk mencapai keselarasan tinggi dan fungsi sosial kependaman rendah, pembangun perlu memilih beberapa alatan dan rangka kerja berprestasi tinggi. Antaranya, Swoole adalah pilihan yang sangat baik.

Swoole ialah rangka kerja komunikasi rangkaian berprestasi tinggi tak segerak berdasarkan PHP Ia direka untuk meningkatkan prestasi aplikasi web, terutamanya apabila mengendalikan permintaan serentak tinggi. Swoole boleh disepadukan dengan lancar dengan elemen bahasa konvensional PHP Ia juga menyediakan API untuk mengendalikan coroutine asas secara langsung, TCP, UDP, soket Unix, HTTP, WebSocket dan protokol rangkaian lain, membolehkan pembangun melaksanakan pelbagai tugasan berprestasi tinggi dengan lebih mudah.

Mari kita terokai cara menggunakan Swoole untuk melaksanakan fungsi sosial berprestasi tinggi.

Melaksanakan perkhidmatan WebSocket

WebSocket ialah protokol yang sangat penting apabila melaksanakan fungsi sosial. Ia menyokong penghantaran data dua hala, masa nyata, membolehkan pelayan menolak mesej kepada pelanggan dalam masa nyata, dan juga membenarkan pelanggan berinteraksi dengan pelayan dalam masa nyata. Dalam Swoole, kita boleh menggunakan kelas swoole_websocket_server untuk melaksanakan perkhidmatan WebSocket.

Berikut ialah contoh mudah:

$server = new swoole_websocket_server("0.0.0.0", 9501);

$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "WebSocket客户端{$request->fd}已连接
";
});

$server->on('message', function (swoole_websocket_server $server, $frame) {
    echo "来自客户端{$frame->fd}的消息：{$frame->data}
";
    $server->push($frame->fd, "这是来自服务器的回复");
});

$server->on('close', function ($server, $fd) {
    echo "WebSocket客户端{$fd}已关闭
";
});

$server->start();

Salin selepas log masuk

Dalam contoh ini, kami mencipta pelayan WebSocket dan mendengar port 9501, mencetak maklumat log apabila pelanggan menyambung atau memutuskan sambungan. Apabila menerima mesej daripada klien, pelayan mencetak kandungan mesej dan membalas dengan mesej.

Gunakan coroutine untuk melaksanakan permintaan HTTP dan mesej tolak

Swoole menyediakan sokongan untuk coroutine, yang membolehkan kami melakukan operasi seperti permintaan HTTP dan tugas tak segerak dengan lebih mudah. Apabila melaksanakan fungsi sosial, kami selalunya perlu membuat permintaan HTTP, seperti mendapatkan maklumat peribadi pengguna, senarai rakan dan maklumat lain. Berikut ialah contoh menggunakan klien HTTP coroutine Swoole:

co(function () {
    $cli = new SwooleCoroutineHttpClient('www.example.com', 80);
    $cli->set(['timeout' => 1]);
    $cli->setHeaders([
        'Host' => 'www.example.com',
        'User-Agent' => 'Chrome/49.0.2587.3',
        'Accept' => 'text/html,application/xhtml+xml,application/xml',
        'Accept-Encoding' => 'gzip',
    ]);
    $cli->get('/path/to/api');

    echo $cli->body;
});

Salin selepas log masuk

Dalam contoh ini, kami menggunakan kelas SwooleCoroutineHttpClient untuk membuat permintaan HTTP. Kelas ini ialah klien coroutine yang boleh melaksanakan operasi permintaan HTTP tak segerak. Sebelum menghantar permintaan, kami boleh menetapkan tamat masa permintaan dan meminta maklumat pengepala. Selepas melaksanakan permintaan, kami boleh mendapatkan kandungan respons melalui $cli->body.

Seterusnya, kita boleh menggunakan permintaan HTTP coroutine dalam pelayan WebSocket untuk meminta klien, mendapatkan maklumat pengguna dan menolaknya kepada klien. Sebagai contoh, apabila mendapatkan profil pengguna, kami boleh menggunakan kod berikut:

$server->on('message', function (swoole_websocket_server $server, $frame) {
    $path = '/user/profile?id=' . $frame->data;
    $cli = new SwooleCoroutineHttpClient('www.example.com', 80);
    $cli->set(['timeout' => 1]);
    $cli->setHeaders([
        'Host' => 'www.example.com',
        'User-Agent' => 'Chrome/49.0.2587.3',
        'Accept' => 'text/html,application/xhtml+xml,application/xml',
        'Accept-Encoding' => 'gzip',
    ]);
    $cli->get($path);

    $profile = json_decode($cli->body, true);

    $server->push($frame->fd, json_encode($profile));
});

Salin selepas log masuk

Dalam contoh ini, kami menerima mesej melalui pelayan WebSocket yang menunjukkan bahawa kami ingin mendapatkan profil pengguna. Kami menggunakan kelas SwooleCoroutineHttpClient untuk membuat permintaan HTTP dan menghuraikan data JSON respons ke dalam tatasusunan $profile. Akhirnya, kandungan $profile ditolak kepada pelanggan melalui WebSocket.

Gunakan klien Swoole Redis untuk caching

Caching ialah keperluan yang sangat biasa apabila melaksanakan fungsi sosial. Untuk meningkatkan kecekapan membaca data, kita selalunya perlu menggunakan alat caching seperti Redis untuk cache data. Dalam Swoole, anda boleh menggunakan klien Swoole Redis untuk berinteraksi dengan pantas dengan tika Redis.

Berikut ialah contoh menggunakan klien Swoole Redis:

$redis = new SwooleCoroutineRedis();
$redis->connect('127.0.0.1', 6379);
$redis->set('key', 'value');
$value = $redis->get('key');

Salin selepas log masuk

Dalam contoh ini, kami menggunakan kelas SwooleCoroutineRedis untuk melaksanakan fungsi klien Redis, yang menjadikannya sangat mudah dibaca dan tulis data.

Untuk senario aplikasi caching, sebagai contoh, apabila mendapatkan senarai rakan, kita boleh cache data ke dalam Redis Apabila pengguna meminta senarai rakan, data dibaca daripada Redis cache, kemudian Baca data daripada pangkalan data dan cache dalam Redis. Ini dapat mengurangkan beban pangkalan data dan meningkatkan kecekapan membaca data.

Melaksanakan siaran dan fungsi sembang peribadi

Dalam aplikasi sosial, siaran dan fungsi sembang peribadi juga penting. Fungsi penyiaran membolehkan mesej dihantar kepada semua pengguna dalam talian sekaligus, manakala fungsi sembang peribadi membolehkan komunikasi masa nyata rakan ke rakan antara pengguna. Dalam Swoole, kedua-dua fungsi ini boleh dicapai melalui pelayan WebSocket.

Berikut ialah pelaksanaan mudah:

$server->on('message', function (swoole_websocket_server $server, $frame) {
    $data = json_decode($frame->data, true);
    switch ($data['command']) {
        case 'broadcast':
            $server->push('broadcast', $data['message']);
            break;
        case 'private':
            $server->push($data['id'], $data['message']);
            break;
    }
});

Salin selepas log masuk

Dalam contoh ini, kami melakukan operasi penyiaran atau sembang peribadi dengan menilai jenis mesej yang diterima. Jika jenis mesej yang diterima disiarkan, mesej akan ditolak kepada semua pengguna dalam talian jika jenis mesej yang diterima adalah peribadi, mesej akan ditolak kepada pengguna yang ditentukan.

Dalam klien WebSocket, kami juga perlu membuat beberapa pelarasan yang sepadan, seperti menyertai bilik siaran untuk menerima mesej siaran:

let ws = new WebSocket('ws://localhost:9501');
ws.onopen = function () {
    // 加入broadcast房间
    ws.send(JSON.stringify({command: 'join', room: 'broadcast'}));
};
ws.onmessage = function (event) {
    let data = JSON.parse(event.data);
    // 处理广播消息
    if (data.room === 'broadcast') {
        console.log(data.message);
    }
};

Salin selepas log masuk

Dalam contoh ini, kami menggunakan klien WebSocket untuk menyertai The bilik siaran boleh menerima mesej yang disiarkan oleh pelayan dan mengeluarkannya dalam konsol.

Ringkasan

Melalui demonstrasi di atas, kita dapat melihat bahawa Swoole menyediakan fungsi yang sangat berkuasa dan kaya yang boleh membantu kita mencapai keselarasan tinggi dan fungsi sosial kependaman rendah. Dalam aplikasi praktikal, kami perlu memilih alat dan penyelesaian yang sesuai berdasarkan keperluan dan senario khusus untuk meningkatkan pengalaman pengguna dan kebolehselenggaraan sistem.

Atas ialah kandungan terperinci Swoole melaksanakan fungsi sosial berprestasi tinggi. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!