如何在php中安装rdkafka

　　介绍

今天就跟大家聊聊有关如何在php中安装rdkafka,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。

php-rdkafka扩展安装

php有两种方式调用卡夫卡

<李> php-rdkafka

rdkafka安装需要依赖librdkafka所以我们需要先安装librdkafka

cd  librdkafka 　　./configure 　　make ,,, make 安装

安装php-rdkafka扩展

git  clone  https://github.com/arnaud-lb/php-rdkafka.git 　　cd  php-rdkafka 　　phpize 　　。/configure ——with-php-config=/usr/地方/php7.0/bin/php-config 　　make ,,, make 安装

然后在php。ini写入

extension =rdkafka。所以

如何在php中安装rdkafka

%20

%20%20

<李> kafka-php扩展包

文档地址:https://github.com/weiboad/kafka-php

<李> 简单示例

生成者

& lt; php ? 　　 　　$ rk =, new  RdKafka \生产商(); 　　rk→美元setLogLevel (LOG_DEBUG); 　　rk→美元addBrokers (“192.168.2.152"); 　　 　　美元$ topic =, rk→newTopic (“shop"); 　　 　　for ($小姐:=,0;,美元小姐:& lt;, 10;,我+ +美元),{ 　　,,,主题→美元生产(RD_KAFKA_PARTITION_UA, 0,“发送信息:,我美元); 　　,,,美元rk→调查(0); 　　} 　　 　　while  (rk→美元getOutQLen(),祝辞,0),{ 　　,,,美元rk→调查(50); 　　} 　　 　　?在

消费者

& lt; php ? 　　 　　$ conf =, new  RdKafka \ Conf (); 　　 　　美元配置→设置(& # 39;group.id& # 39;,, & # 39; myConsumerGroup& # 39;); 　　 　　$ rk =, new  RdKafka \消费者(参看美元); 　　rk→美元addBrokers (“192.168.2.150:9092"); 　　 　　$ topicConf =, new  RdKafka \ TopicConf (); 　　美元topicConf→设置(& # 39;auto.commit.interval.ms& # 39;,, 100); 　　美元topicConf→设置(& # 39;offset.store.method& # 39;,, & # 39;文件# 39;); 　　美元topicConf→设置(& # 39;offset.store.path& # 39;,, sys_get_temp_dir ()); 　　美元topicConf→设置(& # 39;auto.offset.reset& # 39;,, & # 39;最小# 39;); 　　 　　美元$ topic =, rk→newTopic (“shop",, topicConf美元);//,Start  consuming  partition  0 　　主题→美元consumeStart (0,, RD_KAFKA_OFFSET_STORED); 　　 　　while (真实),{ 　　,,,message 美元;=,主题→美元消费(0,120 * 10000); 　　,,,switch (信息→美元犯错),{ 　　,,,,,,,case  RD_KAFKA_RESP_ERR_NO_ERROR: 　　,,,,,,,//没有错误打印信息 　　,,,,,,,,,,,var_dump($消息); 　　,,,,,,,,,,,休息; 　　,,,,,,,case  RD_KAFKA_RESP_ERR__PARTITION_EOF: 　　,,,,,,,,,,,echo “等待接收信息\ n"; 　　,,,,,,,,,,,休息; 　　,,,,,,,case  RD_KAFKA_RESP_ERR__TIMED_OUT: 　　,,,,,,,,,,,echo “超时\ n"; 　　,,,,,,,,,,,休息; 　　,,,,,,,默认值: 　　,,,,,,,,,,,throw  new  \异常(信息→美元errstr(),信息→美元犯错); 　　,,,,,,,,,,,休息; 　　,,,} 　　} 　　 　　?在

如何在php中安装rdkafka

php有什么用

php是一个嵌套的缩写名称,是英文超级文本预处理语言,它的语法混合了C、Java、Perl以及php自创新的语法,主要用来做网站开发,许多小型网站都用php开发,因为php是开源的,从而使php经得久不衰。

看完上述内容,你们对如何在php中安装rdkafka有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注行业资讯频道,感谢大家的支持。

如何在php中安装rdkafka