php测试kafka项目示例分析-创新互联

今天就跟大家聊聊有关php测试kafka项目示例分析,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。

成都创新互联公司是一家专注于成都网站建设、网站建设与策划设计,旌德网站建设哪家好?成都创新互联公司做网站,专注于网站建设10余年,网设计领域的专业建站公司;建站业务涵盖:旌德等地区。旌德做网站价格咨询:028-86922220

概述

Kafka是最初由Linkedin公司开发,是一个分布式、分区的、多副本的、多订阅者,基于zookeeper协调的分布式日志系统(也可以当做MQ系统),常见可以用于web/nginx日志、访问日志,消息服务等等,Linkedin于2010年贡献给了Apache基金会并成为顶级开源项目。

主要应用场景是:日志收集系统和消息系统。

安装kafka-php项目依赖

composer require nmred/kafka-php

produce.php

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

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测试kafka项目示例分析有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注创新互联行业资讯频道,感谢大家的支持。


文章标题:php测试kafka项目示例分析-创新互联
当前网址:http://myzitong.com/article/dhjgje.html