Bagaimana untuk menggunakan perkhidmatan mikro untuk melaksanakan pemprosesan serentak fungsi PHP?

Bagaimana untuk menggunakan perkhidmatan mikro untuk melaksanakan pemprosesan serentak fungsi PHP?

Seni bina perkhidmatan mikro secara beransur-ansur menjadi gaya seni bina perisian yang popular dalam beberapa tahun kebelakangan ini. Ia membahagikan aplikasi yang kompleks kepada berbilang perkhidmatan bebas. Setiap perkhidmatan boleh dibangunkan, digunakan dan Sambungan. Kelebihan penting gaya seni bina ini ialah keupayaan untuk mencapai pemprosesan serentak, iaitu keupayaan untuk memproses berbilang permintaan pada masa yang sama, meningkatkan prestasi dan pemprosesan. Dalam artikel ini, kami akan meneroka cara menggunakan perkhidmatan mikro untuk melaksanakan pemprosesan serentak fungsi PHP dan menyediakan contoh kod khusus.

1. Membina infrastruktur perkhidmatan mikro
   Pertama sekali, kita perlu membina seni bina perkhidmatan mikro asas. Kami boleh menggunakan mana-mana rangka kerja perkhidmatan mikro yang kami suka, seperti Laravel, Symfony, dsb. Dalam contoh ini, kami memilih untuk menggunakan Laravel sebagai rangka kerja pembentangan.
2. Define Microservices
   Seterusnya, kita perlu menentukan satu atau lebih perkhidmatan mikro, setiap perkhidmatan mikro bertanggungjawab untuk fungsi tertentu. Dalam contoh ini, kami mentakrifkan dua perkhidmatan mikro: Perkhidmatan mikro pengguna dan perkhidmatan mikro Pesanan.
3. Menulis Perkhidmatan Mikro Pengguna
   Pertama, kami menulis kod perkhidmatan mikro Pengguna. Perkhidmatan mikro pengguna bertanggungjawab untuk mengendalikan semua fungsi yang berkaitan dengan pengguna, seperti pendaftaran pengguna, log masuk pengguna, dll. Berikut ialah contoh kod teras perkhidmatan mikro Pengguna:

<?php

namespace AppServices;

class UserService
{
    public function register($userData)
    {
        // 处理用户注册逻辑
    }

    public function login($userData)
    {
        // 处理用户登录逻辑
    }
}

4. Menulis perkhidmatan mikro Pesanan
   Seterusnya, kami menulis kod untuk perkhidmatan mikro Pesanan. Perkhidmatan mikro pesanan bertanggungjawab untuk mengendalikan semua fungsi berkaitan pesanan, seperti membuat pesanan, membatalkan pesanan, dsb. Berikut ialah contoh kod teras bagi perkhidmatan mikro Pesanan:

<?php

namespace AppServices;

class OrderService
{
    public function create($orderData)
    {
        // 处理创建订单逻辑
    }

    public function cancel($orderId)
    {
        // 处理取消订单逻辑
    }
}

5. Melaksanakan komunikasi antara perkhidmatan mikro
   Untuk mencapai komunikasi dan pemprosesan serentak antara perkhidmatan mikro, kita boleh Gunakan baris gilir mesej. Dalam contoh ini, kami memilih untuk menggunakan RabbitMQ sebagai baris gilir mesej. Kami boleh mengintegrasikan RabbitMQ dengan mudah menggunakan fungsi baris gilir Laravel.

Pertama, kita perlu memasang pakej sambungan RabbitMQ:

composer require vladimir-yuldashev/laravel-queue-rabbitmq

Kemudian, kita perlu mengkonfigurasi sambungan RabbitMQ dalam Laravel:

// .env文件中添加如下配置
...
RABBITMQ_HOST=127.0.0.1
RABBITMQ_PORT=5672
RABBITMQ_VHOST=/
RABBITMQ_LOGIN=guest
RABBITMQ_PASSWORD=guest
RABBITMQ_QUEUE=test
RABBITMQ_EXCHANGE_NAME=test
...

<?php

namespace AppServices;

use AppJobsSendEmailJob;

class UserService
{
    public function register($userData)
    {
        // 处理用户注册逻辑

        // 将发送邮件的任务放入消息队列中
        SendEmailJob::dispatch($userData['email']);
    }
}

<?php

namespace AppJobs;

use IlluminateBusQueueable;
use IlluminateContractsQueueShouldQueue;
use IlluminateFoundationBusDispatchable;
use IlluminateQueueInteractsWithQueue;
use IlluminateQueueSerializesModels;

class SendEmailJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $email;

    /**
     * Create a new job instance.
     *
     * @param string $email
     */
    public function __construct($email)
    {
        $this->email = $email;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        // 发送邮件的逻辑
    }
}

php artisan queue:work

Concurrency pemprosesan Concurrency
6. Sekarang kami telah melengkapkan definisi perkhidmatan mikro dan konfigurasi baris gilir mesej, kami boleh menggunakan contoh berikut untuk menyediakan perkhidmatan mikro pengguna Hantar permintaan pendaftaran dan perkhidmatan mikro pesanan menghantar permintaan cipta pesanan untuk mencapai pemprosesan serentak:
   

<?php

use AppServicesUserService;
use AppServicesOrderService;

// 创建用户微服务实例
$userService = new UserService();

// 创建订单微服务实例
$orderService = new OrderService();

// 发送注册请求
$userService->register($userData);

// 发送创建订单请求
$orderService->create($orderData);

Salin selepas log masuk
Contoh di atas akan menghantar permintaan pendaftaran dan membuat pesanan permintaan pada masa yang sama, dan melaksanakan pemprosesan serentak melalui baris gilir mesej. Selepas permintaan pendaftaran dan permintaan penciptaan pesanan diletakkan dalam baris gilir mesej, pekerja baris gilir Laravel akan mengalih keluar tugas daripada baris gilir dan melaksanakannya.
Melalui langkah di atas, kami berjaya menggunakan perkhidmatan mikro untuk melaksanakan pemprosesan serentak fungsi PHP. Seni bina perkhidmatan mikro boleh meningkatkan prestasi dan pemprosesan aplikasi dengan sangat baik dan merupakan penyelesaian yang berkesan untuk membangunkan aplikasi konkurensi tinggi.

Atas ialah kandungan terperinci Bagaimana untuk menggunakan perkhidmatan mikro untuk melaksanakan pemprosesan serentak fungsi PHP?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!