這是一個(gè)可以發(fā)送和接受消息的客戶端，下面給大家演示一下發(fā)送和接受的操作，需要的朋友可以自行下載后嘗試一下。

發(fā)送消息

<?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);//沒(méi)有setMessge接口了,使用produce  參考：https://libraries.io/github/mentionapp/php-rdkafka
    } 
} catch (Exception $e) {
    echo $e->getMessage();

接收消息

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

相關(guān)文章

oracle數(shù)據(jù)庫(kù)安裝客戶端工具有哪些

04 Mar 2025

本文探討了Oracle數(shù)據(jù)庫(kù)客戶端工具，這對(duì)于與Oracle數(shù)據(jù)庫(kù)進(jìn)行交互至關(guān)重要，而無(wú)需完整的服務(wù)器安裝。 它詳細(xì)介紹了常用的工具，例如SQL*Plus，SQL開(kāi)發(fā)人員，Enterprise Manager和RMAN，突出了他們的樂(lè)趣

使用命令行客戶端連接到MySQL數(shù)據(jù)庫(kù)

07 Jul 2025

連接MySQL數(shù)據(jù)庫(kù)最直接的方式是使用命令行客戶端。首先輸入mysql-u用戶名-p并正確輸入密碼即可進(jìn)入交互式界面；若連接遠(yuǎn)程數(shù)據(jù)庫(kù)，需添加-h參數(shù)指定主機(jī)地址。其次，可直接在登錄時(shí)切換到特定數(shù)據(jù)庫(kù)或執(zhí)行SQL文件，如mysql-u用戶名-p數(shù)據(jù)庫(kù)名或mysql-u用戶名-p數(shù)據(jù)庫(kù)名

如何使用Go客戶端庫(kù)監(jiān)控Kubernetes服務(wù)變化？

27 Nov 2024

使用 Go 客戶端庫(kù)監(jiān)控 Kubernetes 服務(wù)更改Kubernetes 服務(wù)對(duì)于公開(kāi)應(yīng)用程序和管理流量至關(guān)重要。它是...

如何將HTML5 IndexEdDB API用于高級(jí)客戶端數(shù)據(jù)庫(kù)存儲(chǔ)？

12 Mar 2025

本文解釋了用于客戶端數(shù)據(jù)庫(kù)存儲(chǔ)的HTML5索引DB API。 它詳細(xì)說(shuō)明了關(guān)鍵組件，例如IDBDATABASE，IDBTRANSACTION和IDBOBJECTSTORE，說(shuō)明了它們與代碼示例的使用。 本文還涵蓋了優(yōu)化策略

**哪個(gè) Python SOAP 客戶端庫(kù)適合您？瀏覽不同的選項(xiàng)及其文檔。**

25 Oct 2024

多樣化的 Python SOAP 客戶端庫(kù)：瀏覽文檔迷宮對(duì)于探索 SOAP 及其客戶端庫(kù)的 Python 新手開(kāi)發(fā)人員來(lái)說(shuō)，...

H5 IndexEdDB用于大規(guī)?？蛻舳藬?shù)據(jù)庫(kù)

30 Jul 2025

IndexedDB是瀏覽器端處理大規(guī)模數(shù)據(jù)存儲(chǔ)的合適方案，適合H5的原因包括支持結(jié)構(gòu)化數(shù)據(jù)、異步操作、事務(wù)機(jī)制和索引查詢。1.它能存儲(chǔ)大量結(jié)構(gòu)化數(shù)據(jù)及二進(jìn)制對(duì)象；2.支持高性能查找和檢索；3.采用對(duì)象存儲(chǔ)方式更貼近JavaScript習(xí)慣。使用流程為：打開(kāi)數(shù)據(jù)庫(kù)、創(chuàng)建對(duì)象倉(cāng)庫(kù)、開(kāi)啟事務(wù)讀寫數(shù)據(jù)、使用索引來(lái)優(yōu)化查詢。常見(jiàn)問(wèn)題解決建議包括：1.使用Dexie.js或封裝Promise避免回調(diào)地獄；2.合理使用事務(wù)范圍、批量插入提升性能；3.現(xiàn)代主流瀏覽器均良好兼容。使用中需注意版本升級(jí)邏輯及錯(cuò)誤事件

See all articles