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(); }
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

17 Feb 2025
WordPress sangat bergantung pada JavaScript pihak ketiga dan perpustakaan PHP, di antaranya jQuery adalah perpustakaan JavaScript yang paling banyak digunakan, dan perpustakaan PHP terutamanya terdiri daripada satu fail kelas. Perpustakaan JavaScript lain yang digunakan termasuk jQuery Masonry, Jquery Hotkeys, Jquery Cadangan, Borang JQuery, Warna JQuery, JQuery Migrate, Jquery Jadual, JQuery UI, Backbone, Colorpicker, Hoverintent, S

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

25 Dec 2024
Permata MySQL2: Menyelesaikan Masalah Ralat Penyusunan dengan Perpustakaan Pelanggan MySQLRalat "Versi perpustakaan klien MySQL salah" berlaku apabila...

25 Oct 2024
Perpustakaan Pelanggan SOAP Python Pelbagai: Menavigasi Labyrinth DokumentasiUntuk pembangun Python pemula yang meneroka SOAP dan perpustakaan kliennya,...

01 Dec 2024
Ralat dalam Aplikasi Rails: Versi Perpustakaan Pelanggan MySQL MismatchApabila cuba mewujudkan sambungan pangkalan data dengan aplikasi Rails,...

18 Apr 2025
Apabila membangunkan projek yang memerlukan interaksi yang kerap dengan Restapi luaran, saya menghadapi masalah yang sukar: setiap permintaan memerlukan secara manual membina permintaan HTTP, mengendalikan pengesahan, maklumat header, parameter, dan lain-lain, yang besar dan rawan kesilapan. Selepas mencuba pelbagai kaedah, saya dapati perpustakaan Ogillot/PHP-Restclient, yang sangat memudahkan kerja saya dan meningkatkan kecekapan pembangunan.


Alat panas

Pustaka PHP untuk bekas suntikan kebergantungan
Pustaka PHP untuk bekas suntikan kebergantungan

Koleksi 50 algoritma PHP klasik yang sangat baik
Algoritma PHP klasik, pelajari idea yang sangat baik dan kembangkan pemikiran anda

Pustaka PHP kecil untuk mengoptimumkan imej
Pustaka PHP kecil untuk mengoptimumkan imej
