请选择 进入手机版 | 继续访问电脑版

[PHP编程] PHP扩展之kafka安装应用案例详解

  [复制链接]
查看254 | 回复51 | 2021-9-13 21:32:36 | 显示全部楼层 |阅读模式

话说用了就要有点产出,要不然过段时间又忘了,以是 在这里就记录一下试用Kafka的安装过程和php扩展的试用。

实话 说,假如 用于队列的话,跟PHP比较配的,还是Redis。用的随手 ,呵呵,只是Redis不能有多个consumer。但Kafka官方对PHP不支持,PHP扩展是爱好者或使用 者写的。下面就开始讲Kafka的安装吧。我以CentOS6.4为例,64位。

一. 起首 确认下jdk有没有安装

使用 下令

  1. [root@localhost ~]# java -version
  2. java version "1.8.0_73"
  3. Java(TM) SE Runtime Environment (build 1.8.0_73-b02)
  4. 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文件

  1. [root@localhost ~]# vim /etc/profile
复制代码

把下面这段代码写到文件里

  1. export JAVA_HOME=/usr/local/jdk/jdk1.8.0_73
  2. export CLASSPATH=.:$JAVA_HOME/lib/tools.jar:$JAVA_HOME/lib/dt.jar
  3. export PATH=$JAVA_HOME/bin:$PATH
复制代码

末了

  1. [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

  1. [root@localhost kafka_2.9.1-0.8.2.2]# sh bin/zookeeper-server-start.sh config/zookeeper.properties &
复制代码

启动Kafka server

  1. [root@localhost kafka_2.9.1-0.8.2.2]# sh bin/kafka-server-start.sh config/server.properties &
复制代码

运行生产者producer

  1. [root@localhost kafka_2.9.1-0.8.2.2]# sh bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
复制代码

运行消耗 者consumer

  1. [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

  1. <?php
  2. require 'vendor/autoload.php';
  3. while (1) {
  4. $part = mt_rand(0, 1);
  5. $produce = \Kafka\Produce::getInstance('kafka0:2181', 3000);
  6. // get available partitions
  7. $partitions = $produce->getAvailablePartitions('topic_name');
  8. var_dump($partitions);
  9. // send message
  10. $produce->setRequireAck(-1);
  11. $produce->setMessages('topic_name', 0, array(date('Y-m-d H:i:s'));
  12. sleep(3);
  13. }
复制代码

consumer.php

  1. require 'vendor/autoload.php';
  2. $consumer = \Kafka\Consumer::getInstance('kafka0:2181');
  3. $group = 'topic_name';
  4. $consumer->setGroup($group);
  5. $consumer->setFromOffset(true);
  6. $consumer->setTopic('topic_name', 0);
  7. $consumer->setMaxBytes(102400);
  8. $result = $consumer->fetch();
  9. print_r($result);
  10. foreach ($result as $topicName => $partition) {
  11. foreach ($partition as $partId => $messageSet) {
  12. var_dump($partition->getHighOffset());
  13. foreach ($messageSet as $message) {
  14. var_dump((string)$message);
  15. }
  16. var_dump($partition->getMessageOffset());
  17. }
  18. }
复制代码

到此这篇关于PHP扩展之kafka安装应用案例详解的文章就先容 到这了,更多干系 PHP扩展之kafka安装应用内容请搜索 脚本之家从前 的文章或继续欣赏 下面的干系 文章渴望 大家以后多多支持脚本之家!


免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!
回复

使用道具 举报

avatar yfyffuuy | 2021-9-14 01:31:30 | 显示全部楼层
禽兽不如应该不是说admin楼主的的吧?
回复

使用道具 举报

avatar 玲嘉婕嘉n | 2021-9-19 17:02:30 | 显示全部楼层
admin楼主说的我也略懂!
回复

使用道具 举报

avatar 却写杂布计 | 2021-9-19 17:02:33 | 显示全部楼层
这个帖子好无聊啊!
回复

使用道具 举报

avatar 直子的爱本 | 2021-9-20 21:01:43 | 显示全部楼层
今天过得很不爽!
回复

使用道具 举报

avatar 123457462 | 2021-9-20 21:40:31 | 显示全部楼层
没人理我,好伤心啊!
回复

使用道具 举报

avatar 晴朗71 | 2021-9-21 14:52:20 | 显示全部楼层
admin楼主看起来很有学问!
回复

使用道具 举报

avatar 慧眼识英雄1 | 2021-9-28 09:25:07 | 显示全部楼层
太邪乎了吧?
回复

使用道具 举报

avatar 老三是叔叔 | 2021-9-29 19:39:27 | 显示全部楼层
灌水不是我的目的!
回复

使用道具 举报

avatar chwbn765 | 2021-10-1 22:36:46 | 显示全部楼层
很有看点!
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则