php kafka扩展使用_一路向前ylc的博客-CSDN博客_kafka扩展
php kafka扩展使用
一路向前ylc
于 2018-08-17 16:58:25 发布
5861
收藏
分类专栏：
php
linux
文章标签：
kafka
php kafka
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/yanyan42/article/details/81745141
版权
php
同时被 2 个专栏收录
25 篇文章
0 订阅
订阅专栏
linux
29 篇文章
0 订阅
订阅专栏
一、kafka是什么
Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能，但具有自己独特的设计。 这个独特的设计是什么样的呢？ 首先让我们看几个基本的消息系统术语： Kafka将消息以topic为单位进行归纳。 将向Kafka topic发布消息的程序成为producers. 将预订topics并消费消息的程序成为consumer. Kafka以集群的方式运行，可以由一个或多个服务组成，每个服务叫做一个broker. producers通过网络将消息发送到Kafka集群，集群向消费者提供消息，如下图所示：  客户端和服务端通过TCP协议通信。Kafka提供了Java客户端，并且对多种语言都提供了支持。
二、安装kafka
前提：要安装jdk
1、去这个页面下载kafka http://kafka.apache.org/downloads.html,我这边下载的是二进制的，不需要自己编译，也可以下载源码版，自己编译安装
2、下载安装
cd /download
wget https://www.apache.org/dyn/closer.cgi?path=/kafka/2.0.0/kafka_2.12-2.0.0.tgz
 tar -zxvf kafka_2.11-2.0.0.tgz
cd /download/kafka_2.11-2.0.0/config
编辑  监听的端口，让生产者监听9092端口
vi server.properties
消费者默认监听2182端口，也可以自己去修改
vi zookeeper.properties
三、开启测试
1、开启
cd /download/kafka_2.11-2.0.0
开一个终端1启动zookeeper (这里不懂zookeep是什么，可以看我上一篇博客)
./bin/zookeeper-server-start.sh config/zookeeper.properties
开一个终端2启动启动kafka
./bin/kafka-server-start.sh config/server.properties
开一个终端4启动测试的生产者，并监听topic的test
./bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test
开一个终端3启动测试的消费者，并监听topic的test(注意新版的要用--bootstrap-server，旧版的用--zookeeper)
./bin/kafka-console-consumer.sh --bootstrap-server localhost:2181 --topic test --from-beginning
其他操作指令：
a、创建一个test的话题：
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
b、查询话题
bin/kafka-topics.sh --list --zookeeper localhost:2181
具体可以看：http://kafka.apache.org/quickstart
此时
在终端4 输入信息，在终端3可以看到
注意：启动时可能会有一些问题，比如端口占用，等等，不要慌，慢慢来，看报错信息，百度百度，你会成功的，不懂的可以留言给我
2、设置多代理集群
复制两个server.properties
cp config/server.properties config/server-1.properties
cp config/server.properties config/server-2.properties
分别编辑两个文件
config/server-1.properties:     broker.id=1     listeners=PLAINTEXT://:9093     log.dirs=/tmp/kafka-logs-1   config/server-2.properties:     broker.id=2     listeners=PLAINTEXT://:9094     log.dirs=/tmp/kafka-logs-2
启动两个新节点
终端5：bin/kafka-server-start.sh config/server-1.properties
终端6：bin/kafka-server-start.sh config/server-2.properties
创建一个新的话题作为这个3个代理的replication-factor
开一个终端向生产者写入信息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-replicated-topic
>my test message 1 >my test message 2 >my test message 3
打开终端用消费者获取信息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-replicated-topic --from-beginning
bin/kafka-console-consumer.sh --bootstrap-server localhost:9093 --topic my-replicated-topic --from-beginning
bin/kafka-console-consumer.sh --bootstrap-server localhost:9094 --topic my-replicated-topic --from-beginning
可以测试容错能力
1 2 3 > ps aux | grep server-1.properties 7564 ttys002    0:15.91 /System/Library/Frameworks/JavaVM.framework/Versions/1.8/Home/bin/java... > kill -9 7564
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic
Topic:my-replicated-topic   PartitionCount:1    ReplicationFactor:3 Configs:
    Topic: my-replicated-topic  Partition: 0    Leader: 2   Replicas: 1,2,0 Isr: 2,0
虽然最初写的leader已经挂掉。但是这些信息仍然可以用来消费
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic my-replicated-topic
>my test message 1 >my test message 2 >my test message 3
一路向前ylc
关注
关注
点赞
收藏
打赏
评论
php kafka扩展使用
一、kafka是什么Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能，但具有自己独特的设计。这个独特的设计是什么样的呢？首先让我们看几个基本的消息系统术语：Kafka将消息以topic为单位进行归纳。将向Kafka topic发布消息的程序成为producers.将预订topics并消费消息的程序成为consumer.Kafka以集群的方式运行，可以...
复制链接
扫一扫
专栏目录
php环境下使用kafka
王安的博客
10-16
4922
1.安装PHP 扩展
a. 安装librdkafka 库
官网地址：https://github.com/edenhill/librdkafka
$ git clone https://github.com/edenhill/librdkafka.git
$ ./configure
$ make
$ sudo make install
b. 安装php-rdkafka 扩展
...
php7安装kafka扩展
zsl10的专栏
12-07
4277
一、安装librdkafka# cd /usr/local/src/
# git clone https://github.com/edenhill/librdkafka.git
# cd librdkafka
# ./configure
# make
# make install
# ln -s /usr/local/lib/librdkafka.so.1 /usr/lib/二、安装php-rdk
参与评论
您还未登录，请先
登录
后发表或查看评论
windows-kafka安装.rar
03-20
kafka_2.13-2.7.0 及启动方式
【Kafka原理你真懂了吗?】四万字Kafka教程
最新发布
Java
10-12
3519
Kafka 是一个分布式的，支持多分区、多副本，基于 Zookeeper 的分布式消息流平台，它同时也是一款开源的基于发布订阅模式的消息引擎系统。Kafka 0.9版本之前，offset存储在zookeeper，0.9版本及之后，默认将offset存储在Kafka的一个内置的topic中。除此之外，Kafka还可以选择自定义存储offset。offset的维护是相当繁琐的，因为需要考虑到消费者的Rebalace。
php java 消息队列_PHP 消息队列 Kafka 使用
weixin_32612347的博客
02-28
84
安装 Kafka 服务直接到 kafka 官网 , 下载最新的wget https://mirror.bit.edu.cn/apache/kafka/2.5.0/kafka_2.13-2.5.0.tgz解压，进入目录tar -zxvf kafka_2.13-2.5.0.tgzcd kafka_2.13-2.5.0启动 Kafka 服务使用安装包中的脚本启动单节点 Zookeeper 实例bin/z...
PHP操作Kafka
右手诗的博客
03-30
3421
本文对php操作kafka的方法做一个记录，备忘。
一、搭建kafka集群
下载kafka并解压：
tar -xzf kafka_2.13-2.7.0.tgz
搭建单机集群：
cd kafka_2.13-2.7.0
#创建两个broker配置并修改端口
cp config/server.properties config/server-1.properties
cp config/server.properties config/server-2.properties
编辑拷贝.
在 php 中简单调用 kafka
潘广宇的博客
03-12
3362
一、确保 kafka 已被安装在 Linux 服务器中
若未安装，查看此博客快速安装：
https://blog.csdn.net/panguangyuu/article/details/88408320
二、启动 kakfa 服务
# 启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties &...
PHP Kafka 使用详解
weixin_39104010的博客
06-16
789
PHP使用kafka进行消息订阅
php+kafka实践(亲测可用)
白白手游专栏(cocos2d-x)
01-10
847
1.确保config/server.properties下的listeners=PLAINTEXT://192.168.2.184:9092为域名:ip(这里仅适用ip地址)
2.安装php-kafka扩展
一、下载kafka扩展包 链接：https://pecl.php.net/package/rdkafka
　　a.window版本
根据pnpinfo里面的上述红圈信息选择合适的kaf...
PHP项目中Kafka的使用
hibeatiful的博客
12-28
1902
rdkafka，php-rdkafka
php扩展安装之rdkafka
懒人程序员的博客
01-15
760
在安装rdkafka前需要先安装librdkafka
MacOS安装
brew install librdkafka
CentOS
yum install librdkafka
Debian
apt install librdkafka
FreeBSD
pkg install librdkafka
使用PECL工具安装命令
pecl install rdkafka
源码安装
下载PHP版本对应的扩展版本
下载地址：http://pecl.php.net/package/rdkafka
下面以最新的PHP
php 安装kafka扩展
Bug制造者
11-04
348
1.kafka php扩展下载地址
https://github.com/arnaud-lb/php-rdkafka //php-rdkafka下载地址
2.在安装php-rdkafka之前需要给系统安装一个库，librdkafka。
https://github.com/edenhill/librdkafka //librdkafka地址
两个包都下载完之后，首先进行librdkafka的解压安装
# unzip librdkafka-master.zip
# cd librdkafk
kafka php 安装配置,kafka安装及Kafka-PHP扩展的使用，kafkakafka-php扩展_PHP教程
weixin_30920907的博客
03-10
87
kafka安装及Kafka-PHP扩展的使用，kafkakafka-php扩展话说用了就要有点产出，要不然过段时间又忘了，所以在这里就记录一下试用Kafka的安装过程和php扩展的试用。实话说，如果用于队列的话，跟PHP比较配的，还是Redis。用的顺手，呵呵，只是Redis不能有多个consumer。但Kafka官方对PHP不支持，PHP扩展是爱好者或使用者写的。下面就开始讲Kafka的安装吧。...
Kafka的介绍以及基于PHP的kafka的安装和测试
东哥的博客
03-10
123
本篇文章给大家分享的内容是关于Kafka的介绍以及基于PHP的kafka的安装和测试
简介
Kafka 是一种高吞吐量的分布式发布订阅消息系统
kafka角色必知
producer：生产者。
consumer：消费者。
topic: 消息以topic为类别记录,Kafka将消息种子(Feed)分类, 每一类的消息称之为一个主题(Topic)。
broker：以集群的方式运行,可以由一个或多个服务组...
php处理kafka,使用php操作kafka
weixin_32864847的博客
03-12
249
1：php的kafka扩展安装//下载librdkafka安装包：我下载的是0.9.4版本的库$ wget https://github.com/edenhill/librdkafka/archive/0.9.4.x.zip//解压,安装$ unzip librdkafka-0.9.4.x.zip$ cd librdkafka-0.9.4$ make && make install...
PHP操作Kafka：php-rdkafka扩展的安装
李维山的博客
06-08
3608
【相关文章】Linux下搭建Kafka服务
1、安装librdkafka：
librdkafka 是 Apache Kafka 协议的 C 库实现，提供生产者、消费者和管理客户端。它的设计考虑到了消息传递的可靠性和高性能，当前的数据对于生产者超过100 万 msgs/秒，对于消费者超过300万 msgs/秒。
#进入安装包存放目录
cd /usr/local/src
#克隆安装包
git clone https://github.com/edenhill/librdkafka....
php怎么连kafka,php连接kafka
weixin_34043280的博客
03-09
284
1、首先安装kafka扩展#安装librdkafka:版本：https://github.com/edenhill/librdkafka/releases/tag/v0.9.2$gitclonehttps://github.com/edenhill/librdkafka.git$./configure$make$sudomakeinstall#安装rdkafka...
php kafka
u013713010的专栏
04-01
2913
Kafka 是一种高吞吐的分布式消息系统，能够替代传统的消息队列用于解耦合数据处理，缓存未处理消息等，同时具有更高的吞吐率，支持分区、多副本、冗余，因此被广泛用于大规模消息数据处理应用。
Kafka的特点：
以时间复杂度为O(1)的方式提供消息持久化能力，即使对TB级以上数据也能保证常数时间复杂度的访问性能。高吞吐率。即使在非常廉价的商用机器上也能做到单机支持每秒100K条以上消息
php框架中配置Kafka
stringQiang的博客
07-02
196
由于Kafka是由Java编写的，所以我们需要先安装 java 的 jdk
大致运行原理
1. producer 先从 zookeeper 的 “/brokers/…/state” 节点找到该 partition 的 leader
2. producer 将消息发送给该 leader
3. leader 将消息写⼊本地 log
4. followers 从 leader pull 消息，写⼊本地 log 后 leader 发送 ACK(确认字符)
5. leader 收到所有 ISR 中的 replica
kafka扩展
musi_m的博客
09-08
584
1、kafka名词解释
● Producer ：消息生产者，就是向kafka broker发消息的客户端。
● Consumer ：消息消费者，向kafka broker取消息的客户端
● Topic ：咋们可以理解为一个队列。
● Consumer Group （CG）：这是kafka用来实现一个topic消息的广播（发给所有的consumer）和单播（发给任意一个consumer）的手段。一个...
nmred kafka-php,PHP使用Kafka
weixin_39665507的博客
03-17
698
what is kafkakafka是分布式发布订阅系统安装brew install kafka可能会提示brew cask install java中途会被安装zookeeper修改server.propertiesvim /usr/local/etc/kafka/server.properties增加一行配置listeners=PLAINTEXT://localhost:9092首先我们启动z...
“相关推荐”对你有帮助么？
非常没帮助
没帮助
一般
有帮助
非常有帮助
提交
©️2022 CSDN
皮肤主题：大白
设计师：CSDN官方博客
返回首页
一路向前ylc
CSDN认证博客专家
CSDN认证企业博客
码龄8年
暂无认证
74
原创
6万+
周排名
4万+
总排名
19万+
访问
等级
2023
积分
19
粉丝
42
获赞
27
评论
101
收藏
私信
关注
分类专栏
go
1篇
awk
2篇
histogram.py
1篇
php框架
2篇
Go程序设计语言
深入PHP面向对象编程
1篇
k8s
1篇
工具
1篇
redis
1篇
算法
1篇
linux
29篇
centos
2篇
mac
3篇
git
7篇
nginx
7篇
微信公众号开发
4篇
微信小程序开发
1篇
php
25篇
插件
2篇
七牛云
1篇
python
1篇
docker
11篇
最新评论
docker安装php开发环境
一路向前ylc:
谢谢认可
mac新版根目录不能创建文件夹
一路向前ylc:
开机时，按住command+R，进入恢复模式
mac新版根目录不能创建文件夹
Ataraxia -LIANG:
无法解决
docker安装php开发环境
睿思达DBA_WGX:
作者写的非常认真，好文章，学习起来。
你真的是在使用面向对象吗？
fareast_mzh:
Call undefined class "对象"
您愿意向朋友推荐“博客详情页”吗？
强烈不推荐
不推荐
一般般
推荐
强烈推荐
提交
最新文章
go 通道channel使用for-range造成死锁问题
awk的真实使用案例及区间分布统计工具histogram.py
awk 提取json文本的字段
2022年8篇
2021年7篇
2020年7篇
2019年11篇
2018年40篇
2017年7篇
2016年1篇
目录
目录
分类专栏
go
1篇
awk
2篇
histogram.py
1篇
php框架
2篇
Go程序设计语言
深入PHP面向对象编程
1篇
k8s
1篇
工具
1篇
redis
1篇
算法
1篇
linux
29篇
centos
2篇
mac
3篇
git
7篇
nginx
7篇
微信公众号开发
4篇
微信小程序开发
1篇
php
25篇
插件
2篇
七牛云
1篇
python
1篇
docker
11篇
目录
评论
被折叠的 条评论
为什么被折叠?
到【灌水乐园】发言
查看更多评论
打赏作者
一路向前ylc
你的鼓励将是我创作的最大动力
¥2
¥4
¥6
¥10
¥20
输入1-500的整数
余额支付
(余额：-- )
扫码支付
扫码支付：¥2
获取中
扫码支付
您的余额不足，请更换扫码支付或充值
打赏作者
实付元
使用余额支付
点击重新获取
扫码支付
钱包余额
抵扣说明：
1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。 2.余额无法直接购买下载，可以购买VIP、C币套餐、付费专栏及课程。
余额充值