PHP と Kafka をメッセージングに使用する方法を学ぶ-PHPチュートリアル-php.cn

PHP と Kafka をメッセージングに使用する方法を学ぶ

PHPz

リリース： 2023-06-20 09:22:02

オリジナル

1589 人が閲覧しました

PHP は、サーバーサイド開発や Web アプリケーション開発によく使用される人気のあるプログラミング言語です。 Kafka は、大規模なメッセージングの管理に使用できる分散メッセージングシステムです。この記事では、メッセージングに PHP と Kafka を使用する方法を紹介します。

まず、必要なツールとライブラリをインストールする必要があります。 Linux では、次のコマンドを使用できます。

sudo apt-get install php-zmq librdkafka-dev

ログイン後にコピー

Windows システムを使用している場合は、関連するツールとライブラリを手動でダウンロードしてインストールする必要があります。

次に、PHP 用の ZeroMQ 拡張機能をインストールする必要があります。 Linux では、次のコマンドを使用できます。

sudo pecl install zmq-beta

ログイン後にコピー

Windows システムを使用している場合は、PHP 用の ZeroMQ 拡張機能を手動でダウンロードしてインストールする必要があります。

これらの準備が完了したら、メッセージングに PHP と Kafka の使用を開始できます。簡単な例を次に示します。

<?php

$conf = new RdKafkaConf();
$conf->set('metadata.broker.list', 'localhost:9092');

$producer = new RdKafkaProducer($conf);

$topic = $producer->newTopic("test");

for ($i = 0; $i < 10; $i++) {
    $message = "Message " . $i;
    $topic->produce(RD_KAFKA_PARTITION_UA, 0, $message);
}

$producer->flush(10000);

$consumerConf = new RdKafkaConf();
$consumerConf->set('metadata.broker.list', 'localhost:9092');
$consumerConf->set('group.id', 'testgroup');

$consumer = new RdKafkaKafkaConsumer($consumerConf);
$consumer->subscribe(['test']);

while (true) {
    $message = $consumer->consume(120 * 1000);

    switch ($message->err) {
        case RD_KAFKA_RESP_ERR_NO_ERROR:
            echo "Received message: " . $message->payload . "
";
            break;
        case RD_KAFKA_RESP_ERR__PARTITION_EOF:
            echo "End of partition
";
            break;
        case RD_KAFKA_RESP_ERR__TIMED_OUT:
            echo "Timed out
";
            break;
        default:
            echo "Error: " . $message->errstr() . "
";
            break;
    }

    $consumer->commit();
}

ログイン後にコピー

この例では、最初にプロデューサーを作成し、「test」という名前のトピックに 10 個のメッセージを送信します。次に、コンシューマを作成し、「テスト」トピックをサブスクライブしました。最後に、Kafka トピックから消費されるメッセージを受信する無限ループに入ります。

この例を実行すると、Kafka トピックから送信されたメッセージを継続的に受信し、コンソールに出力します。ループを終了したい場合は、Ctrl C キーの組み合わせを使用してプログラムを停止します。

この簡単な例では、メッセージングに PHP と Kafka を使用する方法を示します。このアプローチを学ぶと、大規模なメッセージングと処理をより適切に管理し、アプリケーションの堅牢性と信頼性を高めることができます。

以上がPHP と Kafka をメッセージングに使用する方法を学ぶの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。