• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

消息中间件Kafaka-PHP操作使用Kafka

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

Centos版本:Centos6.4,PHP版本:PHP7。

在上一篇文章中使用IP为192.168.9.154的机器安装并开启了Kafka进行了简单测试,充当了Kafka服务器。

本篇文章新开启一台IP为192.16.9.157的机器给PHP开启扩展。

找到github的扩展下载地址,这里是php-rdkafka,虽然php有一个扩展是php-kafka,但是php-rdkafka要比php-kafka强大。

https://github.com/arnaud-lb/php-rdkafka  //php-rdkafka下载地址

  在安装php-rdkafka之前需要给系统安装一个库,librdkafka。

https://github.com/edenhill/librdkafka  //librdkafka地址

  两个包都下载完之后,首先进行librdkafka的解压安装

# unzip librdkafka-master.zip 
# cd librdkafka-master
# ./configure
# make && make install

  接下来编译安装php-rdkafka

unzip php-rdkafka-master.zip
# cd php-rdkafka-master
# phpize
# ./configure --with-php-config=/usr/local/php/bin/php-config 
# make && make install

  

Installing shared extensions:     /usr/local/php/lib/php/extensions/no-debug-non-zts-20170718/  //so地址
# vim /usr/local/php/etc/php.ini   //添加下面代码
extension=/usr/local/php/lib/php/extensions/no-debug-non-zts-20170718/rdkafka.so
# service php-fpm restart  //重启PHP

  

#查看扩展是否生效
php -m | grep kafka

OK

 

hp操作kafka

运行前先开启我们的zookeeper和kafka 上篇文章有如何开启

    1. 运行producer
      kafka默认端口9092

      vim producer.php

 <?php
    $rk = new RdKafka\Producer();
    $rk->setLogLevel(LOG_DEBUG);
    $rk->addBrokers("ip:9092");       
    $topic = $rk->newTopic("test");
    $topic->produce(RD_KAFKA_PARTITION_UA, 0, "要发送的消息");

  运行consumer
vim consumer.php

<?php
    $rk = new RdKafka\Consumer();
    $rk->setLogLevel(LOG_DEBUG);
    $rk->addBrokers("ip");
    $topic = $rk->newTopic("test");
    $topic->consumeStart(0, RD_KAFKA_OFFSET_BEGINNING);
    while(true){
        sleep(1);
        $msg = $topic->consume(0, 1000);
        if ($msg) {
            echo $msg->payload, "\n";
        }          
    }    

 开启两个窗口一个运行consumer 一个运行producer

php consumer.php
php producer.php

会发现我们已经简单的会使用kafka了。

 


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap