php環境下使用kafka

2021-08-29 03:59:59 字數 1227 閱讀 9920

a. 安裝librdkafka 庫

$  git clone 


$  ./configure


$  make


$  sudo make install
b. 安裝php-rdkafka 擴充套件

$ git clone 


#生成configure檔案


$ phpize 


#編譯安裝


$ ./configure --with-php-config=/usr/local/php7/bin/php-config


$ make


$ make install 


#在php.ini 檔案中配置 rdkafka擴充套件


$ vim /usr/local/php7/etc/php.ini


extension=rdkafka.so


#檢視擴充套件是否生效


a.我在model層封裝了乙個kafka類


<?php 


/** * created by phpstorm.


* user: wangan


* date: 2018/10/17


* time: 10:06


*/class kafka


$rk = new \rdkafka\producer();


if(empty($rk))


$rk->setloglevel(log_debug);


if(!$rk->addbrokers($this->broker_list))


$this->producer = $rk;


}public function sendmessage($array_message = )


}
b.在controller中呼叫該方法


public function testkafkaproducer()
實現效果如下


可以看到，瀏覽器沒呼叫一次，下方的消費者都會接受到乙個訊息。
				
windows 環境使用 kafka
近來學習 kafka，網上搜的教程好多不好用。在此開一貼記錄一下學習過程。推薦官網，是最好的教程 官網上是linux 環境，我用的是windows 環境。已經安裝過jdk 2 解壓，我把它解壓到 d server kafka2.12，路徑中最好不要有空格 3 修改配置檔案 config 目錄下的 z...

				
Linux下搭建kafka環境
apache官網 tar xzf kafka 2.10 0.8.2.2.tgz cd kafka 2.10 0.8.2.2 啟動zk有兩種方式，第一種是使用kafka自己帶的乙個zk。bin zookeeper server start.sh config zookeeper.properties ...

				
Linux下搭建kafka環境
apache官網 tar xzf kafka 2.10 0.8.2.2.tgz cd kafka 2.10 0.8.2.2 3.啟動服務 3.1 啟動zookeeper 啟動zk有兩種方式，第一種是使用kafka自己帶的乙個zk。bin zookeeper server start.sh confi...