kafka安装及kafka-php扩展的使用，kafkakafka-php扩展话说用了就要有点产出，要不然过段时间又忘了，所以在这里就记录一下试用kafka的安装过程和php扩展的试用。
实话说，如果用于队列的话，跟php比较配的，还是redis。用的顺手，呵呵，只是redis不能有多个consumer。但kafka官方对php不支持，php扩展是爱好者或使用者写的。下面就开始讲kafka的安装吧。我以centos6.4为例,64位。
一. 首先确认下jdk有没有安装
使用命令
[root@localhost ~]# java -versionjava version 1.8.0_73java(tm) se runtime environment (build 1.8.0_73-b02)java hotspot(tm) 64-bit server vm (build 25.73-b02, mixed mode)
如果有以上信息的话，就往下安装吧，有些可能是jdk对不上，那就装到对的上的。如果没有安装，就看一下下面的jdk安装方法：
http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html
到这个地址下载jdk8版本，我下载的是jdk-8u73-linux-x64.tar.gz，然后解压到/usr/local/jdk/下。
然后打开/etc/profile文件
[root@localhost ~]# vim /etc/profile
把下面这段代码写到文件里
export java_home=/usr/local/jdk/jdk1.8.0_73export classpath=.:$java_home/lib/tools.jar:$java_home/lib/dt.jarexport path=$java_home/bin:$path
最后
[root@localhost ~]# source /etc/profile
这时jdk就生效了，可以使用 java -version验证下。
二. 接下来安装kafka
1. 下载kafka
到http://kafka.apache.org/downloads.html下载相应的版本，我使用的是kafka_2.9.1-0.8.2.2.tgz。
2. 下载完解压到你喜欢的目录
我是解压到 /usr/local/kafka/kafka_2.9.1-0.8.2.2
3. 运行默认的kafka
启动zookeeper server
[root@localhost kafka_2.9.1-0.8.2.2]# sh bin/zookeeper-server-start.sh config/zookeeper.properties &
启动kafka server
[root@localhost kafka_2.9.1-0.8.2.2]# sh bin/kafka-server-start.sh config/server.properties &
运行生产者producer
[root@localhost kafka_2.9.1-0.8.2.2]# sh bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
运行消费者consumer
[root@localhost kafka_2.9.1-0.8.2.2]# sh bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
这样，在producer那边输入内容，consumer马上就能接收到。
4. 当有跨机的producer或consumer连接时
需要配置config/server.properties的host.name，要不然跨机的连不上。
三. kafka-php扩展
使用了一圈，就https://github.com/nmred/kafka-php可以用。
我是使用composer安装的，以下是示例：
producer.php
getavailablepartitions('topic_name'); var_dump($partitions); // send message $produce->setrequireack(-1); $produce->setmessages('topic_name', 0, array(date('y-m-d h:i:s')); sleep(3);}
consumer.php
require 'vendor/autoload.php';$consumer = \kafka\consumer::getinstance('kafka0:2181');$group = 'topic_name';$consumer->setgroup($group);$consumer->setfromoffset(true);$consumer->settopic('topic_name', 0);$consumer->setmaxbytes(102400);$result = $consumer->fetch();print_r($result);foreach ($result as $topicname => $partition) { foreach ($partition as $partid => $messageset) { var_dump($partition->gethighoffset()); foreach ($messageset as $message) { var_dump((string)$message); } var_dump($partition->getmessageoffset()); }}
http://www.bkjia.com/phpjc/1100706.htmlwww.bkjia.comtruehttp://www.bkjia.com/phpjc/1100706.htmltecharticlekafka安装及kafka-php扩展的使用，kafkakafka-php扩展 话说用了就要有点产出，要不然过段时间又忘了，所以在这里就记录一下试用kafka的安装过程...