如何在 php中安装rdkafka

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

php-rdkafka 扩展安装

php有两种方式调用kafka

• php-rdkafka

rdkafka安装需要依赖librdkafka所以我们需要先安装librdkafka
git clone https://GitHub.com/edenhill/librdkafka.git

cd librdkafka./configuremake && make install

安装php-rdkafka扩展

git clone Https://github.com/arnaud-lb/php-rdkafka.gitcd php-rdkafkaphpize./configure --with-php-config=/usr/local/php7.0/bin/php-configmake && make install

然后在php.ini写入

extension = rdkafka.so

• kafka-php 扩展包

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

• 简单示例

生成者

<?php$rk = new RdKafka\Producer();$rk->setLogLevel(LOG_DEBUG);$rk->addBrokers("192.168.2.152");$topic = $rk->newTopic("shop");for ($i = 0; $i < 10; $i++) {    $topic->produce(RD_KAFKA_PARTITION_UA, 0, "发送信息： $i");    $rk->poll(0);}while ($rk->getOutQLen() > 0) {    $rk->poll(50);}?>

消费者

<?php$conf = new RdKafka\Conf();$conf->set('group.id', 'myConsumerGroup');$rk = new RdKafka\Consumer($conf);$rk->addBrokers("192.168.2.150:9092");$topicConf = new RdKafka\TopicConf();$topicConf->set('auto.commit.interval.ms', 100);$topicConf->set('offset.store.method', 'file');$topicConf->set('offset.store.path', sys_get_temp_dir());$topicConf->set('auto.offset.reset', 'smallest');$topic = $rk->newTopic("shop", $topicConf);// Start consuming partition 0$topic->consumeStart(0, RD_KAFKA_OFFSET_STORED);while (true) {    $message = $topic->consume(0, 120*10000);    switch ($message->err) {        case RD_KAFKA_RESP_ERR_NO_ERROR:        //没有错误打印信息            var_dump($message);            break;        case RD_KAFKA_RESP_ERR__PARTITION_EOF:            echo "等待接收信息\n";            break;        case RD_KAFKA_RESP_ERR__TIMED_OUT:            echo "超时\n";            break;        default:            throw new \Exception($message->errstr(), $message->err);            break;    }}?>

php有什么用

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

看完上述内容，你们对如何在 php中安装rdkafka有进一步的了解吗？如果还想了解更多知识或者相关内容，请关注编程网PHP编程频道，感谢大家的支持。