Swoole melaksanakan sistem penerbitan dan langganan yang sangat boleh dipercayai

Dengan pembangunan Internet, semakin banyak aplikasi perlu melaksanakan push dan langganan mesej masa nyata. Ini memerlukan sistem penerbitan dan langganan yang sangat dipercayai untuk menyokong permintaan ini. Swoole, sebagai rangka kerja komunikasi rangkaian berprestasi tinggi, boleh memenuhi permintaan ini dengan baik.

Swoole ialah modul lanjutan bahasa PHP, yang boleh menyediakan komunikasi rangkaian berprestasi tinggi tak segerak, selari, dan keupayaan pemprosesan serentak berbilang proses. Aplikasi yang dibangunkan berdasarkan Swoole boleh menyokong konkurensi yang lebih tinggi dan masa respons yang lebih singkat. Dalam artikel ini, kami akan memperkenalkan cara menggunakan Swoole untuk melaksanakan sistem penerbitan dan langganan yang sangat dipercayai.

1. Konsep asas sistem terbitkan-langganan

Sistem terbitan-langganan ialah model pemesejan yang menyokong penerbitan dan langganan mesej satu-ke-banyak. Penerbit menerbitkan mesej kepada satu atau lebih topik, dan pelanggan boleh melanggan topik ini mengikut minat mereka sendiri untuk menerima mesej yang sepadan.

Sistem penerbitan dan langganan biasanya terdiri daripada tiga bahagian: penerbit, pelanggan dan broker mesej (Message Broker). Penerbit menghantar mesej kepada broker mesej dan pelanggan melanggan mesej daripada broker mesej. Penerbit dan pelanggan tidak berkomunikasi secara langsung Broker mesej bertanggungjawab untuk menghalakan mesej kepada pelanggan yang sepadan.

2. Konsep asas Swoole

Sebelum memahami Swoole untuk melaksanakan sistem penerbitan dan langganan, kita perlu memahami beberapa konsep asas Swoole.

1. Proses

Dalam Swoole, proses merujuk kepada persekitaran pelaksanaan bebas. Swoole menyediakan sokongan berbilang proses dan boleh mencapai pemprosesan serentak dengan mencipta berbilang proses.

2. Pelayan

Pelayan ialah modul teras rangka kerja Swoole dan boleh mencipta pelayan TCP atau UDP. Apabila pelayan bermula, ia akan mencipta proses utama dan berbilang sub-proses Proses utama bertanggungjawab untuk mendengar pada port, dan sub-proses mengendalikan permintaan tertentu.

3. Pemasa

Swoole menyediakan fungsi pemasa yang boleh melaksanakan sekeping kod dalam selang masa yang ditentukan. Pemasa boleh digunakan dalam senario seperti tugas berjadual dan semakan berjadual.

4. Coroutine

Coroutine ialah benang ringan yang boleh menjalankan berbilang coroutine secara serentak dalam satu thread. Coroutines boleh melaksanakan pengaturcaraan tak segerak dan mengelakkan overhed penukaran benang dalam pengaturcaraan berbilang benang tradisional. Swoole menyediakan sokongan untuk coroutine, yang boleh digunakan untuk melaksanakan pengaturcaraan rangkaian serentak tinggi.

3. Langkah-langkah untuk melaksanakan sistem penerbitan dan langganan dengan Swoole

Seterusnya, kami akan memperkenalkan cara menggunakan Swoole untuk melaksanakan sistem penerbitan dan langganan. Untuk mengurangkan kerumitan kod, kami akan menggunakan pengundian aktif oleh pelanggan untuk melaksanakan fungsi langganan.

1. Buat broker mesej

Mula-mula kita perlu mencipta broker mesej, yang bertanggungjawab untuk menerima mesej dan menghalakannya kepada pelanggan yang sepadan. Kami boleh menggunakan pelayan TCP dan fungsi pengurusan proses yang disediakan oleh Swoole untuk melaksanakan broker mesej.

$server = new SwooleServer('0.0.0.0', 8080, SWOOLE_PROCESS);
$server->set([
    'worker_num' => 2,
    'daemonize' => false,
]);
$server->on('WorkerStart', function($serv, $worker_id) {
    // 创建消息队列
    $queue_key = ftok(__FILE__, 'a');
    $queue = msg_get_queue($queue_key, 0666 | IPC_CREAT);
    // 将消息队列作为全局变量存放起来
    global $message_queue;
    $message_queue = $queue;
    // 启动消息处理进程
    if ($worker_id == 0) {
        $process = new SwooleProcess(function($process) {
            global $message_queue;
            while (true) {
                // 从消息队列中获取消息
                if (msg_receive($message_queue, 0, $msg_type, 1024, $msg, true, MSG_IPC_NOWAIT)) {
                    // 将消息发送给对应的订阅者
                    // TODO:实现发送消息的逻辑
                }
                // 隔一段时间循环一次
                usleep(100);
            }
        }, false, false);
        $process->start();
    }
});
$server->on('Connect', function($serv, $fd) {
    echo "Client[$fd]: Connect.
";
});
$server->on('Receive', function($serv, $fd, $from_id, $data) {
    global $message_queue;
    // 接收到消息，将消息存放到消息队列
    if (msg_send($message_queue, 1, $data, true, true)) {
        echo "Received message: $data
";
    } else {
        echo "Failed to send message to message queue.
";
    }
});
$server->on('Close', function($serv, $fd) {
    echo "Client[$fd]: Close.
";
});
$server->start();

Dalam kod di atas, kami mencipta pelayan TCP dan menyediakan 2 proses anak. Apabila setiap proses kanak-kanak bermula, kami mencipta baris gilir mesej dan menyimpannya dalam pembolehubah global $message_queue. Dalam sub-proses pertama, kami mencipta proses pemprosesan mesej, yang akan mendapatkan mesej daripada baris gilir mesej dan menghantar mesej kepada pelanggan yang sepadan. Apabila menerima mesej, kami menyimpan mesej dalam baris gilir mesej melalui fungsi msg_send.

2. Laksanakan fungsi langganan

Fungsi langganan bermakna pelanggan boleh memilih topik yang perlu mereka langgan mengikut minat mereka sendiri, dengan itu menerima mesej yang berkaitan. Kami boleh melaksanakan fungsi langganan melalui coroutine Swoole.

$client = new SwooleClient(SWOOLE_SOCK_TCP);
if (!$client->connect('127.0.0.1', 8080)) {
    echo "Failed to connect to server.
";
    exit(1);
}
// 订阅主题
if (!$client->send("subscribe:topic1")) {
    echo "Failed to send subscribe message.
";
    exit(1);
}
// 接收消息
while (true) {
    $data = $client->recv();
    if ($data === false) {
        echo "Failed to receive message.
";
        break;
    }
    if (empty($data)) {
        continue;
    }
    echo "Received message: $data
";
}
$client->close();

Dalam kod di atas, kami mencipta klien TCP dan menyambung ke port broker mesej. Mesej langganan dihantar melalui fungsi hantar, dan topik langganan ialah topik1. Apabila menerima mesej, kami menggunakan gelung untuk menyemak sama ada terdapat mesej baharu dan menggunakan fungsi recv untuk menyekat dan menunggu mesej baharu.

3. Laksanakan fungsi penerbitan

Fungsi penerbitan bermaksud penerbit boleh menerbitkan mesej kepada topik yang ditentukan. Kami boleh menggunakan klien TCP Swoole untuk melaksanakan fungsi penerbitan.

$client = new SwooleClient(SWOOLE_SOCK_TCP);
if (!$client->connect('127.0.0.1', 8080)) {
    echo "Failed to connect to server.
";
    exit(1);
}
// 发布消息
if (!$client->send("publish:topic1:message1")) {
    echo "Failed to send publish message.
";
    exit(1);
}
$client->close();

Dalam kod di atas, kami mencipta klien TCP dan menyambung ke port broker mesej. Terbitkan mesej melalui fungsi hantar Topik penerbitan ialah topik1 dan kandungan mesej ialah mesej1.

4. Ringkasan

Swoole ialah rangka kerja pengaturcaraan rangkaian yang berkuasa yang boleh membantu kami melaksanakan aplikasi rangkaian berprestasi tinggi dan berkonkurensi tinggi. Artikel ini memperkenalkan cara menggunakan Swoole untuk melaksanakan sistem penerbitan dan langganan yang sangat dipercayai, yang terutamanya termasuk mencipta ejen mesej, melaksanakan fungsi langganan dan fungsi penerbitan. Menggunakan Swoole untuk melaksanakan sistem terbitkan dan langgan boleh meningkatkan prestasi dan kebolehpercayaan sistem dan sesuai untuk pelbagai senario aplikasi yang memerlukan fungsi pemesejan.

Atas ialah kandungan terperinci Swoole melaksanakan sistem penerbitan dan langganan yang sangat boleh dipercayai. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!