bibliothèque cliente php-rdkafka

Il s'agit d'un client qui peut envoyer et recevoir des messages. Ci-dessous, je vais démontrer les opérations d'envoi et de réception. Les amis qui en ont besoin peuvent le télécharger et l'essayer.

Envoyer un message

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

Recevoir un message

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

Article connexe

Memcache vs Memcached : quelle bibliothèque PHP devriez-vous choisir ?

09Nov2024

Distinguer « Memcache » et « Memcached » dans PHPPHP propose deux bibliothèques memcached : memcache et memcached. Comprendre leurs différences aide...

Memcache vs Memcached : quelle bibliothèque PHP Memcached devriez-vous choisir ?

19Nov2024

Memcache vs Memcached : choisir la bonne bibliothèque PHP MemcachedIntroductionPHP propose deux bibliothèques Memcached apparemment similaires : memcache et...

PhpMailer vs SwiftMailer : quelle bibliothèque PHP est la meilleure pour vos besoins de messagerie ?

18Oct2024

PhpMailer vs SwiftMailer : comparaison des bibliothèques de messagerie Lors de la création d'un script PHP nécessitant une fonctionnalité de messagerie, les développeurs sont souvent confrontés au choix entre les bibliothèques PhpMailer et SwiftMailer. Prendre cette décision peut être crucial pour trouver le meilleur

Explication détaillée de la bibliothèque de fonctions PHP PDO

06Jan2017

PDO est une « couche d'abstraction d'accès à la base de données » qui unifie les interfaces d'accès de diverses bases de données. Comparé aux bibliothèques de fonctions de mysql et mysqli, PDO rend l'utilisation entre bases de données plus conviviale que ADODB et MDB2.

Memcache vs Memcached : quelle bibliothèque de mise en cache PHP devriez-vous choisir ?

12Nov2024

Memcache vs Memcached : choisir la bonne bibliothèque PHP pour vos besoins de cacheDans le domaine des bibliothèques de mise en cache PHP, Memcache et Memcached se démarquent...

Comment jQuery simplifie-t-il la manipulation du DOM pour les développeurs Web ?

03Jan2025

Overflow : Hidden and Expansion of HeightjQuery se distingue des autres bibliothèques JavaScript par sa compatibilité multiplateforme et...

See all articles