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...

Bagaimana untuk mencipta perpustakaan fungsi PHP dan mengintegrasikannya ke dalam projek PHP yang lain?

26 Apr 2024

Langkah-langkah untuk mencipta pustaka fungsi PHP adalah seperti berikut: 1. Cipta fail perpustakaan fungsi dan tulis fungsi 2. Integrasikan pustaka fungsi ke dalam projek lain melalui require_once() atau spl_autoload_register(). Contohnya, perpustakaan fungsi yang mengira jumlah harga pesanan dibuat dan disepadukan serta digunakan dalam skrip lain.

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