這是一個可以發送和接受訊息的客戶端，下面給大家示範一下發送和接受的操作，需要的朋友可以自行下載後嘗試一下。
發送訊息
<?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();接收訊息
<?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();
}本站所有資源皆由網友貢獻或各大下載網站轉載。請自行檢查軟體的完整性！本站所有資源僅供學習參考。請不要將它們用於商業目的。否則，一切後果都由您負責！如有侵權，請聯絡我們刪除。聯絡方式：admin@php.cn
相關文章
為什麼我的Go程式無法正確使用HTTP客戶端庫？10Jun2023
Go語言是近年來非常流行的程式語言，它被廣泛應用於Web開發、系統程式設計、雲端運算等領域。在Go語言中使用HTTP協定進行網路通訊是非常常見的場景，而為了方便地編寫HTTP客戶端程序，Go語言提供了標準庫中自帶的net/http套件及其相關子套件。不過，有時候我們在使用HTTP客戶端庫時卻會遇到一些問題，例如程式無法正確取得到網路服務端回傳的數據，或是客戶端程式
如何將自訂 go http 用戶端與從 openapi 規範產生的客戶端 go 程式碼結合使用06Feb2024
我正在努力根據開放api格式的api規範生成http客戶端庫。我用來產生它的指令與此類似openapi-generator產生-ggo-ispec.yaml-ocode-gen-go-ppackagename=mypackage這會在產生的程式碼中建立一個類似於下面的結構typeConfigurationstruct{Hoststring`json: "host,omitempty"`Scheme
取得客戶端ip、地理資訊、瀏覽器、真實IP的php類別庫23Apr2018
這篇文章主要介紹了取得客戶端ip、地理資訊、瀏覽器、真實IP的php類別庫，有著一定的參考價值，現在分享給大家，有需要的朋友可以參考一下
PHP8.0中的HTTP客戶端程式庫14May2023
PHP8.0中的HTTP客戶端庫PHP8.0的發布帶來了許多新特性和改進，其中一個最引人注目的是內建的HTTP客戶端庫的加入。這個函式庫提供了一個簡單的方法來傳送HTTP請求並處理傳回的回應。在本文中，我們將探討這個函式庫的主要功能和用法。發送HTTP請求使用PHP8.0內建的HTTP客戶端庫發送HTTP請求非常簡單。在本例中，我們將使用GET方法來取得這個網站的首頁
PHP8.0中的API客戶端函式庫：Guzzle14May2023
隨著網路技術的發展，Web應用程式和API應用程式越來越普遍。為了存取這些應用程序，需要使用API客戶端庫。在PHP中，Guzzle是一個廣受歡迎的API客戶端程式庫，它提供了許多功能，使得在PHP中存取Web服務和API變得更加容易。 Guzzle庫的主要目標是提供一個簡單而強大的HTTP客戶端，它可以處理任何形式的HTTP請求和回應，並且支援並發請求處理。在
Hot tools Tags
Hot Tools
