workerman/rabbitmq

workerman/rabbitmq একটি অভ্যন্তরীণ RabbitMQ ক্লায়েন্ট যা AMQP প্রোটোকল ব্যবহার করে।

প্রকল্পের ঠিকানা:

https://github.com/walkor/rabbitmq

ইনস্টলেশন:

composer require workerman/rabbitmq

উদাহরণ

কনজিউমার

টিপ
workerman >= v5.1 প্রয়োজন

• receive.php

<?php
declare(strict_types=1);

use Bunny\Channel;
use Bunny\Message;
use Workerman\Worker;
use Workerman\RabbitMQ\Client;

require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker();
$worker->eventLoop = \Workerman\Events\Fiber::class;

$worker->onWorkerStart = function() {
    // RabbitMQ ক্লায়েন্ট তৈরি করুন
    $client = Client::factory([
        'host' => '127.0.0.1',
        'port' => 5672,
        'user' => 'guest',
        'password' => 'guest',
        'vhost' => '/',
        'heartbeat' => 60,
        'heartbeat_callback' => function () {
            echo " [-] coroutine-consumer-heartbeat\n";
        },
        'interval' => [100, 300]
    ])->connect();
    $channel = $client->channel();
    $channel->queueDeclare('hello-coroutine');
    // কনজিউমার
    $channel->consume(function (Message $message, Channel $channel, \Bunny\AbstractClient $client) {
        echo " [>] গ্রহণ করা হয়েছে ", $message->content, "\n";
    },
        'hello-coroutine',
        '',
        false,
        true
    );
    $client->run();
    echo ' [*] বার্তার জন্য অপেক্ষা করা হচ্ছে। বের হতে CTRL+C চাপুন', "\n";
    // প্রযোজক
    \Workerman\Timer::add($interval = 5 , function () use ($channel) {
        $channel->publish($message = 'Hello World By Self Timer. ' . time(), [], '', 'hello-coroutine');
        echo " [<] পাঠানো হয়েছে $message\n";
    });
    echo " [!] প্রযোজক টায়мер তৈরি হয়েছে, সময়সীমা: $interval সেকেন্ড।\n";
};
Worker::runAll();

• কমান্ড রান করুন php receive.php start।

workerman পরিবেশে publish ব্যবহার করা

টিপ
workerman >= v5.1 প্রয়োজন

• send.php

<?php
declare(strict_types=1);

use Workerman\RabbitMQ\Client;
use Workerman\Worker;

require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker();
$worker->eventLoop = \Workerman\Events\Fiber::class;
$worker->onWorkerStart = function() {
    $client = Client::factory([
        'host' => 'host.docker.internal',
        'port' => 5672,
        'user' => 'guest',
        'password' => 'guest',
        'vhost' => '/',
        'heartbeat' => 60,
        'heartbeat_callback' => function () {
            echo "coroutine-producer-heartbeat\n";
        }
    ])->connect();
    $channel = $client->channel();
    $channel->queueDeclare('hello-coroutine');
    // প্রতি 5 সেকেন্ডে একটি বার্তা পাঠান
    \Workerman\Timer::add(5, function () use ($channel) {
        $channel->publish($message = 'Hello World By Workerman Env Producer. ' . time(), [], '', 'hello-coroutine');
        echo " [x] পাঠানো হয়েছে '$message'\n";
    });
};
Worker::runAll();

• কমান্ড রান করুন php send.php start।

PHP-FPM অথবা PHP-CLI তে publish ব্যবহার করা

• script.php

<?php
declare(strict_types=1);

use Workerman\RabbitMQ\Client;

require_once __DIR__ . '/vendor/autoload.php';

$client = Client::factory([
    'host' => 'host.docker.internal',
    'port' => 5672,
    'user' => 'guest',
    'password' => 'guest',
    'vhost' => '/',
    'heartbeat' => 60,
    'heartbeat_callback' => function () {
        echo "coroutine-producer-heartbeat\n";
    }
])->connect();
$channel = $client->channel();
$channel->queueDeclare('hello-coroutine');
$res = $channel->publish($message = 'Hello World By Normal Producer. ' . time(), [], '', 'hello-coroutine');
echo " [x] পাঠানো হয়েছে '$message', সাফল্য: $res\n";

• কমান্ড রান করুন php script.php।

প্রমিজ অ asynchronous কনজিউমার

• receive.php

<?php

use Bunny\Channel;
use Bunny\Message;
use Workerman\Worker;
use Workerman\RabbitMQ\Client;

require __DIR__ . '/vendor/autoload.php';

$worker = new Worker();
$worker->onWorkerStart = function() {
    (new Client())->connect()->then(function (Client $client) {
        return $client->channel();
    })->then(function (Channel $channel) {
        return $channel->queueDeclare('hello', false, false, false, false)->then(function () use ($channel) {
            return $channel;
        });
    })->then(function (Channel $channel) {
        echo ' [*] বার্তার জন্য অপেক্ষা করা হচ্ছে। বের হতে CTRL+C চাপুন', "\n";
        $channel->consume(
            function (Message $message, Channel $channel, Client $client) {
                echo " [x] গ্রহণ করা হয়েছে ", $message->content, "\n";
            },
            'hello',
            '',
            false,
            true
        );
    });
};
Worker::runAll();

• কমান্ড রান করুন php receive.php start।

প্রমিজ অ asynchronous Publish

নোট: অ্যাসিনক্রোনাস উৎপাদনের কারণে অপ্রত্যাশিত/প্রক্রিয়া বন্ধের কারণে ডেটা হারাতে পারে

• send.php

<?php
use Bunny\Channel;
use Bunny\Message;
use Workerman\Worker;
use Workerman\RabbitMQ\Client;

require __DIR__ . '/vendor/autoload.php';

$worker = new Worker();
$worker->onWorkerStart = function() {
    (new Client())->connect()->then(function (Client $client) {
        return $client->channel();
    })->then(function (Channel $channel) {
        return $channel->queueDeclare('hello', false, false, false, false)->then(function () use ($channel) {
            return $channel;
        });
    })->then(function (Channel $channel) {
        echo " [x] পাঠানো হচ্ছে 'Hello World!'\n";
        return $channel->publish('Hello World!', [], '', 'hello')->then(function () use ($channel) {
            return $channel;
        });
    })->then(function (Channel $channel) {
        echo " [x] পাঠানো হয়েছে 'Hello World!'\n";
        $client = $channel->getClient();
        return $channel->close()->then(function () use ($client) {
            return $client;
        });
    })->then(function (Client $client) {
        $client->disconnect();
    });
};
Worker::runAll();

• কমান্ড রান করুন php send.php start।