本文摘自PHP中文网,作者小云云,侵删。
本文主要和大家分享linux下php扩展kafka的实例,希望能帮助到大家。
1、安装librdkafka
1 2 3 4 5 6 7 | wget https://github.com/edenhill/librdkafka/archive/master.zip #下载
mv master.zip librdkafka-master.zip #修改包名
unzip librdkafka-master.zip #解压
cd librdkafka-master #进入安装文件夹
./configure #配置
make #编译
make install #安装
|
2、安装phpkafka
1 2 3 4 5 6 7 8 9 10 11 | cd /usr/local/src #进入安装包存放目录
wget https://github.com/EVODelavega/phpkafka/archive/master.zip #下载
mv master.zip phpkafka-master.zip #修改包名
unzip phpkafka-master.zip #解压
cd phpkafka-master #进入安装文件夹
/usr/local/php/bin/phpize #加载php扩展模块
./configure --enable-kafka --with-php-config=/usr/local/php/bin/php-config #配置
make #编译
make install #安装
3、修改php配置文件
vi /usr/local/php/etc/php.ini
|
打开php配置文件,在最后一行添加下面的代码
:wq! #保存退出
4、测试
以下代码,保存为phpinfo.php
有kafka模块
这是生产者
1 2 3 4 5 6 7 8 9 10 11 12 | $kafka = new Kafka( "localhost:9092" );
$partitions = $kafka ->getPartitionsForTopic( 'testkk' );
$in = fopen ( 'php://stdin' , 'r' );
while (true) {
echo "\nEnter comma separated messages:\n" ;
$messages = explode ( ',' , fgets ( $in ));
foreach ( array_keys ( $messages ) as $k ) {
}
$bytes = $kafka ->produce( "testkk" , "kkkkkkk" );
printf( "\nSuccessfully sent %d messages (%d bytes)\n\n" , count ( $messages ), $bytes );
}
|
相关推荐:
使用 PHP 编写的 Kafka 客户端
kafka安装及Kafka-PHP扩展的使用
kafka装配及Kafka-PHP扩展的使用
以上就是linux下php扩展kafka的实例分享的详细内容,更多文章请关注木庄网络博客!
相关阅读 >>
关于windows桌面上ftp如何上传文件到Linux服务器
Linux与android的区别吗
Linux共享上网设置的实例分析
Linux文件路径怎么写?
如何在Linux上编译和运行c和c++程序
Linux用哪个发行版
Linux 下同名符冲突的问题及解决办法
Linux不识别网卡
Linux实现使用cp命令时不提示信息
Linux中显示当前工作目录的命令是什么
更多相关阅读请进入《Linux》频道 >>
转载请注明出处:木庄网络博客 » linux下php扩展kafka的实例分享