linux 下php对kafka的扩展
2016-07-21 14:56
351 查看
1、安装librdkafka
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
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配置文件,在最后一行添加下面的代码
extension="kafka.so"
:wq! #保存退出
4、测试
以下代码,保存为phpinfo.php<?php
phpinfo();
?>
有kafka模块
这是生产者
$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) { //$messages[$k] = trim($messages[$k]); } $bytes=$kafka->produce("testkk", "kkkkkkk"); printf("\nSuccessfully sent %d messages (%d bytes)\n\n", count($messages), $bytes); }
相关文章推荐
- linux red hat 安装svn
- windows 文件夹挂载到linux目录下
- 决心书之学习linux高级运维
- linux中的/dev/fd详解(linux3.2.0)
- centos6.3配置MFS服务器
- Linux上几个可以影响到服务器并发处理性能的系统参数
- centos6.5上dstat的安装
- Linux系统编程--文件(四)
- FIFO管道通信(linux)
- Linux下通过crontab及expect实现自动化处理
- centos 安装软件的方法
- PIPO管道通信范列(linux)
- Linux系统调用--mmap/munmap函数详解【转】
- FreeBSD和linux下/proc 目录介绍
- linux、python、exvim相关软件下载
- 转:linux下共享库的注意点之-fpic
- linux历史发展
- Linux + python +mysqlDB + mysql + innoDB
- Linux命令-less
- Linux中zip压缩和unzip解压缩命令详解