Dies ist ein Client, der Nachrichten senden und empfangen kann. Nachfolgend werde ich die Sende- und Empfangsvorg?nge demonstrieren. Freunde, die ihn ben?tigen, k?nnen ihn herunterladen und ausprobieren.
Nachricht senden
<?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();
Nachricht empfangen
<?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(); }
Alle Ressourcen auf dieser Website werden von Internetnutzern bereitgestellt oder von gro?en Download-Sites nachgedruckt. Bitte überprüfen Sie selbst die Integrit?t der Software! Alle Ressourcen auf dieser Website dienen nur als Referenz zum Lernen. Bitte nutzen Sie diese nicht für kommerzielle Zwecke. Andernfalls sind Sie für alle Folgen verantwortlich! Wenn ein Versto? vorliegt, kontaktieren Sie uns bitte, um ihn zu l?schen. Kontaktinformationen: admin@php.cn
Verwandter Artikel

30 Sep 2016
Auf der Suche nach einem PHP/Python-Bibliotheksverwaltungsprogramm (?hnlich der Baidu-Bibliothek, die doc/pdf und andere Bibliotheken verwaltet) ~~ Es muss haupts?chlich über Suchfunktionen verfügen, insbesondere Funktionen zum Abrufen der Dateiklassifizierung/Datei-Tags, keine Online-Konvertierung erforderlich, online St?bern!

09 Nov 2024
Unterscheidung zwischen ?Memcache“ und ?Memcached“ in PHPPHP bietet zwei Memcached-Bibliotheken: Memcache und Memcached. Das Verst?ndnis ihrer Unterschiede hilft...

19 Nov 2024
Memcache vs. Memcached: Auswahl der richtigen PHP-Memcached-BibliothekEinführungPHP bietet zwei scheinbar ?hnliche Memcached-Bibliotheken: Memcache und...

12 Nov 2024
Memcache vs. Memcached: Auswahl der richtigen PHP-Bibliothek für Ihre Cache-AnforderungenIm Bereich der PHP-Caching-Bibliotheken stechen Memcache und Memcached hervor ...

18 Nov 2024
PHP-Bibliotheken zur E-Mail-Adressvalidierung aufgedecktE-Mail-Adressvalidierung spielt eine entscheidende Rolle bei der Datenvalidierung, aber die Erstellung einer...

05 Jan 2025
Empfehlungen zur PHP-ORM-BibliothekWenn es um objektrelationales Mapping (ORM) für PHP geht, stechen mehrere Bibliotheken hervor. Zur Adressierung...


Hei?e Werkzeuge

PHP-Bibliothek für Abh?ngigkeitsinjektionscontainer
PHP-Bibliothek für Abh?ngigkeitsinjektionscontainer

Eine Sammlung von 50 hervorragenden klassischen PHP-Algorithmen
Klassischer PHP-Algorithmus, lernen Sie hervorragende Ideen und erweitern Sie Ihr Denken

Kleine PHP-Bibliothek zur Optimierung von Bildern
Kleine PHP-Bibliothek zur Optimierung von Bildern
