Bagaimana untuk melaksanakan operasi baris gilir mesej dalam ThinkPHP6?

Dengan pembangunan Internet, senario aplikasi menjadi lebih dan lebih kompleks, dan keperluan prestasi menjadi lebih tinggi dan lebih tinggi. Baris Gilir Mesej ialah kaedah komunikasi tak segerak biasa yang boleh meningkatkan prestasi program dan kestabilan dalam senario konkurensi tinggi. Dalam bahasa PHP, rangka kerja ThinkPHP6 juga menyediakan sokongan baris gilir mesej Artikel ini akan memperkenalkan secara ringkas cara untuk melaksanakan operasi baris gilir mesej dalam ThinkPHP6.

1. Persediaan persekitaran

Pertama sekali, sebelum menggunakan baris gilir mesej, anda perlu memasang komponen atau pelayan baris gilir mesej. Di sini kami menggunakan RabbitMQ sebagai pelayan baris gilir mesej. Untuk memasang RabbitMQ, anda boleh merujuk kepada dokumentasi rasmi atau sumber dalam talian lain.

Kedua, dalam ThinkPHP6, anda boleh memasang komponen baris gilir mesej yang disediakan secara rasmi melalui komposer: think-amqp. Anda boleh menggunakan arahan berikut dalam terminal untuk memasang:

composer require topthink/think-amqp

2. Fail konfigurasi

Selepas memasang komponen, anda perlu membuat konfigurasi yang berkaitan dalam fail amqp.php dalam direktori konfigurasi. Contoh:

<?php
return [
    'default' => [
        'host'          => '127.0.0.1',
        'port'          => 5672,
        'vhost'         => '/',
        'login'         => 'guest',
        'password'      => 'guest',
        // 是否自动开启通道，默认为true
        'auto_declare'  => true,
        // 队列列表
        'queue_list'    => [
            'default'   => [
                'queue_name'    => 'default',
            ],
        ],
        // 交换机列表
        'exchange_list' => [
            'default'   => [
                'exchange_name' => 'default',
                // 默认使用direct交换机类型，也可以使用其他类型
                'exchange_type' => 'direct',
            ],
        ],
        // 绑定列表
        'bind_list'     => [
            'default'   => [
                'queue_name'    => 'default',
                'exchange_name' => 'default',
            ],
        ],
    ],
];

Dalam fail konfigurasi di atas, 'lalai' ialah nama sambungan, dan tatasusunan mengandungi maklumat sambungan, senarai baris gilir, senarai suis dan senarai mengikat. Dalam senarai baris gilir dan senarai suis, anda boleh menentukan berbilang baris gilir dan suis serta konfigurasi berkaitannya. Dalam senarai mengikat, anda boleh menentukan hubungan mengikat antara baris gilir dan suis.

Nota: Apabila menggunakan nama baris gilir, menukar nama dan nama mengikat, anda perlu memastikan keunikannya.

3. Hantar mesej

Untuk menghantar mesej, anda boleh menggunakan kaedah pengeluar dalam kelas AMQP, contoh:

<?php
namespace appindexcontroller;

use thinkmqpAMQP;

class Index
{
    public function index()
    {
        $config = config('amqp.default');
        $exchange_name = 'default';
        $routing_key = 'default';
        $message = "hello world";
        $producer = AMQP::instance($config)->producer($exchange_name, $routing_key);
        $producer->publish($message);
        echo "send message success";
    }
}

Dalam kod di atas , $config ialah fail konfigurasi di atas Untuk maklumat sambungan 'lalai', $exchange_name ialah nama suis, $routing_key ialah kunci penghalaan dan $message ialah kandungan mesej.

4. Terima mesej

Untuk menerima mesej, anda perlu menggunakan kaedah pengguna dan kaedah penggunaan dalam kelas AMQP, contoh:

<?php
namespace appindexcontroller;

use thinkmqpAMQP;

class Index
{
    public function queue()
    {
        $config = config('amqp.default');
        $queue_name = 'default';
        $callback = function ($envelope, $queue) {
            $msg = $envelope->getBody();
            echo $msg."
";
            $queue->ack($envelope->getDeliveryTag());
        };
        $consumer = AMQP::instance($config)->consumer($queue_name);
        $consumer->consume($callback);
    }
}

Dalam kod di atas, $config ialah Untuk maklumat sambungan 'lalai' dalam fail konfigurasi di atas, $queue_name ialah nama baris gilir dan $callback ialah fungsi panggil balik. Dalam fungsi panggil balik, mula-mula dapatkan kandungan mesej, dan kemudian laksanakan kaedah ack untuk menunjukkan bahawa mesej telah digunakan.

5. Ringkasan

Di atas ialah contoh mudah menggunakan baris gilir mesej dalam ThinkPHP6. Melalui penggunaan baris gilir mesej, program boleh dipisahkan dan prestasi serta kestabilan sistem dapat dipertingkatkan. Untuk lebih banyak jenis baris gilir, mekanisme pengesahan mesej dan penyelesaian kelompok, anda boleh merujuk kepada dokumentasi rasmi untuk belajar dan memahami.

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan operasi baris gilir mesej dalam ThinkPHP6?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!