国产av日韩一区二区三区精品,成人性爱视频在线观看,国产,欧美,日韩,一区,www.成色av久久成人,2222eeee成人天堂

ホームページ PHP ライブラリ その他の図書館 php-rdkafkaクライアントライブラリ
php-rdkafkaクライアントライブラリ

これはメッセージを送受信できるクライアントです。送受信の操作をデモします。必要な友人はダウンロードして試してみてください。

メッセージ送信

<?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();
}


免責(zé)事項

このサイトのすべてのリソースはネチズンによって提供されたもの、または主要なダウンロード サイトによって転載されたものです。ソフトウェアの整合性をご自身で確認してください。このサイトのすべてのリソースは學(xué)習(xí)の參考のみを目的としています。商業(yè)目的で使用しないでください。そうでない場合は、すべての結(jié)果に対して責(zé)任を負うことになります。侵害がある場合は、削除するためにご連絡(luò)ください。連絡(luò)先情報: admin@php.cn

関連記事

cURL はどのように PHP での HTTP リクエストを容易にするのですか? cURL はどのように PHP での HTTP リクエストを容易にするのですか?

30 Nov 2024

cURL: PHP の HTTP リクエスト ハンドラー PHP 開発の分野では、「cURL」という用語が頻繁に登場します。それは図書館です...

2025年に知るべきトップ50のPythonライブラリ 2025年に知るべきトップ50のPythonライブラリ

16 Mar 2025

Python:AIとデータサイエンスの未來へのゲートウェイ Pythonの比類のない汎用性と読みやすさは、データサイエンス、機械學(xué)習(xí)、人工知能の優(yōu)先言語としてのステータスを固めています。 その広範(fàn)な図書館のエコシス

App Engine 上の Golang アプリケーションでパスワードを保護するにはどうすればよいですか? App Engine 上の Golang アプリケーションでパスワードを保護するにはどうすればよいですか?

30 Oct 2024

App Engine 上の Golang でパスワードを保護するWeb アプリケーションのパスワード ハッシュに関しては、セキュリティが最も重要です。人気の図書館ですが...

無料のjqueryオンラインエディター 無料のjqueryオンラインエディター

05 Mar 2025

JSFiddle:便利なオンラインjQueryコードエディター JSFiddleは、開発者がjQueryコードを書き、テスト、デバッグすることを促進する強力なオンラインエディターです。それは、HTML、CSS、およびJavaScript/jQueryコードの入力にそれぞれ使用され、結(jié)果をリアルタイムで表示するために使用されるスプリットスクリーンインターフェイスを使用します。これは、非個人的なコンピューターでコードをテストしたり、異なるjQueryバージョン間のコードの違いを比較したりするのに非常に役立ちます。 JQueryに加えて、Mootools、Prototype、Yui、Glow、Dojo、その他の図書館もサポートしています。 jsfiddleの例 JSFiddle FAQ JSFiddleおよびその他のオンライン

iTextSharp を使用してテキストの書式設(shè)定情報 (フォント、サイズなど) を抽出するにはどうすればよいですか? iTextSharp を使用してテキストの書式設(shè)定情報 (フォント、サイズなど) を抽出するにはどうすればよいですか?

11 Jan 2025

iTextSharp でテキストの書式設(shè)定を行うにはどうすればよいですか?はい、iTextSharp でテキストの書式設(shè)定を行うことができます。図書館では次のようなサービスを提供しています...

PINIAのコア概念を説明する:店、州、ゲッター、アクション。 PINIAのコア概念を説明する:店、州、ゲッター、アクション。

26 Mar 2025

この記事では、vue.jsの州管理図書館であるPiniaについて説明し、そのコアコンセプト、ストア、州、ゲッター、アクションに焦點を當(dāng)てています。 Piniaを使用するためのベストプラクティスを探索し、GettersをVue.js計算プロパティと対比し、強調(diào)します

See all articles