Ketahui cara menggunakan PHP dan Kafka untuk pemesejan

PHP ialah bahasa pengaturcaraan popular yang biasa digunakan untuk pembangunan bahagian pelayan dan pembangunan aplikasi web. Kafka ialah sistem pemesejan teragih yang boleh digunakan untuk mengurus pemesejan berskala besar. Artikel ini akan memperkenalkan cara menggunakan PHP dan Kafka untuk pemesejan.

Pertama, kita perlu memasang beberapa alatan dan perpustakaan yang diperlukan. Di Linux, kami boleh menggunakan arahan berikut:

sudo apt-get install php-zmq librdkafka-dev

Jika anda menggunakan sistem Windows, anda perlu memuat turun dan memasang alatan dan perpustakaan yang berkaitan secara manual.

Seterusnya, kita perlu memasang sambungan ZeroMQ untuk PHP. Di Linux, anda boleh menggunakan arahan berikut:

sudo pecl install zmq-beta

Jika anda menggunakan sistem Windows, anda perlu memuat turun dan memasang sambungan ZeroMQ untuk PHP secara manual.

Setelah kami menyelesaikan persediaan ini, kami boleh mula menggunakan PHP dan Kafka untuk pemesejan. Berikut ialah contoh mudah:

<?php

$conf = new RdKafkaConf();
$conf->set('metadata.broker.list', 'localhost:9092');

$producer = new RdKafkaProducer($conf);

$topic = $producer->newTopic("test");

for ($i = 0; $i < 10; $i++) {
    $message = "Message " . $i;
    $topic->produce(RD_KAFKA_PARTITION_UA, 0, $message);
}

$producer->flush(10000);

$consumerConf = new RdKafkaConf();
$consumerConf->set('metadata.broker.list', 'localhost:9092');
$consumerConf->set('group.id', 'testgroup');

$consumer = new RdKafkaKafkaConsumer($consumerConf);
$consumer->subscribe(['test']);

while (true) {
    $message = $consumer->consume(120 * 1000);

    switch ($message->err) {
        case RD_KAFKA_RESP_ERR_NO_ERROR:
            echo "Received message: " . $message->payload . "
";
            break;
        case RD_KAFKA_RESP_ERR__PARTITION_EOF:
            echo "End of partition
";
            break;
        case RD_KAFKA_RESP_ERR__TIMED_OUT:
            echo "Timed out
";
            break;
        default:
            echo "Error: " . $message->errstr() . "
";
            break;
    }

    $consumer->commit();
}

Dalam contoh ini, kami mula-mula mencipta pengeluar dan menghantar 10 mesej kepada topik bernama "ujian". Kemudian, kami mencipta pengguna dan melanggan topik "ujian". Akhir sekali, kami memasuki gelung tak terhingga di mana kami menerima mesej yang digunakan daripada topik Kafka.

Apabila kami menjalankan contoh ini, ia akan terus menerima mesej yang dihantar daripada topik Kafka dan mengeluarkannya pada konsol. Jika anda ingin keluar dari gelung, hentikan program dengan kombinasi kekunci Ctrl + C.

Dalam contoh mudah ini, kami menunjukkan cara menggunakan PHP dan Kafka untuk pemesejan. Mempelajari pendekatan ini akan membantu anda mengurus pemesejan dan pemprosesan berskala besar dengan lebih baik serta menjadikan aplikasi anda lebih mantap dan boleh dipercayai.

Atas ialah kandungan terperinci Ketahui cara menggunakan PHP dan Kafka untuk pemesejan. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!