Oracle Blockchain Platform in global verteilte Transaktionen einschließen

Oracle Blockchain Platform in global verteilte Transaktionen einbeziehen

Möglicherweise muss Ihre Anwendung auf atomare Weise Aktualisierungen im Oracle Blockchain Platform-Ledger und in anderen Repositorys wie Datenbanken oder anderen Blockchain-Ledgern vornehmen, bei denen entweder alle Aktualisierungen erfolgreich oder nicht erfolgreich sind.

Um atomare Updates über mehrere Datenbanken hinweg zu ermöglichen, verwenden Entwickler globale Transaktionen, die von verteilten Transaktionskoordinatoren wie Oracle WebLogic Server, Oracle Tuxedo, Oracle Transaction Manager for Microservices, JBoss Enterprise Application Platform, IBM WebSphere und anderen Systemen koordiniert werden. Alle diese Systeme basieren auf dem X/Open XA-Protokoll, um einen zweiphasigen Commit-Prozess mit Standard-APIs zu orchestrieren, die von XA Resource Managers (RMs) für jede Datenbank oder andere Ressource bereitgestellt werden. Oracle Blockchain Platform unterstützt Zwei-Phasen-Commits und stellt eine eigene XA-RM-Bibliothek bereit, mit der externe Transaktionskoordinatoren XA-konforme APIs aufrufen können. Diese globalen Transaktionen können auch eine einzelne Nicht-XA-Ressource (z.B. ein Nicht-Oracle-Blockchain-Ledger oder eine nicht XA-konforme Datenbank) enthalten, indem eine letzte Ressourcen-Commit-Optimierung verwendet wird.

Die XA-Spezifikation ist Teil der X/Open Distributed Transaction Processing-Architektur, die eine Standardarchitektur definiert, mit der mehrere Anwendungsprogramme Ressourcen gemeinsam nutzen können, die von mehreren Ressourcenmanagern bereitgestellt werden. Die Java XA-Schnittstelle selbst wird als Teil der Java-Plattform definiert. Weitere Informationen zur Java XA-Schnittstelle finden Sie in der Java-Dokumentation unter Schnittstelle XAResource.

Oracle Blockchain Platform stellt eine Library bereit, die der XA-Spezifikation entspricht und die Java-Standardschnittstelle für einen XA-Ressourcenmanager implementiert. Mit der Bibliothek kann ein clientseitiger Transaktionsmanager globale Transaktionen koordinieren. Eine globale Transaktion ist eine einzelne Arbeitseinheit, die Vorgänge wie Datenbankupdates und Blockchain-Transaktionen umfassen kann, die alle atomar festgeschrieben werden müssen. Mit anderen Worten, alle Operationen müssen erfolgreich ausgeführt werden. Wenn ein Vorgang, der Teil der globalen Transaktion ist, nicht erfolgreich verläuft, werden alle Vorgänge zurückgesetzt. Die XA-Schnittstelle basiert auf dem Zwei-Phasen-Commit-Protokoll, ähnlich dem Protokoll, das von den REST-Endpunkten für atomare Transaktionen unterstützt wird. Weitere Informationen zu atomaren Transaktionen in Oracle Blockchain Platform finden Sie unter Atomare Updates über Chaincodes und Kanäle hinweg vornehmen.

Die XA-Implementierung für Oracle Blockchain Platform wird als Java-Library bereitgestellt. Sie kann über die Registerkarte Entwicklungstools im Bereich Anwendungsentwicklung der Oracle Blockchain Platform-Konsole heruntergeladen werden.

Vollständige Informationen zur Bibliothek sind in den Javadoc-Informationen enthalten, die in der herunterladbaren Datei enthalten sind. Die drei von der Bibliothek unterstützten Schlüsselobjekte sind OBPXAResource, OBPXADataSource und OBPXAConnection.

Objekt	Zweck
`OBPXAResource`	In dieser Klasse werden die erforderlichen APIs implementiert, die ein Transaktionsmanager mit Oracle Blockchain Platform als Ressourcenmanager für XA-Transaktionen koordinieren kann.
`OBPXADataSource`	Mit diesem Objekt können Sie eine Instanz der Datei `OBPXAConnection` abrufen und die Authentifizierungs- und Autorisierungszugangsdaten angeben.
`OBPXAConnection`	Mit diesem Objekt können Sie eine Instanz des Objekts `OBPXAResource` abrufen und die Blockchain-Transaktionen definieren, die als Teil einer XA-Transaktion ausgeführt werden sollen.

Um die XA-Bibliothek mit Oracle Blockchain Platform verwenden zu können, muss die Anwendung Zugangsdaten für die Authentifizierung und Autorisierung der angeforderten Vorgänge angeben. Die Bibliothek unterstützt sowohl Basisauthentifizierungstoken (Benutzer/Kennwort) als auch Zugriffstoken der Version OAuth 2.0, die Sie beim Erstellen der Instanz OBPXADataSource konfigurieren können. Die beiden Authentifizierungsmethoden sind mit den Authentifizierungsmethoden konsistent, die Sie mit dem Oracle Blockchain Platform-REST-Proxy verwenden. Weitere Informationen finden Sie unter Authentifizierung in der REST-API-Dokumentation.

Nachdem Sie eine OBPXADataSource-Instanz erstellt haben, können Sie die xaConnection-Instanz mit der Methode obpxaDataSource.getXAConnection() abrufen. Um die Authentifizierung bei Verwendung von Zugriffstoken der Version OAuth 2.0 zu aktualisieren, können Sie die Methode getXAConnection verwenden, wie im folgenden Code gezeigt:

OBPXAConnection xaConnection = obpxaDataSource.getXAConnection(accessToken);      // get an XA connection using an OAuth 2.0 access token

Sie können die Basisauthentifizierung auch mit der Methode getXAConnection aktualisieren.

OBPXAConnection xaConnection = obpxaDataSource.getXAConnection(user, password);   // get an XA connection using username and password for basic authentication

Um eine Blockchain-Transaktion zu definieren, die als Teil einer globalen XA-Transaktion ausgeführt werden soll, verwenden Sie die folgende Methode:

public void createXAInvokeTransaction(Xid xid, OBPXAInvokeTxRequest invokeTxRequest)

Bei dieser Methode ist xid eine globale Transaktions-ID und invokeTxRequest die Blockchain-Transaktion, die als Teil der globalen XA-Transaktion ausgeführt werden soll. Um eine XA-Aufruftransaktionsanforderung zu erstellen, verwenden Sie die folgende Konstruktormethode:

OBPXAInvokeTxRequest invokeTxRequest = new OBPXAInvokeTxRequest(channel, chaincode, args);

In dieser Konstruktormethode ist channel der Kanal, in dem die Blockchain-Transaktion ausgeführt wird, chaincode der zu verwendende Chaincode und args die Chaincode-Funktion und alle für die Transaktion zu verwendenden Argumente.

Das folgende Code-Snippet zeigt, wie Sie ein OBPXADataSource-Objekt erstellen, die OBPXAConnection-Instanz abrufen, die Transaktionsanforderung erstellen und die createXAInvokeTransaction-Methode aufrufen.

OBPXADataSource obpxaDataSource = OBPXADataSource.builder()
                        .withHost(host)
                        .withPort(port)
                        .withBasicAuth(username, password)
                        .withRole(role)
                        .build();
.
.
.
OBPXAConnection obpxaConnection = obpxaDataSource.getXAConnection();

OBPXAInvokeTxRequest invokeTxRequest = new OBPXAInvokeTxRequest(channel, chaincode, args);
invokeTxRequest.setEndorsers(endorsersArray); // optional blockchain transaction request attributes
invokeTxRequest.setTransientMap(transientMap); // optional blockchain transaction request attributes
invokeTxRequest.setTimeout(60000); // optional blockchain transaction request attributes

obpxaConnection.createXAInvokeTransaction(xid, invokeTxRequest);

Szenario: XA-Transaktionen mit Mustern untersuchen

Das folgende Szenario ähnelt dem für atomare Transaktionen beschriebenen Szenario: Szenario: Atomare Transaktionen anhand von Mustern untersuchen. Dabei werden die in Oracle Blockchain Platform enthaltenen Saldenübertragungs- und Marble-Beispiele verwendet.

In diesem Szenario installieren Sie die Beispiele für Balance Transfer und Marbles auf zwei verschiedenen Instanzen von Oracle Blockchain Platform. Jede Instanz entspricht dann einer XA-Datenquelle:

XA-Ressource OBP-1, wobei der Marbles-Kettencode auf dem Warenkanal installiert ist
XA-Ressource OBP-2, wobei der Balance Transfer-Kettencode im Wallet-Kanal installiert ist

In diesem Szenario können Sie eine XA-Transaktion verwenden, die mehrere Datenquellen umfasst, um sicherzustellen, dass der Geldumtausch und der Marmortransfer atomar erfolgen, wobei entweder alle Vorgänge erfolgreich sind oder keine erfolgreich sind. Der folgende Code veranschaulicht dieses Szenario:

OBPXADataSource obpxaDS1 = ... // create an XA data source, supplying details about the OBP-1 instance
OBPXADataSource obpxaDS2 = ... // create an XA data source, supplying details about the OBP-2 instance

// start a global transaction in the client application
// invoke marble transfer on OBP-1
OBPXAConnection obpxaConn1 = (OBPXAConnection) obpxaDS1.getXAConnection();
OBPXAInvokeTxRequest invokeMarbleTransferReq = new OBPXAInvokeTxRequest("goods", "obcs-marbles", new String[]{"transferMarble", "marble1", "tom"});
obpxaConn1.createXAInvokeTransaction(xid1, invokeMarbleTransferReq);
.
.
.
// invoke fund transfer on OBP-2
OBPXAConnection obpxaConn2 = (OBPXAConnection) obpxaDS2.getXAConnection();
OBPXAInvokeTxRequest invokeBalanceTransferReq = new OBPXAInvokeTxRequest("wallet", "obcs-example02", new String[]{"invoke", "a", "b", "50"});
obpxaConn2.createXAInvokeTransaction(xid2, invokeBalanceTransferReq);
.
.
.
// end the global transaction in the client application

Es ist ein bekanntes Problem mit dem Muster "Murmeln" und dem Standardwert des Feldes Marmorbesitzer aufgetreten. Weitere Informationen finden Sie unter: Bekannte Probleme für Oracle Blockchain Platform.