메시지를 보내고 받을 수 있는 클라이언트입니다. 아래에서 보내기 및 받기 작업을 보여드리겠습니다. 필요한 친구는 다운로드하여 사용해 볼 수 있습니다.
메시지 보내기
<?phptry {
$rcf = new RdKafka\Conf();
$rcf->set('group.id', 'test');
$cf = new RdKafka\TopicConf();
$cf->set('offset.store.method', 'broker');
$cf->set('auto.offset.reset', 'smallest');
$rk = new RdKafka\Producer($rcf);
$rk->setLogLevel(LOG_DEBUG);
$rk->addBrokers("127.0.0.1");
$topic = $rk->newTopic("test", $cf);
for($i = 0; $i < 1000; $i++) {
$topic->produce(0,0,'test' . $i);//没有setMessge接口了,使用produce 参考：https://libraries.io/github/mentionapp/php-rdkafka
}
} catch (Exception $e) {
echo $e->getMessage();메시지 받기
<?phptry {
$rcf = new RdKafka\Conf();
$rcf->set('group.id', 'test');
$cf = new RdKafka\TopicConf();/*
$cf->set('offset.store.method', 'file');
*/
$cf->set('auto.offset.reset', 'smallest');
$cf->set('auto.commit.enable', true);
$rk = new RdKafka\Consumer($rcf);
$rk->setLogLevel(LOG_DEBUG);
$rk->addBrokers("127.0.0.1");
$topic = $rk->newTopic("test", $cf); //$topic->consumeStart(0, RD_KAFKA_OFFSET_BEGINNING);
while (true) {
$topic->consumeStart(0, RD_KAFKA_OFFSET_STORED);
$msg = $topic->consume(0, 1000);
var_dump($msg); if ($msg->err) { echo $msg->errstr(), "\n"; break;
} else { echo $msg->payload, "\n";
}
$topic->consumeStop(0);
sleep(1);
}
} catch (Exception $e) { echo $e->getMessage();
}이 사이트의 모든 리소스는 네티즌이 제공하거나 주요 다운로드 사이트에서 재인쇄되었습니다. 소프트웨어의 무결성을 직접 확인하십시오! 이 사이트의 모든 리소스는 학습 참고용으로만 사용됩니다. 상업적 목적으로 사용하지 마시기 바랍니다. 그렇지 않으면 모든 결과에 대한 책임은 귀하에게 있습니다! 침해가 있는 경우 당사에 연락하여 삭제하시기 바랍니다. 연락처: admin@php.cn
관련 기사
PHP 개발 실습: 온라인 라이브러리 플랫폼 구축27Oct2023
PHP 개발 실습: 온라인 도서관 플랫폼 구축 지속적인 기술 개발로 인해 전통적인 도서관 서비스 모델은 점차 디지털 및 온라인 도서관 플랫폼으로 대체되고 있습니다. 보다 편리하고 효율적인 도서관 서비스를 제공하고자 하는 기관이나 단체에게 온라인 도서관 플랫폼을 구축하는 것은 매우 효과적인 방법입니다. 이 기사에서는 PHP를 사용하여 모든 기능을 갖춘 사용자 친화적인 온라인 라이브러리 플랫폼을 개발하는 방법을 소개합니다. 1. 요구사항 분석 온라인 도서관 플랫폼을 구축하기 전에 먼저 플랫폼의 기능을 명확히 해야 합니다.
PHP8.0의 HTTP 클라이언트 라이브러리14May2023
PHP8.0의 HTTP 클라이언트 라이브러리 PHP8.0 릴리스에는 많은 새로운 기능과 개선 사항이 포함되어 있으며, 가장 눈길을 끄는 것 중 하나는 내장된 HTTP 클라이언트 라이브러리의 추가입니다. 이 라이브러리는 HTTP 요청을 보내고 반환된 응답을 처리하는 간단한 방법을 제공합니다. 이번 글에서는 이 라이브러리의 주요 기능과 사용법을 살펴보겠습니다. HTTP 요청 보내기 PHP8.0에 내장된 HTTP 클라이언트 라이브러리를 사용하여 HTTP 요청을 보내는 것은 매우 간단합니다. 이 예에서는 GET 메소드를 사용하여 이 웹사이트의 홈페이지를 가져옵니다.
Java로 간단한 버전의 도서관 관리 시스템을 구현하는 자세한 예15Jul2022
이 기사에서는 Java에 대한 관련 지식을 제공하며, 도서관 관리 시스템의 기능 분석, IDEA에서 기능적 클래스 생성 및 사용자 관련 작업 수행을 포함하여 간단한 버전의 도서관 관리 시스템 구현과 관련된 문제를 주로 정리합니다. 처리과정 및 기타 내용을 살펴보시고 모든 분들께 도움이 되었으면 좋겠습니다.
Java를 사용하여 간단한 라이브러리 관리 시스템을 구현하는 방법은 무엇입니까?04Nov2023
디지털 시대의 도래로 인해 전통적인 도서관 관리 방식은 더 이상 사람들의 요구를 충족시킬 수 없습니다. 컴퓨터 기술을 사용하면 도서관 관리의 효율성과 정확성이 크게 향상될 수 있습니다. 이 기사에서는 Java를 사용하여 간단한 라이브러리 관리 시스템을 작성하는 방법을 자세히 설명합니다. 1. 요구사항 분석 도서관 관리 시스템 작성을 시작하기 전에 요구사항을 분석해야 합니다. 구현해야 할 기능은 다음과 같습니다. 1) 도서 추가: 도서명, 저자, 출판사, 가격 및 기타 정보를 입력합니다. 2) 도서 삭제 : 도서에 따라
PHP8.0의 API 클라이언트 라이브러리: Guzzle14May2023
네트워크 기술의 발전으로 웹 애플리케이션과 API 애플리케이션이 점점 더 보편화되고 있습니다. 이러한 애플리케이션에 액세스하려면 API 클라이언트 라이브러리가 필요합니다. PHP에서 Guzzle은 PHP의 웹 서비스 및 API에 더 쉽게 액세스할 수 있는 많은 기능을 제공하는 인기 있는 API 클라이언트 라이브러리입니다. Guzzle 라이브러리의 주요 목표는 모든 형태의 HTTP 요청 및 응답을 처리할 수 있고 동시 요청 처리를 지원하는 간단하면서도 강력한 HTTP 클라이언트를 제공하는 것입니다. 존재하다
Hot Tools
종속성 주입 컨테이너용 PHP 라이브러리
종속성 주입 컨테이너용 PHP 라이브러리
50개의 뛰어난 클래식 PHP 알고리즘 모음
클래식 PHP 알고리즘, 훌륭한 아이디어를 배우고 사고력을 확장하세요
이미지 최적화를 위한 작은 PHP 라이브러리
이미지 최적화를 위한 작은 PHP 라이브러리