• 企业400电话
  • 微网小程序
  • AI电话机器人
  • 电商代运营
  • 全 部 栏 目

    企业400电话 网络优化推广 AI电话机器人 呼叫中心 网站建设 商标✡知产 微网小程序 电商运营 彩铃•短信 增值拓展业务
    php测试kafka项目示例

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

    您可能感兴趣的文章:
    • 使用 PHP Masked Package 屏蔽敏感数据的实现方法
    • 完美解决phpdoc导出文档中@package的warning及Error的错误
    • 利用ThinkPHP内置的ThinkAjax实现异步传输技术的实现方法
    • PHP扩展之kafka安装应用案例详解
    上一篇:PHP图像处理 imagestring添加图片水印与文字水印操作示例
    下一篇:PHP查找一列有序数组是否包含某值的方法
  • 相关文章
  • 

    © 2016-2020 巨人网络通讯 版权所有

    《增值电信业务经营许可证》 苏ICP备15040257号-8

    php测试kafka项目示例 php,测试,kafka,项目,示例,