ホームページ  >  記事  >  バックエンド開発  >  rdkafka phpのインストール方法

rdkafka phpのインストール方法

藏色散人
藏色散人オリジナル
2021-05-13 09:14:442847ブラウズ

php rdkafka のインストール方法: 最初に librdkafka をダウンロードしてインストールし、次に php-rdkafka 拡張機能をインストールし、最後に php.ini に "extension=rdkafka.so" を書き込みます。

rdkafka phpのインストール方法

#この記事の動作環境: Windows7 システム、php7.0 バージョン、DELL G3 コンピューター

php-rdkafka 拡張機能のインストール

php には kafka を呼び出す 2 つの方法があります

    ##php-rdkafka
  • ドキュメント アドレス: https://arnaud -lb .github.io/php-rdkafka/phpdoc/book.rdkafka.html
rdkafka のインストールには librdkafka に依存する必要があるため、最初に librdkafka をインストールする必要があります

ダウンロード アドレス http://pecl.php.net/ package/rdkafka

git clone https://github.com/edenhill/librdkafka.git
cd librdkafka
./configure
make && make install

php-rdkafka 拡張機能をインストールします
git clone https://github.com/arnaud-lb/php-rdkafka.git
cd php-rdkafka
phpize
./configure --with-php-config=/usr/local/php7.0/bin/php-config
make && make install

次に、

extension = rdkafka.so


rdkafka phpのインストール方法 と記述します# php.ini の




rdkafka phpのインストール方法

rdkafka phpのインストール方法# kafka-php 拡張パッケージ

  • ドキュメント アドレス: https://github.com/weiboad/kafka-php

簡単な例

  • ジェネレータ
    <?php $rk = new RdKafka\Producer();
    $rk->setLogLevel(LOG_DEBUG);
    $rk->addBrokers("192.168.2.152");
    
    $topic = $rk->newTopic("shop");
    
    for ($i = 0; $i produce(RD_KAFKA_PARTITION_UA, 0, "发送信息: $i");
        $rk->poll(0);
    }
    
    while ($rk->getOutQLen() > 0) {
        $rk->poll(50);
    }
    
    ?>
  • コンシューマ
<?php $conf = new RdKafka\Conf();

$conf->set('group.id', 'myConsumerGroup');

$rk = new RdKafka\Consumer($conf);
$rk->addBrokers("192.168.2.150:9092");

$topicConf = new RdKafka\TopicConf();
$topicConf->set('auto.commit.interval.ms', 100);
$topicConf->set('offset.store.method', 'file');
$topicConf->set('offset.store.path', sys_get_temp_dir());
$topicConf->set('auto.offset.reset', 'smallest');

$topic = $rk->newTopic("shop", $topicConf);

// Start consuming partition 0
$topic->consumeStart(0, RD_KAFKA_OFFSET_STORED);

while (true) {
    $message = $topic->consume(0, 120*10000);
    switch ($message->err) {
        case RD_KAFKA_RESP_ERR_NO_ERROR:
        //没有错误打印信息
            var_dump($message);
            break;
        case RD_KAFKA_RESP_ERR__PARTITION_EOF:
            echo "等待接收信息\n";
            break;
        case RD_KAFKA_RESP_ERR__TIMED_OUT:
            echo "超时\n";
            break;
        default:
            throw new \Exception($message->errstr(), $message->err);
            break;
    }
}

?>


rdkafka phpのインストール方法推奨学習: 「

PHP ビデオ チュートリアル


以上がrdkafka phpのインストール方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

声明:
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。