php 테스트 kafka 프로젝트 예시

본 논문 의 사례 는 phop 테스트 kafka 프로젝트 를 서술 하 였 다.여러분 께 참고 하도록 공유 하 겠 습 니 다.구체 적 으로 는 다음 과 같 습 니 다.
개술
Kafka 는 최초 로 Linkedin 회사 가 개발 한 분포 식,파 티 션,다 중 복사 본,다 중 구독 자 입 니 다.zookeeper 가 조 화 를 이 루 는 분포 식 로그 시스템(MQ 시스템 으로 도 사용 할 수 있 습 니 다)을 바탕 으로 웹/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 프로 그래 밍 에 도움 이 되 기 를 바 랍 니 다.