php测试kafka项目示例
2020-02-13 11:31
1451 查看
本文实例讲述了php测试kafka项目。分享给大家供大家参考,具体如下:
概述
Kafka是最初由Linkedin公司开发,是一个分布式、分区的、多副本的、多订阅者,基于zookeeper协调的分布式日志系统(也可以当做MQ系统),常见可以用于web/nginx日志、访问日志,消息服务等等,Linkedin于2010年贡献给了Apache基金会并成为顶级开源项目。
主要应用场景是:日志收集系统和消息系统。
安装kafka-php项目依赖
composer require nmred/kafka-php
produce.php
<?php require './vendor/autoload.php'; date_default_timezone_set('PRC'); $config = \Kafka\ProducerConfig::getInstance(); $config->setMetadataRefreshIntervalMs(10000); $config->setMetadataBrokerList('127.0.0.1:9092'); $config->setBrokerVersion('0.10.2.1'); $config->setRequiredAck(1); $config->setIsAsyn(false); $config->setProduceInterval(500); $producer = new \Kafka\Producer(function() { $t = time(); return array( array( 'topic' => 'test', 'value' => $t, 'key' => $t, ), ); }); $producer->success(function($result) { var_export($result); }); $producer->error(function($errorCode) { var_dump('error', $errorCode); }); $producer->send();
consumer.php
<?php require './vendor/autoload.php'; date_default_timezone_set('PRC'); $config = \Kafka\ConsumerConfig::getInstance(); $config->setMetadataRefreshIntervalMs(10000); $config->setMetadataBrokerList('127.0.0.1:9092'); $config->setGroupId('test'); $config->setBrokerVersion('0.10.2.1'); $config->setTopics(array('test')); $consumer = new \Kafka\Consumer(); $consumer->start(function($topic, $part, $message) { var_dump($message); });
测试生产者
php produce.php
测试消费者
php consumer.php
更多关于PHP相关内容感兴趣的读者可查看本站专题:《php面向对象程序设计入门教程》、《PHP数组(Array)操作技巧大全》、《PHP基本语法入门教程》、《PHP运算与运算符用法总结》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
您可能感兴趣的文章:
相关文章推荐
- spring整合kafka项目生产和消费测试结果记录(一)
- Android推送通知的实现--PHP+ANDROID做消息推送:基于IBM的MQTT协议的Tokudu项目测试
- PHP开发的一个小小项目,记录下实现思路(附上实现功能的示例代码)(一)
- PHP+ANDROID做消息推送:基于IBM的MQTT协议的Tokudu项目测试
- php使用mysqli和pdo扩展,测试对比mysql数据库的执行效率完整示例
- php使用mysqli和pdo扩展,测试对比连接mysql数据库的效率完整示例
- PHP利用pdo_odbc实现连接数据库示例【基于ThinkPHP5.1搭建的项目】
- 一个完整的php项目示例
- 使用php测试硬盘写入速度示例
- PHP实现的自定义图像居中裁剪函数示例【测试可用】
- 如何使用jQuery+PHP+MySQL来实现一个在线测试项目
- Jimoshi_整合三大框架(一)--创建整合maven项目(SSH项目)、简单的测试示例(登录)、加载数据库模拟数据
- php token使用与验证示例【测试可用】[原创]_php技巧_脚本之家
- Eclipse根据wsdl文件自动生成webservice client图解,以及调用示例,附测试项目
- php中serialize序列化与json性能测试的示例分析
- PHP异常测试,示例二原创
- 如何使用jQuery+PHP+MySQL来实现一个在线测试项目
- PHP开发的一个小小项目,记录下实现思路(附上实现功能的示例代码)(二)
- 如何使用jQuery+PHP+MySQL来实现一个在线测试项目
- PHP中strtr与str_replace函数运行性能简单测试示例