消息中间件Kafaka - PHP操作使用Kafka
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了消息中间件Kafaka - PHP操作使用Kafka,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含1785字,纯文字阅读大概需要3分钟。
内容图文
![消息中间件Kafaka - PHP操作使用Kafka](/upload/InfoBanner/zyjiaocheng/666/be82efc0ec184a51af7e3f40596ca9a2.jpg)
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
OK
hp操作kafka
运行前先开启我们的zookeeper和kafka 上篇文章有如何开启
-
运行producer
kafka默认端口9092vim 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, "要发送的消息");
运行consumervim 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了。
内容总结
以上是互联网集市为您收集整理的消息中间件Kafaka - PHP操作使用Kafka全部内容,希望文章能够帮你解决消息中间件Kafaka - PHP操作使用Kafka所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。