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
30Sep2016
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!
Integration der PHP-Funktionsbibliothek und der Bibliothek von Drittanbietern22Apr2024
Funktionsbibliotheken und Bibliotheken von Drittanbietern in PHP können die Funktionalität von Anwendungen erweitern. Die Funktionsbibliothek stellt vordefinierte Funktionen bereit, die über die Include-Anweisung eingebunden werden können. Bibliotheken von Drittanbietern sind aus Quellen wie Packagist und GitHub verfügbar und können mit Composer installiert werden. Implementieren Sie das automatische Laden von Klassen über einen Autoloader, z. B. das automatische Laden der Guzzle-Bibliothek. Erfahren Sie anhand praktischer Beispiele, wie Sie die Dompdf-Drittanbieterbibliothek zum Generieren von PDF-Dateien verwenden, einschließlich des Ladens der Bibliothek, des Ladens von HTML-Inhalten und der Ausgabe von PDF-Dateien. Die Integration von Funktionsbibliotheken und Bibliotheken von Drittanbietern erweitert die Funktionalität von PHP-Anwendungen erheblich und verbessert die Entwicklungseffizienz und Projektleistung.
Memcache vs. Memcached: Welche PHP-Bibliothek sollten Sie wählen?09Nov2024
Unterscheidung zwischen „Memcache“ und „Memcached“ in PHPPHP bietet zwei Memcached-Bibliotheken: Memcache und Memcached. Das Verständnis ihrer Unterschiede hilft...
PHP- und OpenCV-Bibliothek: Wie kann ich Bildunschärfe wiederherstellen?18Jul2023
PHP- und OpenCV-Bibliotheken: Wie kann ich Bildunschärfe wiederherstellen? Einleitung: Im Bereich der Bildverarbeitung ist Bildunschärfe ein häufiges Problem. Wenn wir mit einer Kamera aufgenommene Bilder verarbeiten, kann es manchmal zu unscharfen Bildern kommen, beispielsweise aufgrund von Handschütteln oder schnellen Bewegungen. In diesem Artikel wird erläutert, wie Sie mithilfe von PHP- und OpenCV-Bibliotheken unscharfe Bilder wiederherstellen. Installieren Sie die OpenCV-Bibliothek. Zuerst müssen wir die OpenCV-Bibliothek in der PHP-Umgebung installieren. OpenCV (OpenSource
Memcache vs. Memcached: Welche PHP-Memcached-Bibliothek sollten Sie wählen?19Nov2024
Memcache vs. Memcached: Auswahl der richtigen PHP-Memcached-BibliothekEinführungPHP bietet zwei scheinbar ähnliche Memcached-Bibliotheken: Memcache und...
Hot Tools
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