Rumah

Perpustakaan PHP

Perpustakaan lain

perpustakaan pelanggan php-rdkafka

Perpustakaan lain

Dapatkannya sekarang

perpustakaan pelanggan php-rdkafka

Ini adalah pelanggan yang boleh menghantar dan menerima mesej Di bawah saya akan menunjukkan operasi penghantaran dan penerimaan Rakan yang memerlukannya boleh memuat turunnya dan mencubanya.

Hantar mesej

<?phptry {
    $rcf = new RdKafka\Conf();
    $rcf->set('group.id', 'test');
    $cf = new RdKafka\TopicConf();
    $cf->set('offset.store.method', 'broker');
    $cf->set('auto.offset.reset', 'smallest');
    $rk = new RdKafka\Producer($rcf);
    $rk->setLogLevel(LOG_DEBUG);
    $rk->addBrokers("127.0.0.1");
    $topic = $rk->newTopic("test", $cf);
    for($i = 0; $i < 1000; $i++) {
        $topic->produce(0,0,'test' . $i);//没有setMessge接口了,使用produce  参考：https://libraries.io/github/mentionapp/php-rdkafka
    } 
} catch (Exception $e) {
    echo $e->getMessage();

Terima mesej

<?phptry {
    $rcf = new RdKafka\Conf();
    $rcf->set('group.id', 'test');
    $cf = new RdKafka\TopicConf();/*
    $cf->set('offset.store.method', 'file');
*/
    $cf->set('auto.offset.reset', 'smallest');
    $cf->set('auto.commit.enable', true);
    $rk = new RdKafka\Consumer($rcf);
    $rk->setLogLevel(LOG_DEBUG);
    $rk->addBrokers("127.0.0.1");
    $topic = $rk->newTopic("test", $cf);    //$topic->consumeStart(0, RD_KAFKA_OFFSET_BEGINNING);
    while (true) {
        $topic->consumeStart(0, RD_KAFKA_OFFSET_STORED);
        $msg = $topic->consume(0, 1000);
        var_dump($msg);        if ($msg->err) {            echo $msg->errstr(), "\n";            break;
        } else {            echo $msg->payload, "\n";
        }
        $topic->consumeStop(0);
        sleep(1);
    }
} catch (Exception $e) {    echo $e->getMessage();
}

Penafian

Semua sumber di laman web ini disumbangkan oleh netizen atau dicetak semula oleh tapak muat turun utama. Sila semak integriti perisian itu sendiri! Semua sumber di laman web ini adalah untuk rujukan pembelajaran sahaja. Tolong jangan gunakannya untuk tujuan komersial. Jika tidak, anda akan bertanggungjawab untuk semua akibat! Jika terdapat sebarang pelanggaran, sila hubungi kami untuk memadamkannya. Maklumat hubungan: admin@php.cn

Artikel Berkaitan

Bagaimana untuk menulis perpustakaan fungsi PHP?

17 Apr 2024

Langkah-langkah untuk menulis perpustakaan fungsi dalam PHP adalah seperti berikut: Cipta fail PHP (seperti myFunctions.php) untuk menyimpan fungsi. Gunakan kata kunci fungsi untuk menentukan fungsi dalam fail. Sertakan perpustakaan dalam skrip lain menggunakan penyataan require_once atau include_once. Setelah perpustakaan fungsi disertakan, fungsinya boleh digunakan.

Tutorial Pengaturcaraan PHP: Cara Menggunakan Perpustakaan Pihak Ketiga

26 Aug 2023

Tutorial pengaturcaraan PHP: Cara menggunakan perpustakaan pihak ketiga Pengenalan: Dalam pembangunan program PHP, kadangkala perlu menggunakan perpustakaan pihak ketiga untuk menyediakan fungsi dan alatan tambahan. Perpustakaan ini boleh mengurangkan jumlah kod dan meningkatkan kecekapan pembangunan. Tutorial ini menerangkan cara menggunakan perpustakaan pihak ketiga dan menyediakan contoh kod. Fahami Jenis-Jenis Perpustakaan Pihak Ketiga Perpustakaan pihak ketiga ialah koleksi kod yang ditulis dan diselenggara oleh pembangun lain. Perpustakaan pihak ketiga yang biasa termasuk perpustakaan operasi pangkalan data, perpustakaan pemprosesan imej, perpustakaan pengesahan borang, dsb. Pustaka ini tersedia melalui Composer, alat pengurusan pakej untuk PHP

Perpustakaan sambungan dalam PHP

25 May 2023

Sebagai bahasa pembangunan web yang popular, PHP mempunyai pelbagai kumpulan pengguna dan perpustakaan sambungan yang kaya. Pustaka sambungan merujuk kepada beberapa fail perpustakaan dengan modul fungsi khusus yang disediakan oleh pihak ketiga, yang boleh dimuatkan ke dalam PHP melalui pautan dinamik dan boleh berinteraksi dengan kernel PHP. Perpustakaan sambungan ini sangat meluaskan skop fungsi PHP dan memenuhi banyak keperluan khas. Pustaka sambungan PHP digunakan secara meluas, termasuk sambungan pangkalan data, pemprosesan imej, pemampatan dan penyahmampatan, penyulitan dan penyahsulitan, pengesahan identiti dan banyak bidang lain, yang sangat meningkatkan prestasi PHP.

## Apakah Perpustakaan Pelanggan Python SOAP Terbaik untuk Digunakan pada tahun 2023?

25 Oct 2024

Perpustakaan Pelanggan Python SOAP: Dokumentasi dan PilihanMelayari dunia perpustakaan klien SOAP Python boleh menjadi menakutkan bagi pemula. Sementara...

Tetapan PHP menyokong perpustakaan dinamik

28 May 2023

PHP ialah bahasa pembangunan web yang berkuasa yang boleh menyediakan pelbagai fungsi dan ciri yang berbeza untuk tapak web. PHP boleh meningkatkan fungsinya melalui perpustakaan pautan dinamik, tetapi secara lalai, PHP mungkin tidak menyokong perpustakaan pautan dinamik. Artikel ini akan memperkenalkan cara menyediakan PHP untuk menyokong perpustakaan pautan dinamik untuk meningkatkan kefungsian PHP. PHP ialah bahasa skrip sebelah pelayan yang boleh digunakan untuk membangunkan laman web dan aplikasi web. Tidak seperti bahasa pengaturcaraan lain, PHP menjana halaman web secara dinamik dengan menulis kod sebelah pelayan. PHP menyokong pelbagai pangkalan data dan teknologi pelayan, termasuk MySQL,

Bolehkah fungsi PHP disepadukan dengan perpustakaan luaran? Bagaimana untuk mencapai

16 Apr 2024

Fungsi PHP boleh disepadukan dengan perpustakaan luaran untuk melanjutkan fungsi. Kaedah khusus termasuk: menggunakan fungsi include() atau require() untuk memuatkan fail PHP sebagai perpustakaan. Gunakan Komposer untuk mengurus dan memuatkan perpustakaan. Gunakan kaedah lain seperti piawaian autoloading PSR-4 atau memuatkan fail kelas secara manual.

See all articles