摘要:最近項(xiàng)目開(kāi)發(fā)中需要使用消息隊(duì)列。不過(guò)在環(huán)境中安裝的過(guò)程中出現(xiàn)了以下報(bào)錯(cuò)開(kāi)始以為是因?yàn)榘惭b缺少了一些依賴。然后使用了源碼編譯的方式進(jìn)行安裝同樣報(bào)錯(cuò)了。然后安裝它再執(zhí)行,執(zhí)行。擴(kuò)展包使用純粹的編寫的客戶端,目前支持以上版本的。
最近項(xiàng)目開(kāi)發(fā)中需要使用 Kafka 消息隊(duì)列。經(jīng)過(guò)檢索,PHP下面有通用的兩種方式來(lái)調(diào)用 Kafka 。
php-rdkafka 擴(kuò)展以 PHP 擴(kuò)展的形式進(jìn)行使用是非常高效的。另外,該項(xiàng)目也提供了非常完備的 文檔 。
不過(guò)在 Mac 環(huán)境中安裝的過(guò)程中出現(xiàn)了以下報(bào)錯(cuò):
$ sudo pecl install rdkafka checking for re2c... no configure: WARNING: You will need re2c 0.13.4 or later if you want to regenerate PHP parsers. checking for gawk... no checking for nawk... no checking for awk... awk checking if awk is broken... no checking for rdkafka support... yes, shared checking for librdkafka/rdkafka.h" in default path... not found configure: error: Please reinstall the rdkafka distribution
開(kāi)始以為是因?yàn)?pecl 安裝缺少了一些依賴。然后使用了源碼編譯的方式進(jìn)行安裝:
$ git clone https://github.com/arnaud-lb/php-rdkafka.git $ cd php-rdkafka $ phpize $ ./configure $ make all -j 5 .... checking for re2c... no configure: WARNING: You will need re2c 0.13.4 or later if you want to regenerate PHP parsers. checking for gawk... no checking for nawk... no checking for awk... awk checking if awk is broken... no checking for rdkafka support... yes, shared checking for librdkafka/rdkafka.h" in default path... not found configure: error: Please reinstall the rdkafka distribution
同樣報(bào)錯(cuò)了。后來(lái)仔細(xì)看文檔才發(fā)現(xiàn)。這里有一個(gè)依賴:librdkafka 。
然后安裝它:
$ git clone https://github.com/edenhill/librdkafka.git $ cd librdkafka $ ./configure $ make && make install
再執(zhí)行 sudo pecl install rdkafka ,執(zhí)行OK。
然后將 rdkafka.so 添加到相應(yīng)的 /path/to/php.ini 的末尾即可。
執(zhí)行 php -m | grep rdkafka ,驗(yàn)證是否添加完成。
kafka-php 擴(kuò)展包Kafka-php 使用純粹的 PHP 編寫的 Kafka 客戶端,目前支持 0.8.x 以上版本的 Kafka。由于使用 PHP 語(yǔ)言編寫所以不用編譯任何的擴(kuò)展就可以使用,降低了接入與維護(hù)成本。
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://m.specialneedsforspecialkids.com/yun/29408.html
摘要:本文主要實(shí)現(xiàn)的目標(biāo)是連接并且成功發(fā)送消息給。發(fā)送消息網(wǎng)上找了一圈,終于找到一個(gè)可以用的也可以用代碼如下發(fā)送消息到不同的參考文章最后附一張截圖 本文主要實(shí)現(xiàn)的目標(biāo)是php連接kafka并且成功發(fā)送消息給kafka。為了驗(yàn)證這個(gè)連接和發(fā)送,另外配置了logstash監(jiān)聽(tīng)kafka相對(duì)應(yīng)的消息,然后轉(zhuǎn)發(fā)到redis,原來(lái)我不知道對(duì)kafka比較陌生,不知道怎么看里面的消息內(nèi)容(我知道安裝包里...
摘要:消息以為類別記錄將消息種子分類每一類的消息稱之為一個(gè)主題。這意味著生產(chǎn)者不等待來(lái)自同步完成的確認(rèn)繼續(xù)發(fā)送下一條批消息。這意味著在已成功收到的數(shù)據(jù)并得到確認(rèn)后發(fā)送下一條。三種機(jī)制,性能依次遞減吞吐量降低,數(shù)據(jù)健壯性則依次遞增。 kafka 簡(jiǎn)介 Kafka 是一種高吞吐量的分布式發(fā)布訂閱消息系統(tǒng) kafka角色必知 producer:生產(chǎn)者。 consumer:消費(fèi)者。 topic: 消...
閱讀 3227·2023-04-25 18:43
閱讀 907·2021-11-24 09:39
閱讀 1372·2021-10-14 09:43
閱讀 3905·2021-09-22 15:58
閱讀 1935·2019-08-29 17:18
閱讀 428·2019-08-29 14:14
閱讀 3087·2019-08-29 13:01
閱讀 1628·2019-08-29 12:33