Gute Neuigkeiten! DTM Distributed Transaction Manager PHP Coroutine Client v0.1 Betaversion veröffentlicht! ! !
→ github.com/dtm-php/dtm-client

Einführung

dtm/dtm-client ist der PHP-Client des Distributed Transaction Manager DTM, der bereits den TCC-Modus, Saga und zweiphasige Nachrichten unterstützt Modus. Verteilter Transaktionsmodus und realisiert die Kommunikation mit dem DTM-Server über das HTTP-Protokoll bzw. das gRPC-Protokoll. Der Client kann sicher in PHP-FPM- und Swoole-Coroutine-Umgebungen ausgeführt werden und bietet außerdem benutzerfreundlichere funktionale Unterstützung für Hyperf. [Empfohlen: PHP-Video-Tutorial]

Über DTM

DTM ist ein verteilter Open-Source-Transaktionsmanager, der auf der Go-Sprache basiert und leistungsstarke Funktionen zum Kombinieren von Transaktionen über Sprachen und Speicher-Engines hinweg bietet. DTM löst auf elegante Weise verteilte Transaktionsprobleme wie Idempotenz, Nullkompensation und Aussetzung und bietet außerdem eine einfach zu verwendende, leistungsstarke und einfach horizontal erweiterbare Lösung für verteilte Transaktionen.

Highlights

• Einfacher Einstieg
  • Startdienst ohne Konfiguration, der eine sehr einfache HTTP-Schnittstelle bietet und die Schwierigkeit beim Einstieg in verteilte Transaktionen erheblich reduziert
• Sprachübergreifend
  • Geeignet für Unternehmen mit mehreren -Sprachstapel. Bequeme Verwendung von Go, Python, PHP, NodeJs, Ruby, C# und anderen Sprachen.
• Einfach zu verwenden
  • Entwickler müssen sich keine Sorgen mehr über verschiedene Probleme wie Hängenbleiben, Nullkompensation, Potenzierung usw. machen. Die erste Subtransaktionsbarriere-Technologie erledigt das für Sie
• Einfach bereitzustellen und zu erweitern
  • Nur basiert auf MySQL/Redis, einfache Bereitstellung, einfach zu gruppieren, einfach horizontal zu erweitern
• Unterstützung mehrerer verteilter Transaktionsprotokolle
  • TCC, SAGA,

Vergleich In Nicht-Java-Sprachen gibt es außer DTM keinen ausgereiften verteilten Transaktionsmanager, daher hier ein Vergleich zwischen DTM und Seata, dem ausgereiftesten Open-Source-Projekt in Java:

Den oben verglichenen Merkmalen nach zu urteilen, hat DTM in vielerlei Hinsicht große Vorteile. Wenn Sie mehrsprachige Unterstützung und Multi-Storage-Engine-Unterstützung in Betracht ziehen, ist DTM zweifellos Ihre erste Wahl.

Installation

Die Installation des DTM-Clients über Composer ist sehr praktisch der DTM-Server, wenn er verwendet wird Oh

Wenn Sie ihn im Hyperf-Framework verwenden, können Sie nach der Installation der Komponente den folgenden vendor:publishverwenden > Befehl zum Veröffentlichen der Konfigurationsdatei in einem Stück ./config/autoload/dtm.php

composer require dtm/dtm-client

Nach dem Login kopieren

use DtmClient\Constants\Protocol;
use DtmClient\Constants\DbType;

return [
    // 客户端与 DTM Server 通讯的协议，支持 Protocol::HTTP 和 Protocol::GRPC 两种
    'protocol' => Protocol::HTTP,
    // DTM Server 的地址
    'server' => '127.0.0.1',
    // DTM Server 的端口
    'port' => [
        'http' => 36789,
        'grpc' => 36790,
    ],
    // 子事务屏障配置
    'barrier' => [
        // DB 模式下的子事务屏障配置
        'db' => [
            'type' => DbType::MySQL
        ],
        // Redis 模式下的子事务屏障配置
        'redis' => [
            // 子事务屏障记录的超时时间
            'expire_seconds' => 7 * 86400,
        ],
        // 非 Hyperf 框架下应用子事务屏障的类
        'apply' => [],
    ],
    // HTTP 协议下 Guzzle 客户端的通用配置
    'guzzle' => [
        'options' => [],
    ],
];

如果您是在非 Hyperf 框架中使用，可复制 ./vendor/dtm/dtm-client/publish/dtm.php 文件到对应的配置目录中。

<?php
namespace App\Controller;

use DtmClient\TCC;
use DtmClient\TransContext;
use Hyperf\Di\Annotation\Inject;
use Hyperf\HttpServer\Annotation\Controller;
use Hyperf\HttpServer\Annotation\GetMapping;
use Throwable;

#[Controller(prefix: &#39;/tcc&#39;)]
class TccController
{

    protected string $serviceUri = &#39;http://127.0.0.1:9501&#39;;

    #[Inject]
    protected TCC $tcc;

    #[GetMapping(path: &#39;successCase&#39;)]
    public function successCase()
    {
        try {

            $this->tcc->globalTransaction(function (TCC $tcc) {
                // 创建子事务 A 的调用数据
                $tcc->callBranch(
                    // 调用 Try 方法的参数
                    [&#39;amount&#39; => 30],
                    // Try 方法的 URL
                    $this->serviceUri . &#39;/tcc/transA/try&#39;,
                    // Confirm 方法的 URL
                    $this->serviceUri . &#39;/tcc/transA/confirm&#39;,
                    // Cancel 方法的 URL
                    $this->serviceUri . &#39;/tcc/transA/cancel&#39;
                );
                // 创建子事务 B 的调用数据，以此类推
                $tcc->callBranch(
                    [&#39;amount&#39; => 30],
                    $this->serviceUri . &#39;/tcc/transB/try&#39;,
                    $this->serviceUri . &#39;/tcc/transB/confirm&#39;,
                    $this->serviceUri . &#39;/tcc/transB/cancel&#39;
                );
            });
        } catch (Throwable $e) {
            var_dump($e->getMessage(), $e->getTraceAsString());
        }
        // 通过 TransContext::getGid() 获得 全局事务ID 并返回
        return TransContext::getGid();
    }
}

配置中间件

在使用之前，需要配置 DtmClientMiddlewareDtmMiddlewareMiddleware konfigurieren

Informationen zur Middleware-Konfiguration in Hyperf finden Sie im Kapitel Hyperf-Dokumentation – Middleware.

Verwendung

Bevor Sie diese Komponente verwenden, wird außerdem dringend empfohlen, die offizielle DTM-Dokumentation zu lesen, um ein detaillierteres Verständnis zu erhalten.

TCC-Modus

Der TCC-Modus ist eine sehr beliebte flexible Transaktionslösung. Das Konzept von TCC besteht aus den Akronymen Try-Confirm-Cancel. Es wurde erstmals 2007 von Pat Helland veröffentlicht. Vorgeschlagen in einem Artikel mit dem Titel „Life über verteilte Transaktionen hinaus: die Meinung eines Abtrünnigen“. 3 Phasen von TCC Stufe bestätigen. Bestätigen führt das Geschäft tatsächlich ohne Geschäftsprüfungen aus und verwendet nur die in der Versuchsphase reservierten Geschäftsressourcen. Abbruchphase: Wenn einer der Versuche aller Zweige fehlschlägt, geht es zur Abbruchphase über. Abbrechen gibt die während der Testphase reservierten Geschäftsressourcen frei. Wenn wir ein Geschäft ähnlich einer Interbank-Überweisung durchführen möchten, befinden sich die Überweisung (TransOut) und die Überweisung (TransIn) in unterschiedlichen Microservices. Das typische Sequenzdiagramm einer erfolgreich abgeschlossenen TCC-Transaktion sieht wie folgt aus:

Das Folgende zeigt, wie man es im Hyperf-Framework verwendet. Andere Frameworks sind ähnlich beliebt in wichtigen Systemen, erschien erstmals 1987 in der Veröffentlichung SAGAS von Hector Garcaa-Molrna und Kenneth Salem.

Saga ist eine schließlich konsistente Transaktion und eine flexible Transaktion, die auch als Langzeittransaktion bezeichnet wird und aus einer Reihe lokaler Transaktionen besteht. Nachdem jede lokale Transaktion die Datenbank aktualisiert, veröffentlicht sie eine Nachricht oder ein Ereignis, um die Ausführung der nächsten lokalen Transaktion in der globalen Saga-Transaktion auszulösen. Wenn eine lokale Transaktion fehlschlägt, weil einige Geschäftsregeln nicht erfüllt werden können, führt Saga Ausgleichsvorgänge für alle Transaktionen durch, die vor der fehlgeschlagenen Transaktion erfolgreich festgeschrieben wurden. Daher wird es beim Vergleich des Saga-Modus mit dem TCC-Modus oft schwieriger, eine Rollback-Logik zu implementieren, da keine Schritte zur Ressourcenreservierung vorhanden sind.

Saga-Untertransaktionsaufteilung

Zum Beispiel möchten wir ein Geschäft ähnlich einer Interbank-Überweisung durchführen und 30 Yuan von Konto A auf Konto B überweisen. Nach dem Prinzip der Saga-Transaktionen teilen wir das Ganze auf globale Transaktion Für die folgenden Dienste:

Transferservice, hier wird das B-Konto um 30 Yuan erhöht

Die Logik der gesamten Transaktion ist:
Überweisung erfolgreich ausführen => Übertragung erfolgreich ausführen => Die globale Transaktion ist abgeschlossen
Wenn in der Mitte ein Fehler auftritt, z. B. ein Fehler bei der Übertragung auf Konto B, wird die Kompensationsoperation der ausgeführten Verzweigung aufgerufen :
Transfer erfolgreich ausführen => Transfer in konnte nicht ausgeführt werden => Erfolgreich ausgeführter Transfer in Kompensation => Erfolgreich ausgeführter Transfer in Kompensation => Globales Transaktions-Rollback abgeschlossen
Das Folgende ist ein typisches Zeitdiagramm einer erfolgreich abgeschlossenen SAGA-Transaktion:

代码示例

以下展示在 Hyperf 框架中的使用方法，其它框架类似

namespace App\Controller;

use DtmClient\Saga;
use DtmClient\TransContext;
use Hyperf\Di\Annotation\Inject;
use Hyperf\HttpServer\Annotation\Controller;
use Hyperf\HttpServer\Annotation\GetMapping;

#[Controller(prefix: '/saga')]
class SagaController
{

    protected string $serviceUri = 'http://127.0.0.1:9501';

    #[Inject]
    protected Saga $saga;

    #[GetMapping(path: 'successCase')]
    public function successCase(): string
    {
        $payload = ['amount' => 50];
        // 初始化 Saga 事务
        $this->saga->init();
        // 增加转出子事务
        $this->saga->add(
            $this->serviceUri . '/saga/transOut', 
            $this->serviceUri . '/saga/transOutCompensate', 
            $payload
        );
        // 增加转入子事务
        $this->saga->add(
            $this->serviceUri . '/saga/transIn', 
            $this->serviceUri . '/saga/transInCompensate', 
            $payload
        );
        // 提交 Saga 事务
        $this->saga->submit();
        // 通过 TransContext::getGid() 获得 全局事务ID 并返回
        return TransContext::getGid();
    }
}

Das obige ist der detaillierte Inhalt von[DTM] Die Betaversion des PHP-Coroutine-Clients v0.1 ist veröffentlicht!. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!