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
Tipps zum Generieren farbenfroher Verifizierungscodebilder mit PHP und der GD-Bibliothek14Jul2023
Tipps zum Generieren farbenfroher Verifizierungscode-Bilder mit PHP- und GD-Bibliotheken Einführung: Verifizierungscode ist eine gängige Netzwerksicherheitstechnologie. Indem Benutzer beim Anmelden, Registrieren oder Absenden eines Formulars zur Eingabe eines Bestätigungscodes aufgefordert werden, können Sie automatisierte Angriffe durch Roboter und Schadprogramme effektiv verhindern. In diesem Artikel werden die Techniken zur Verwendung von PHP- und GD-Bibliotheken zum Generieren farbenfroher Verifizierungscodebilder vorgestellt, um Entwicklern dabei zu helfen, beim Erstellen von Verifizierungscodes ein gewisses Maß an Erkennbarkeit und Kunstfertigkeit zu verleihen. 1. Vorbereitung der Umgebung Bevor Sie beginnen, stellen Sie sicher, dass PHP- und GD-Bibliotheken in Ihrer Entwicklungsumgebung installiert sind. Kann
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