php-rdkafka扩展的安装

不念不忘少年蓝@ 2022-11-15 14:06 444阅读 0赞

### 安装 PHP 扩展 ###

*  一、安装 librdkafka 扩展
 *  二、安装 php-rdkafka 扩展
 *  三、修改配置文件
 *  四、简单示例

# 一、安装 librdkafka 扩展 #

rdkafka 安装需要依赖 librdkafka , 所以先安装 librdkafka

git clone https://github.com/edenhill/librdkafka.git

git上面的总是下载不下来  
我的  
链接：https://pan.baidu.com/s/1NLaIeD8h66Q9\_MJIq-7dBQ  
提取码：3sz2  
![在这里插入图片描述][20210401170949657.png]  
我这里的名字是 librdkafka-master

unzip librdkafka.zip  #解压 如果是git下载的就可以直接使用 如果是我的就unzip librdkafka-master #解压然后进到文件夹里面 
    cd librdkafka
    ./configure
    make && make install

# 二、安装 php-rdkafka 扩展 #

git clone https://github.com/arnaud-lb/php-rdkafka.git

git上面的总是下载不下来  
我的  
链接：https://pan.baidu.com/s/1NoGfGp5ZfWmH\_IG941jvcA  
提取码：0pr7  
![在这里插入图片描述][20210401170850222.png]  
我这里的名字是 php-rdkafka-master

unzip php-rdkafka-master.zip  #解压 如果是git下载的就可以直接使用 如果是我的就unzip php-rdkafka-master.zip #解压然后进到文件夹里面 
    cd php-rdkafka
    phpize
    ./configure --with-php-config=/usr/local/php/bin/php-config
    #这里根据自己的情况填写路径
    make && make install

成功会显示这个 这样的就可以直接添加  
![在这里插入图片描述][2021040117045381.png_pic_center]

# 三、修改配置文件 #

在 php-ini 加上 在PHPinfo输出里面看你的配置文件地址  
![在这里插入图片描述][20210401170423211.png_pic_center]

extension=rdkafka.so

如果提示找不到rdkafka.so 就直接全局搜 然后写绝对路径就可以了  
重启，php-fpm，就应该可以看到该扩展。  
执行phpinfo（）  
![在这里插入图片描述][20210401170356933.png_pic_center]

应该就有了 这个时候就可以使用了

# 四、简单示例 #

生产者 创建一个生产者Producer.php

<?php
    
         $rk = new \RdKafka\Producer();
            $rk->addBrokers("localhost:9092"); //kafka服务器地址
             
            $topic = $rk->newTopic("qzcsbj"); //topic名称
            for ($i = 0; $i < 10; $i++) { 
                $topic->produce(RD_KAFKA_PARTITION_UA, 0, "发送信息： $i");
                $rk->poll(0);
            }
            while ($rk->getOutQLen() > 0) { 
                $rk->poll(50);
            }
    
    
    ?>

消费者 创建一个消费者 Consumer.php

<?php
    
            $conf = new \RdKafka\Conf();
            $conf->set('group.id', 'myConsumerGroup');
     
            $rk = new \RdKafka\Consumer($conf);
            $rk->addBrokers("localhost: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("qzcsbj", $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;
                }
            }
    
    
    ?>

执行消费者监听消息 可见消费者收到了消息：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1bnNpamlhMjE5ODM_size_16_color_FFFFFF_t_70_pic_center]

执行生产者

![在这里插入图片描述][2021040117025747.png_pic_center]

[20210401170949657.png]: /images/20221022/86d2d60e53f342069c9b83cbb4d66ce4.png
[20210401170850222.png]: /images/20221022/34f6b74c751c447597d165fbbe2fd025.png
[2021040117045381.png_pic_center]: /images/20221022/1cc0a67928a04e3bb747c09f68a0eec8.png
[20210401170423211.png_pic_center]: /images/20221022/7117fdef606648fda57aaf2dc3652719.png
[20210401170356933.png_pic_center]: /images/20221022/d9133fce236e4bdab871f2f89b6e37a2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1bnNpamlhMjE5ODM_size_16_color_FFFFFF_t_70_pic_center]: /images/20221022/30325773c1454655ae1afef9a33cabda.png
[2021040117025747.png_pic_center]: /images/20221022/aec99de3d2c14fa8baa8192e678e8215.png