PHP melaksanakan SDK RabbitMQ sumber terbuka

RabbitMQ ialah baris gilir mesej berdasarkan protokol AMQP (Advanced Message Qeuing Protocol), yang digunakan secara meluas dalam senario seperti penyahgandingan dan pemprosesan tak segerak. Sebagai bahasa dinamik yang sangat popular, PHP juga mempunyai banyak SDK RabbitMQ sumber terbuka untuk dipilih. Artikel ini akan memperkenalkan cara melaksanakan RabbitMQ SDK sumber terbuka melalui PHP untuk memenuhi keperluan pembangunan harian setiap orang.

1 Sediakan persekitaran RabbitMQ

Sebelum memulakan pelaksanaan kod secara rasmi, anda perlu menyediakan persekitaran RabbitMQ terlebih dahulu. RabbitMQ menyokong pemasangan dan penggunaan pelbagai sistem Untuk butiran, sila rujuk dokumentasi rasmi: https://www.rabbitmq.com/install.html.

Untuk kemudahan, dalam artikel ini kami akan menggunakan docker untuk membina persekitaran RabbitMQ. Kelebihan menggunakan docker ialah ia boleh mengelakkan masalah yang disebabkan oleh persekitaran yang berbeza. Berikut ialah arahan untuk mencipta bekas RabbitMQ:

docker run -d --name rabbitmq -p 5672:5672 rabbitmq:3.7.14-management

2. Pasang sambungan PHP AMQP

Sebelum anda mula menggunakan RabbitMQ SDK, anda perlu memasang sambungan PHP AMQP. Ia boleh dipasang melalui arahan berikut:

sudo apt-get install php7.4-dev libpcre3-dev php-dev librabbitmq-dev

git clone https://github.com/alanxz/rabbitmq-c.git

cd rabbitmq-c && mkdir build && cd build

cmake ..

cmake --build .

sudo cmake --build . --target install

sudo pecl install amqp

echo "extension=amqp.so" >> /etc/php/7.4/mods-available/amqp.ini

sudo php -m | grep amqp

Setelah pemasangan selesai, anda boleh menggunakan sambungan AMQP dalam kod PHP anda.

3. Laksanakan RabbitMQ PHP SDK

Seterusnya kita mula melaksanakan RabbitMQ PHP SDK. Artikel ini akan memperkenalkan dua kaedah pelaksanaan: satu dilaksanakan dengan melanjutkan amqp melalui PHP, dan satu lagi dilaksanakan dengan menggunakan perpustakaan php-amqp yang disediakan secara rasmi.

1. pelaksanaan amqp

amqp ialah klien RabbitMQ dalam sambungan PHP yang menyokong penerbitan, penggunaan dan pengesahan perkhidmatan baris gilir. APInya agak mesra, ringkas dan mudah digunakan. Berikut ialah pengenalan ringkas tentang cara menggunakannya.

i. Menerbitkan mesej

Dalam sambungan amqp, gunakan kelas AMQPExchange untuk menerbitkan mesej. Berikut ialah contoh asas:

<?php
//连接RabbitMQ服务器
$conn = new AMQPConnection();
$conn->setHost('localhost');
$conn->setPort(5672);
$conn->setLogin('guest');
$conn->setPassword('guest');
$conn->connect();

//创建交换机
$ex = new AMQPExchange($conn);
$ex->setName('exchange-name');
$ex->setType(AMQP_EX_TYPE_DIRECT);
$ex->declare();

//发布消息
$message = 'Hello World!';
$ex->publish($message, 'routing-key');

//关闭连接
$conn->disconnect();
?>

ii Menggunakan mesej

Gunakan kelas AMQPQueue untuk menggunakan mesej. Berikut ialah contoh asas:

<?php
//连接RabbitMQ服务器
$conn = new AMQPConnection();
$conn->setHost('localhost');
$conn->setPort(5672);
$conn->setLogin('guest');
$conn->setPassword('guest');
$conn->connect();

//创建队列
$q = new AMQPQueue($conn);
$q->setName('queue-name');
$q->declare();

//绑定交换机
$q->bind('exchange-name', 'routing-key');

//消费消息
while (true) {
    $message = $q->get();
    if ($message) {
        echo $message->getBody() . PHP_EOL;
        $q->ack($message->getDeliveryTag());
    }
}

//关闭连接
$conn->disconnect();
?>

2. pelaksanaan perpustakaan php-amqp

php-amqp ialah perpustakaan PHP RabbitMQ yang disediakan secara rasmi Berbanding dengan sambungan amqp, bandingkan Mudah untuk digunakan. Berikut ialah pengenalan ringkas tentang cara menggunakannya.

i. Terbitkan mesej

Gunakan kelas AMQPChannel dan AMQPExchange untuk melaksanakan penerbitan mesej. Berikut ialah contoh asas:

<?php
//连接RabbitMQ服务器
$conn = new AMQPConnection();
$conn->setHost('localhost');
$conn->setPort(5672);
$conn->setLogin('guest');
$conn->setPassword('guest');
$conn->connect();

//创建通道和交换机
$channel = new AMQPChannel($conn);
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange-name');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declare();

//发布消息
$message = 'Hello World!';
$exchange->publish($message, 'routing-key');

//关闭连接
$conn->disconnect();
?>

ii Menggunakan mesej

Kelas AMQPQueue digunakan dalam perpustakaan php-amqp untuk melaksanakan penggunaan mesej. Berikut ialah contoh asas:

<?php
//连接RabbitMQ服务器
$conn = new AMQPConnection();
$conn->setHost('localhost');
$conn->setPort(5672);
$conn->setLogin('guest');
$conn->setPassword('guest');
$conn->connect();

//创建通道和队列
$channel = new AMQPChannel($conn);
$queue = new AMQPQueue($channel);
$queue->setName('queue-name');
$queue->declare();

//绑定交换机
$queue->bind('exchange-name', 'routing-key');

//消费消息
while (true) {
    $message = $queue->get();
    if ($message) {
        echo $message->getBody() . PHP_EOL;
        $queue->ack($message->getDeliveryTag());
    }
}

//关闭连接
$conn->disconnect();
?>

Pada ketika ini, kami telah berjaya melaksanakan pembinaan RabbitMQ PHP SDK.

4. Ringkasan

Artikel ini memperkenalkan secara ringkas cara melaksanakan RabbitMQ SDK sumber terbuka melalui PHP, daripada membina persekitaran RabbitMQ kepada memasang sambungan PHP AMQP kepada dua cara untuk melaksanakan SDK. Saya percaya pembaca Sudah mempunyai pemahaman dan keupayaan praktikal tertentu. Dalam pembangunan sebenar, memilih SDK yang sesuai boleh meningkatkan kecekapan pembangunan, membolehkan kami menyelesaikan tugasan dengan cepat dan cekap.

Atas ialah kandungan terperinci PHP melaksanakan SDK RabbitMQ sumber terbuka. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!