国产av日韩一区二区三区精品,成人性爱视频在线观看,国产,欧美,日韩,一区,www.成色av久久成人,2222eeee成人天堂

首頁(yè) PHP 函式庫(kù) 其它類(lèi)別庫(kù) php-rdkafka客戶端程式庫(kù)
php-rdkafka客戶端程式庫(kù)

這是一個(gè)可以發(fā)送和接受訊息的客戶端,下面給大家示範(fàn)一下發(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();
}


#
免責(zé)聲明

本站所有資源皆由網(wǎng)友貢獻(xiàn)或各大下載網(wǎng)站轉(zhuǎn)載。請(qǐng)自行檢查軟體的完整性!本站所有資源僅供學(xué)習(xí)參考。請(qǐng)不要將它們用於商業(yè)目的。否則,一切後果都由您負(fù)責(zé)!如有侵權(quán),請(qǐng)聯(lián)絡(luò)我們刪除。聯(lián)絡(luò)方式:admin@php.cn

相關(guān)文章

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

27 Nov 2024

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

客戶端與伺服器端程式設(shè)計(jì):JavaScript 和 PHP 如何互動(dòng)? 客戶端與伺服器端程式設(shè)計(jì):JavaScript 和 PHP 如何互動(dòng)?

05 Jan 2025

了解客戶端和伺服器端程式設(shè)計(jì)之間的差異提供的程式碼說(shuō)明了客戶端和...

如何修復(fù)'MySQL 客戶端庫(kù)版本不正確!” Rails 應(yīng)用程式出錯(cuò)? 如何修復(fù)'MySQL 客戶端庫(kù)版本不正確!” Rails 應(yīng)用程式出錯(cuò)?

02 Dec 2024

Rails 應(yīng)用程式 MySQL 連線錯(cuò)誤嘗試透過(guò) Rails 應(yīng)用程式連接到 MySQL 伺服器時(shí),可能會(huì)發(fā)生錯(cuò)誤:不正確...

客戶端與伺服器端程式設(shè)計(jì):有什麼區(qū)別? 客戶端與伺服器端程式設(shè)計(jì):有什麼區(qū)別?

29 Dec 2024

客戶端與伺服器端程式設(shè)計(jì):詳細(xì)探索程式設(shè)計(jì)領(lǐng)域包含兩種不同的範(fàn)例:客戶端...

取得客戶端使用作業(yè)系統(tǒng)類(lèi)型的php程式碼 取得客戶端使用作業(yè)系統(tǒng)類(lèi)型的php程式碼

25 Jul 2016

取得客戶端使用作業(yè)系統(tǒng)類(lèi)型的php程式碼

Rails 中的 MySQL 用戶端程式庫(kù)版本不符:如何修復(fù)'MySQL 用戶端程式庫(kù)版本不正確!”錯(cuò)誤? Rails 中的 MySQL 用戶端程式庫(kù)版本不符:如何修復(fù)'MySQL 用戶端程式庫(kù)版本不正確!”錯(cuò)誤?

01 Dec 2024

Rails 應(yīng)用程式中的錯(cuò)誤:MySQL 用戶端程式庫(kù)版本不符合嘗試與 Rails 應(yīng)用程式建立資料庫(kù)連線時(shí),...

See all articles