Pemprosesan transaksi yang diedarkan menggunakan perkhidmatan RPC yang dibina dengan TP6 Think-Swoole

Gunakan perkhidmatan RPC yang dibina dengan TP6 Think-Swoole untuk melaksanakan pemprosesan transaksi teragih

Sistem teragih menjadi semakin biasa dalam aplikasi Internet moden. Walau bagaimanapun, pemprosesan transaksi teragih merupakan satu cabaran untuk mencapai konsistensi dalam persekitaran teragih. Apabila berurusan dengan logik perniagaan yang kompleks merentas pelbagai perkhidmatan, memastikan ketekalan dan kebolehpercayaan data menjadi sangat penting.

Dalam artikel ini, kami akan menggunakan ThinkPHP 6 dan Swoole untuk membina perkhidmatan RPC (Remote Procedure Call, remote procedure call) dan melaksanakan pemprosesan transaksi teragih melalui perkhidmatan ini. Kami akan membincangkan cara membuat perkhidmatan RPC asas dan menunjukkan cara melaksanakan operasi transaksi melaluinya.

1. Tinjauan Keseluruhan Senibina

Kami akan menggunakan seni bina berikut untuk melaksanakan pemprosesan transaksi teragih:

• Aplikasi Utama (Pelanggan): Ia adalah aplikasi teras kami, bertanggungjawab untuk memproses logik perniagaan dan memproses transaksi yang diedarkan.
• Sub-aplikasi (Pelayan): Ia adalah pembekal perkhidmatan RPC kami dan bertanggungjawab untuk menerima dan melaksanakan permintaan panggilan jauh.
• Pangkalan Data: Kami menggunakan MySQL sebagai enjin storan pangkalan data.

2. Pasang ThinkPHP 6

Mula-mula, kita perlu memasang ThinkPHP 6. Pemasangan boleh diselesaikan melalui Composer, jalankan arahan berikut:

composer create-project topthink/think=6.* myproject

3. Pasang sambungan Swoole

Untuk menggunakan pemalam Swoole ThinkPHP, kami juga perlu memasang sambungan Swoole. Panduan pemasangan boleh didapati di laman web rasmi Swoole.

4. Mengkonfigurasi pemalam Swoole

Dalam ThinkPHP 6, pemalam Swoole disediakan sebagai sambungan. Kami perlu mengkonfigurasinya dalam fail konfigurasi aplikasi config/app.php. Cari coretan kod berikut: config/app.php中进行配置。找到以下代码段：

return [
    // ...
    'ext' => [
        // ...
    ],
    // ...
];

在ext数组中加入thinkswooleSwoole即可，如下所示：

return [
    // ...
    'ext' => [
        thinkswooleSwoole::class,
    ],
    // ...
];

5. 创建RPC服务

在ThinkPHP 6中，我们可以使用中间件来实现RPC服务。创建一个新的中间件类，在app/middleware目录下创建一个名为RpcMiddleware.php的文件，并在其中编写以下代码：

<?php

namespace appmiddleware;

use SwooleCoroutine;
use thinkswoolepcserverResponse;
use thinkswoolepcserverReceiveContext;
use thinkswooleRpc;

class RpcMiddleware
{
    public function handle(ReceiveContext $context, Closure $next)
    {
        // 执行远程过程调用
        $response = new Response();
        $rpc = new Rpc();
        $rpc->dispatch($context->getRaw(), $response);
        // 获取执行结果
        $result = $response->getMessage();

        if ($response->getCode() === Rpc::RESULT_CODE_SUCCESS) {
            // 执行成功，将结果返回给客户端
            $context->reply($result);
        } else {
            // 出现错误，设置错误代码和消息
            $context->setCode($response->getCode());
            $context->setMessage($response->getMessage());
        }

        return $next($context);
    }
}

6. 配置RPC服务

在ThinkPHP 6中，我们可以通过配置文件来定义中间件。打开config/middleware.php文件，并添加要使用的中间件类，如下所示：

return [
    // ...
    // rpc服务中间件
    appmiddlewareRpcMiddleware::class,
];

然后，我们需要在config/swoole.php文件中进行一些额外的配置。找到以下代码段：

return [
    // ...
    'rpc' => [
        // ...
    ],
    // ...
];

在rpc数组中添加以下代码：

return [
    // ...
    'rpc' => [
        'server' => [
            // 绑定服务地址和端口
            'host' => '127.0.0.1',
            'port' => 9502,
        ],
        'services' => [
            // 注册服务
            'AppRpcServicesTransactionService',
        ],
    ],
    // ...
];

7. 创建事务服务

我们将创建一个名为TransactionService的服务类，用于处理分布式事务。在app/rpc/services目录下创建一个名为TransactionService.php的文件，并在其中编写以下代码：

<?php

namespace apppcservices;

use thinkswoolepcRequest;
use thinkswoolepcResponse;

class TransactionService
{
    public function beginTransaction(Request $request, Response $response)
    {
        // 执行事务开始操作
        // ...

        $response->setCode(Response::CODE_SUCCESS);
        $response->setMessage('事务开始成功');
    }

    public function commit(Request $request, Response $response)
    {
        // 执行事务提交操作
        // ...

        $response->setCode(Response::CODE_SUCCESS);
        $response->setMessage('事务提交成功');
    }

    public function rollback(Request $request, Response $response)
    {
        // 执行事务回滚操作
        // ...

        $response->setCode(Response::CODE_SUCCESS);
        $response->setMessage('事务回滚成功');
    }
}

8. 调用RPC服务

最后，我们将在主应用中调用RPC服务来执行分布式事务处理。创建一个新的控制器类，在app/controller目录下创建一个名为TransactionController.php的文件，并在其中编写以下代码：

<?php

namespace appcontroller;

use thinkacadeRpc;
use thinkswoolepcRequest;

class TransactionController
{
    public function beginTransaction()
    {
        // 创建RPC请求
        $request = new Request();
        $request->setService('AppRpcServicesTransactionService');
        $request->setMethod('beginTransaction');

        // 发起远程调用
        $result = Rpc::call($request);

        // 处理返回结果
        if ($result->getCode() === 200) {
            // 操作成功
            return '事务开始成功';
        } else {
            // 操作失败
            throw new Exception($result->getMessage(), $result->getCode());
        }
    }

    public function commit()
    {
        // 创建RPC请求
        $request = new Request();
        $request->setService('AppRpcServicesTransactionService');
        $request->setMethod('commit');

        // 发起远程调用
        $result = Rpc::call($request);

        // 处理返回结果
        if ($result->getCode() === 200) {
            // 操作成功
            return '事务提交成功';
        } else {
            // 操作失败
            throw new Exception($result->getMessage(), $result->getCode());
        }
    }

    public function rollback()
    {
        // 创建RPC请求
        $request = new Request();
        $request->setService('AppRpcServicesTransactionService');
        $request->setMethod('rollback');

        // 发起远程调用
        $result = Rpc::call($request);

        // 处理返回结果
        if ($result->getCode() === 200) {
            // 操作成功
            return '事务回滚成功';
        } else {
            // 操作失败
            throw new Exception($result->getMessage(), $result->getCode());
        }
    }
}

9. 测试RPC服务

现在我们可以使用浏览器或其他HTTP客户端测试我们的RPC服务了。在浏览器中访问/transaction/beginTransaction，/transaction/commit和/transaction/rollbackrrreee

Cuma tambah thinkswooleSwoole pada tatasusunan ext, seperti ditunjukkan di bawah:

rrreee

Buat perkhidmatan RPC🎜 🎜🎜Dalam ThinkPHP 6, kami boleh menggunakan perisian tengah untuk melaksanakan perkhidmatan RPC. Buat kelas middleware baharu, buat fail bernama RpcMiddleware.php dalam direktori app/middleware dan tulis kod berikut di dalamnya: 🎜rrreee
🎜Konfigurasikan perkhidmatan RPC🎜🎜🎜Dalam ThinkPHP 6, kami boleh menentukan perisian tengah melalui fail konfigurasi. Buka fail config/middleware.php dan tambah kelas middleware yang anda mahu gunakan seperti yang ditunjukkan di bawah: 🎜rrreee🎜 Kemudian, kita perlu menambah fail dalam config/swoole.php file Buat beberapa konfigurasi tambahan. Cari coretan kod berikut: 🎜rrreee🎜Tambahkan kod berikut dalam tatasusunan <code>rpc: 🎜rrreee
🎜Buat Perkhidmatan Transaksi🎜🎜🎜Kami akan membuat kelas perkhidmatan yang dipanggil TransactionService , digunakan untuk memproses transaksi yang diedarkan. Buat fail bernama TransactionService.php dalam direktori app/rpc/services dan tulis kod berikut di dalamnya: 🎜rrreee
🎜 Memanggil Perkhidmatan RPC🎜🎜🎜Akhir sekali, kami akan memanggil perkhidmatan RPC dalam aplikasi utama untuk melakukan pemprosesan transaksi teragih. Cipta kelas pengawal baharu, buat fail bernama TransactionController.php dalam direktori app/controller dan tulis kod berikut di dalamnya: 🎜rrreee
🎜Menguji perkhidmatan RPC🎜🎜🎜Kini kami boleh menguji perkhidmatan RPC kami menggunakan pelayar atau klien HTTP lain. Akses laluan /transaction/beginTransaction, /transaction/commit dan /transaction/rollback dalam penyemak imbas untuk mencetuskan permulaan transaksi dalam RPC perkhidmatan masing-masing , komit dan operasi balik. Jika operasi berjaya, anda akan melihat mesej Kejayaan Operasi. 🎜🎜Ini adalah proses asas untuk melaksanakan pemprosesan transaksi teragih menggunakan perkhidmatan RPC yang dibina oleh TP6 Think-Swoole. Melalui perkhidmatan RPC, kami boleh mengendalikan operasi transaksi yang kompleks dalam persekitaran yang diedarkan dan memastikan ketekalan dan kebolehpercayaan data. 🎜

Atas ialah kandungan terperinci Pemprosesan transaksi yang diedarkan menggunakan perkhidmatan RPC yang dibina dengan TP6 Think-Swoole. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!