Как опубликовать множество сообщений в rabbitmq?

Question

[borodka_lenina]

Привет. Необходимо в очереди 'queue_example' опубликовать сообщение вида:
{ ID : $number}
Точнее надо опубликовать несколько сотен таких сообщений и в каждом переменная $number будет уникальна.
Как это сделать наиболее просто и быстро?
P.s. знаю что мог бы и сам разобраться, но требуется быстро найти решение и вникать просто нет времени(

Answer 1

[Владимир]

пример на Perl
чуть подредактировать, убрав все "$ch->consume...", вызывать publish в цикле.

нашел на пыхе используется php-amqp:

<?php
    $connection = new AMQPConnection(['host'=> '127.0.0.1', 'port' => '5672', 'login' => '', 'password' => '', 'vhost' => 'ejebberd', 'connect_timeout' => 10]);
    $connection->connect();
    $channel = new AMQPChannel($connection);

    $exchangename = IPhonParameters::$rabbit_EXCHANGE;
    $queue = 'ejabberd';
    $routing_key = 'ejabberd';

    $exchange = new AMQPExchange($channel);
    $exchange->setName($exchangename);
    $exchange->setType(AMQP_EX_TYPE_DIRECT);
    $exchange->setFlags(AMQP_DURABLE);
    $exchange->declareExchange();

    $q = new AMQPQueue($channel);
    $q->setName($queue);
    $q->setFlags(AMQP_DURABLE);
    $q->declareQueue();
    $q->bind($exchangename, $routing_key);

    for ($i = 1001; $i < 3001 ; $i++) {
        $aaa = sprintf('%04d', $i);
        $a_body = [
            'server' => 'default'
            , 'domain' => 'test.com'
            , 'action' => 'add'
            , 'login' => 'test'.$aaa
            , 'password' => 'test'.$aaa
        ];
        $msg_body = json_encode($a_body, JSON_UNESCAPED_UNICODE);
        $exchange->publish($msg_body, $routing_key, AMQP_NOPARAM, ['content_type' => 'text/javascript', 'delivery_mode' => 2]);
    }

    $connection->disconnect();
?>

Comments

[borodka_lenina]

А чуть попроще нет способа?) Я в перл вообще не умею
нашел вариант с rabbitmqadmin в оф доке, но не могу понять как подставить нужные переменные(Имя очереди и сообщение).

[Владимир]

отредактировал ответ