Pengurusan cache yang cekap menggunakan perkhidmatan RPC yang dibangunkan oleh ThinkPHP6 dan Swoole

Gunakan perkhidmatan ThinkPHP6 dan RPC yang dibangunkan oleh Swoole untuk mencapai pengurusan cache yang cekap

Pengenalan:
Dalam aplikasi web moden, pengurusan cache ialah salah satu bahagian penting untuk meningkatkan prestasi dan tindak balas pantas. Untuk mempercepatkan akses data, kami biasanya menggunakan cache untuk menyimpan data yang kerap diakses untuk mengelakkan operasi pertanyaan pangkalan data yang kompleks setiap kali. Artikel ini akan memperkenalkan cara menggunakan ThinkPHP6 dan Swoole untuk membangunkan perkhidmatan RPC (panggilan prosedur jauh) yang cekap untuk melaksanakan fungsi pengurusan cache.

1. Pengenalan
ThinkPHP ialah rangka kerja pembangunan PHP yang sangat baik yang menyediakan pelbagai ciri dan komponen untuk memudahkan pembangun membina aplikasi web berprestasi tinggi dengan cepat. Swoole ialah sambungan PHP berprestasi tinggi yang boleh menukar kod PHP untuk dijalankan dalam cara tak segerak dan tidak menyekat, meningkatkan keselarasan dan kelajuan tindak balas aplikasi. Dalam artikel ini, kami akan menggunakan ThinkPHP6 sebagai rangka kerja pembangunan aplikasi web dan menggabungkannya dengan Swoole untuk melaksanakan sistem pengurusan cache yang cekap.

2. Reka bentuk seni bina
Untuk mencapai pengurusan cache yang cekap, kami perlu mereka bentuk perkhidmatan RPC untuk menyediakan antara muka untuk operasi cache. Perkhidmatan RPC boleh berjalan secara bebas, menerima permintaan daripada aplikasi web dan memajukannya ke pelayan cache untuk diproses. Reka bentuk seni bina khusus adalah seperti berikut:

1. Aplikasi web menghantar permintaan dengan menghubungi pelanggan RPC.
2. Pelanggan RPC menghantar permintaan ke pelayan RPC.
3. Pelayan RPC menerima permintaan dan memprosesnya.
4. Pelayan RPC memajukan permintaan kepada pelayan cache untuk operasi caching tertentu.
5. Pelayan cache mengembalikan keputusan kepada pelayan RPC.
6. Pelayan RPC mengembalikan keputusan kepada klien RPC.
7. Pelanggan RPC mengembalikan keputusan kepada aplikasi web. Implementasi kod

Buat pelayan RPC

Pertama, buat kelas bernama RpcServer untuk melaksanakan fungsi pelayan RPC. Kodnya adalah seperti berikut:

1. namespace apppc;
   
   use SwooleHttpServer;
   use SwooleProcess;
use SwooleCoroutine;
2. use SwooleRuntime;
   use think acadedb;
Class ThinkDb;

private $serv;
private $processNum;

public function __construct($port, $processNum)
{
    $this->serv = new Server('0.0.0.0', $port);
    $this->processNum = $processNum;
}

public function start()
{
    $this->serv->on('Start', [$this, 'onStart']);
    $this->serv->on('ManagerStart', [$this, 'onManagerStart']);
    $this->serv->on('Request', [$this, 'onRequest']);
    $this->serv->on('WorkerStart', [$this, 'onWorkerStart']);

    $this->serv->set([
        'worker_num' => $this->processNum,
    ]);

    $this->serv->start();
}

public function onStart($serv)
{
    Process::daemon();
    swoole_set_process_name('rpc_server');
}

public function onManagerStart($serv)
{
    swoole_set_process_name('rpc_manager');
}

public function onRequest($request, $response)
{
    Coroutine::create(function () use ($request, $response) {
        $container = Container::getInstance();
        $container->instance('thinkRequest', $request);
        $container->instance('thinkResponse', $response);

        $http = $container->make('thinkApp', [
            $container,
        ]);

        $response = $http->run();
        $response->send();
    });
}

public function onWorkerStart($serv, $workerId)
{
    if ($workerId >= $serv->setting['worker_num']) {
        Runtime::enableCoroutine();
    }
}

}

Buat Pengawal Pengurusan cache
Seterusnya, cipta kelas pengawal bernama CacheController untuk melaksanakan logik khusus operasi cache. Kodnya adalah seperti berikut:

namespace apppccontroller;

gunakan think acadeCache;

class CacheController

{

public function get($key)
{
    return Cache::get($key);
}

public function set($key, $value, $expire = null)
{
    return Cache::set($key, $value, $expire);
}

public function delete($key)
{
    return Cache::delete($key);
}

3. }
   

Konfigurasi laluan php dan direktori rpc dalam fail. kod berikut:

gunakan think acadeRoute;

Route::group('rpc', function () {

Route::rule('cache/:action', 'rpc.Cache/:action');

});

4. Mulakan pelayan RPC
   Akhir sekali, kita perlu menulis fail entri untuk mulakan pelayan RPC. Dalam direktori awam, buat fail bernama rpc.php dan tambahkan kod berikut:

use apppcRpcServer;

require

DIR

../vendor/autoload.php';

$port = 9501 // Nombor port berjalan
5. $processNum = 4; // Bilangan proses
   
$server = RpcServer baharu($port, $processNum);

$server->start();

4. Gunakan klien RPC Memanggil perkhidmatan pengurusan cache

Dalam aplikasi web, kami boleh menggunakan klien RPC untuk memanggil perkhidmatan pengurusan cache dan mengendalikan cache. Berikut ialah contoh kod menggunakan klien RPC: $client = new SwooleHttpClient('127.0.0.1', 9501);

// Panggil kaedah cache/get untuk mendapatkan nilai cache
$request = array(

'action' => 'get',
'key' => 'user:1',

);
$client->post('/rpc/cache', $request);

$response = json_decode($client->body, true);

if ($respons['status'] = = 200) {

echo '缓存值为：' . $response['data'];

}

//Panggil kaedah cache/set dan tetapkan nilai cache

$request = array(

'action' => 'set',
'key' => 'user:1',
'value' => 'John Doe',
'expire' => 3600,

);

$client->post('/rpc/cache', $ request);
$response = json_decode($client->body, true);
if ($response['status'] == 200) {

echo '设置缓存成功';

}

// Panggil kaedah cache/padam untuk memadam nilai cache

$request = array (

'action' => 'delete',
'key' => 'user:1',

);

$client->post('/rpc/cache', $request);
$response = json_decode($client->body, true);
if ($response['status' ] == 200) {

echo '删除缓存成功';

}

Ringkasan:

Melalui pengenalan artikel ini, kami telah mempelajari cara menggunakan ThinkPHP6 dan Swoole untuk membangunkan perkhidmatan RPC yang cekap bagi melaksanakan fungsi pengurusan cache . Melalui kerjasama pelayan RPC dan klien RPC, kami boleh memanggil dan mengendalikan data cache dengan mudah, meningkatkan prestasi aplikasi dan memberikan pengalaman yang lebih baik kepada pengguna. Sudah tentu, sebagai tambahan kepada pengurusan cache, kami juga boleh menggabungkan modul berfungsi lain untuk membangunkan lebih banyak perkhidmatan RPC untuk memenuhi keperluan senario aplikasi yang berbeza. Saya harap artikel ini akan membantu kerja pembangunan anda!

Atas ialah kandungan terperinci Pengurusan cache yang cekap menggunakan perkhidmatan RPC yang dibangunkan oleh ThinkPHP6 dan Swoole. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!