php rdkafka实例,kafka 消息队列 php-rdkafka扩展示例

php版本为：7.2

# cd /var/www/html/

生产者，producer.php

$rk = new RdKafka\Producer();

$rk->setLogLevel(LOG_DEBUG); // 设置日志级别

$rk->addBrokers('127.0.0.1'); // 添加经纪人，就是ip地址

$topic = $rk->newTopic("test2"); // 新建主题

// 第一个参数：是分区。RD_KAFKA_PARTITION_UA代表未分配，并让librdkafka选择分区

// 第二个参数：是消息标志，必须为0

// 第三个参数：消息，如果不为NULL，它将被传递给主题分区程序

$topic->produce(RD_KAFKA_PARTITION_UA, 0, 'Message'); // 生成并发送单个消息

消费者，consumer.php

$rk = new RdKafka\Consumer();

$rk->setLogLevel(LOG_DEBUG); // 设置日志级别

$rk->addBrokers("127.0.0.1"); // 添加经纪人，就是ip地址

$topic = $rk->newTopic("test2"); // 这里的$rk和生产者是不同的类哦

// 第一个参数分区ID

// 第二个参数是开始消费的偏移量，有效值

$topic->consumeStart(0, RD_KAFKA_OFFSET_BEGINNING);

while (true) {

// 第一个参数要消耗的分区

// 第二个参数是等待收到消息的最长时间，1000是一秒

$msg = $topic->consume(0, 1000);

if (@$msg->err) {

echo $msg->errstr(), "\n"; // 输出错误

break;

} else {

echo @$msg->payload, "\n"; // 输出消息

}

测试

# cd /var/www/html/

# php consumer.php

新开一个终端，运行生产者，发送消息

# php producer.php

每当生产者运行一次就会发送一条消息，消费者那边就会接收到这条消息并进行相应的处理。

php rdkafka实例,kafka 消息队列 php-rdkafka扩展示例相关推荐

Kafka 消息队列的使用
本篇概要: 1. 消息队列相关概念: 2. Kafka 消息队列: 3. 安装 Kafka 服务: 4. 安装PHP的 Kafka 扩展 rdkafka: 5. 编写 Kafka 的生产者方法: 6. ...
Flink使用KafkaSource从Kafka消息队列中读取数据
Flink使用KafkaSource从Kafka消息队列中读取数据使用KafkaSource从Kafka消息队列中读取数据 1.KafkaSource创建的DataStream是一个并行的DataS ...
Kafka消息队列的搭建与基础使用
一.Kafka消息队列 1.为什么需要消息队列? 解耦冗余扩展性灵活性 & 峰值处理能力可恢复性顺序保证缓冲异步通信 2.消息队列的模式 1.点对点模式一对一,消费者主动拉取数 ...
kafka消息队列的概念理解
kafka在大数据.分布式架构中都很流行.kafka可以进行流式计算,也可以做为日志系统,还可以用于消息队列. kafka作为消息队列的优点: 分布式的系统高吞吐量.即使存储了许多TB的消息,它也保 ...
使用kafka消息队列中间件实现跨进程，跨服务器的高并发消息通讯
作者 | 陈屹责编 | 欧阳姝黎近来工作上接收到一项任务,实现c++后台服务器程序,要求它能承载千万级别的DAU读写请求.目前实现千万级高并发海量数据请求的服务器设计在"套路 ...
19 kafka消息队列
文章目录 19 kafka消息队列一.kafka介绍 1.消息队列基本介绍 2.常用的消息队列介绍 3.消息队列的应用场景 4.消息队列的两种模式 5.kafka的基本介绍 6.kafka的架构介绍 ...
kafka 消息队列
kafka 消息队列 kafka 架构原理大数据时代来临,如果你还不知道Kafka那就真的out了!据统计,有三分之一的世界财富500强企业正在使用Kafka,包括所有TOP10旅游公司,7家TOP ...
Java+Kafka消息队列
本文主要针对,Java端对Kafka消息队列的生产和消费.Kafka的安装部署,请看查看相关文章. 笔者最近所用的是Spring mvc,监听文件路径,然后将读取到的文件内容发送到消息队列中.由另外系 ...
SpringBoot集成Kafka消息队列
1.说明 Spring可以方便的集成使用 Kafka消息队列 , 只需要引入依赖包spring-kafka, 注意版本兼容问题, 本文详细介绍SpringBoot集成Kafka的方法, 以及生产者和消 ...

php rdkafka实例,kafka 消息队列 php-rdkafka扩展示例

php rdkafka实例,kafka 消息队列 php-rdkafka扩展示例相关推荐

最新文章

热门文章