文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

如何在 php中安装rdkafka

2023-06-15 00:57

关注

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

php-rdkafka 扩展安装

php有两种方式调用kafka

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

如何在 php中安装rdkafka

如何在 php中安装rdkafka

如何在 php中安装rdkafka

文档地址: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中安装rdkafka

php有什么用

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

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

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯