脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 网络编程 → PHP编程 → php技巧 → php测试kafka项目

php测试kafka项目示例

 更新时间：2020年02月06日 12:15:49   作者：李琼涛  
这篇文章主要介绍了php测试kafka项目,结合实例形式分析了kafka-php项目依赖的安装、配置及测试使用技巧,需要的朋友可以参考下

本文实例讲述了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程序设计有所帮助。

您可能感兴趣的文章:

相关文章

  • 解决Mac OS X 自带PHP环境gd库扩展缺少freetype的问题

    解决Mac OS X 自带PHP环境gd库扩展缺少freetype的问题

    下面小编就为大家分享一篇解决Mac OS X 自带PHP环境gd库扩展缺少freetype的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2018-03-03
  • 关于php支持的协议与封装协议总结（推荐）

    关于php支持的协议与封装协议总结（推荐）

    这篇文章主要给大家介绍了关于php支持的协议与封装协议的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用PHP具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧。
    2017-11-11
  • PHP 引用文件技巧

    PHP 引用文件技巧

    最近在学PHP,习惯性的喜欢把它与.NET作些比较，发现其中一个不同就是对其他文件中对象的引用问题。
    2010-03-03
  • PHP include_path设置技巧分享

    PHP include_path设置技巧分享

    当时候函数include(),require(),fopen_with_path()函数来寻找文件时候.在不设置include_path的情况下,这些函数打开文件时候默认的是以web根目录去寻找.当设置include_path以后,这些php函数就会先在指定的include_path目录下面去搜索寻找
    2011-07-07
  • php异常处理方法实例汇总

    php异常处理方法实例汇总

    这篇文章主要介绍了php异常处理方法,实例汇总了常见的php异常处理技巧,非常具有实用价值,需要的朋友可以参考下
    2015-06-06
  • PHP中error_reporting()函数的用法(修改PHP屏蔽错误)

    PHP中error_reporting()函数的用法(修改PHP屏蔽错误)

    一般在默认的普通PHP文件中输出一个未定义声明的变量是不会报错误的，但在codeigniter框架下却要报错误，这对于想集成 添加 和 修改 页面于一体的”懒人”很不方便，由于是初学者开始还想怎么在代码中屏蔽这一错误提示呢.甚至用到了@,但听很多人都说@会大大降低性能.
    2011-07-07
  • php中getservbyport与getservbyname函数用法实例

    php中getservbyport与getservbyname函数用法实例

    这篇文章主要介绍了php中getservbyport与getservbyname函数用法,以实例形式分析了getservbyport与getservbyname函数获取server端的端口等信息的方法,需要的朋友可以参考下
    2014-11-11
  • PHP互换两个变量值的方法(不用第三变量)

    PHP互换两个变量值的方法(不用第三变量)

    相信每个刚接触PHP语言的童鞋们应该藕知道，PHP中两个变量的值互换是个很常见的做法，那么下面这篇文章我们就来介绍几个对于变量值互换的常见操作方法，文中介绍的很详细，相信对于大家的理解和学习很有帮助，下面有需要的朋友们来一起看看吧。
    2016-11-11
  • Linux下php5.4启动脚本

    Linux下php5.4启动脚本

    这篇文章主要介绍了Linux下php5.4启动脚本,需要的朋友可以参考下
    2014-08-08
  • php读取目录及子目录下所有文件名的方法

    php读取目录及子目录下所有文件名的方法

    这篇文章主要介绍了php读取目录及子目录下所有文件名的方法,对比了几种常见的方法,最后实例总结了一个php读取目录及子目录下所有文件名的方法,非常具有实用价值,需要的朋友可以参考下
    2014-10-10

最新评论