Laksanakan baris gilir mesej menggunakan ThinkPHP6

Dengan kemunculan Internet dan era data besar, baris gilir mesej telah menjadi bahagian yang sangat diperlukan dalam pembangunan perniagaan dan pemprosesan data. Dalam bidang PHP, rangka kerja ThinkPHP sentiasa menjadi pilihan popular di kalangan pembangun. Artikel ini akan memperkenalkan cara menggunakan ThinkPHP6 untuk melaksanakan baris gilir mesej dan memberikan anda beberapa contoh kod praktikal.

1. Pasang sambungan baris gilir mesej

Sebelum kita mula membuat baris gilir mesej, kita perlu memasang sambungan baris gilir mesej (seperti RabbitMQ atau Beanstalkd). Artikel ini mengambil RabbitMQ sebagai contoh Berikut ialah langkah pemasangan:

1.1 Pasang Erlang

RabbitMQ dibangunkan dalam bahasa Erlang, jadi Erlang perlu dipasang terlebih dahulu.

1.2 Pasang RabbitMQ

Sebelum memasang RabbitMQ, anda perlu memasang alat wget dan gnupg. Jalankan arahan berikut dalam terminal:

sudo apt-get install wget gnupg -y

Kemudian muat turun dan pasang RabbitMQ: <. 🎜>

wget -O - "https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey" | sudo apt-key add -
sudo tee /etc/apt/sources.list.d/bintray.rabbitmq.list <<EOF
deb https://dl.bintray.com/rabbitmq-erlang/debian buster erlang
deb https://dl.bintray.com/rabbitmq/debian buster main
EOF
sudo apt-get update -y
sudo apt-get install rabbitmq-server -y

Buat baris gilir dan pengguna

    'worker' => [
        'type'  => 'socket',   // 驱动方式
        'host'  => '0.0.0.0',  // 监听地址
        'port'  => 2345,       // 监听端口
    ],

rreee

Run Worker

    'worker' => [
        'type'      => 'rabbitmq',
        'host'      => 'localhost',
        'port'      => 5672,
        'user'      => 'guest',
        'password'  => 'guest',
        'vhost'     => '/',
        'exchange'  => 'test',  // 交换机名称
        'queue'     => 'test',  // 队列名称
    ],

Salin selepas log masuk
Menguji baris gilir mesej

4. Jalankan arahan berikut dalam terminal pertama untuk menolak mesej ke baris gilir:

namespace appcontroller;

use thinkworkerServer;

class Task extends Server
{
    public function send()
    {
        $data = ['name'=>'ThinkPHP','score'=>100];
        $this->worker->push(json_encode($data));
    }
}

Salin selepas log masuk

namespace appcontroller;

use thinkworkerServer;

class Worker extends Server
{
    public function onMessage($connection, $data)
    {
        // 处理逻辑
    }
}

Atas ialah kandungan terperinci Laksanakan baris gilir mesej menggunakan ThinkPHP6. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!