[JAVA] So fügen Sie Hyperledger Iroha Peer hinzu

Artikelinhalt

Dieser Artikel beschreibt, wie Sie Peer mit Hyperledger Iroha hinzufügen. Es gibt auch eine Möglichkeit, es mit "iroha-cli" hinzuzufügen, diesmal jedoch mithilfe der Java-Bibliothek. Wenn Sie es mit "iroha-cli" hinzufügen möchten, können Sie den öffentlichen und den privaten Schlüssel mit dem Code im Artikel abrufen. Ich denke, dass Sie dies einfach mithilfe der Schlüsselinformationen tun können.

Ich werde zuerst die Schlussfolgerung schreiben, aber bei diesem Verfahren wird Peer nicht hinzugefügt. Das Peer-Zusatzprogramm endet normal und ist ebenfalls im Block enthalten, aber die Kommunikation zwischen Peers funktioniert nicht.

Ich bin mir nicht sicher, ob dies ein Umweltproblem oder ein Iroha-Problem ist, daher werde ich eine Notiz hinterlassen, die nicht funktioniert hat.

Umgebung

In der Arbeit dieses Artikels starten wir vier Konsolen. Schreiben Sie sorgfältig, damit die Konsole im Artikel nicht verwirrend ist.

  1. iroha Unit 1 iroha-Daemon-Protokollprüfkonsole
  2. iroha Unit 1 iroha container bedienungskonsole
  3. iroha Unit 1 Konsolenbetriebskonsole für einige Postgres
  4. iroha Unit 2 iroha container bedienungskonsole

Vorbereitungen

Wir werden die Umgebung für iroha für zwei Autos bauen. Laden Sie die Überweisungsblöcke usw. im Voraus ordnungsgemäß auf Einheit 1. Einheit 2 bleibt nur mit dem Genesis-Block übrig.

Bereiten Sie einen Schlüssel vor, der beim Hinzufügen von Peer verwendet werden soll

Ursprünglich? Ich denke, ich werde einen öffentlichen Schlüssel mit OpenSSL usw. vorbereiten. Sie können einen Schlüssel einfach mithilfe des in der Iroha-Dokumentation beschriebenen Beispielcodes erstellen. Dieses Mal erstellen wir die Schlüsselinformationen in Java.

Zusätzliche Verarbeitung von Peer

Peer zusätzliches Programm

Code, der nur Peer hinzufügt.

import java.net.URI;
import java.security.KeyPair;

import org.testcontainers.shaded.org.apache.commons.codec.binary.Hex;

import jp.co.soramitsu.crypto.ed25519.Ed25519Sha3;
import jp.co.soramitsu.iroha.java.IrohaAPI;
import jp.co.soramitsu.iroha.java.Transaction;
import jp.co.soramitsu.iroha.java.TransactionStatusObserver;
import lombok.val;

public class AddPeer {

    private static final Ed25519Sha3 crypto = new Ed25519Sha3();

    private static final KeyPair peerKeypair = crypto.generateKeypair();

    public static void main(String[] args) throws Exception{

 // Diese IP ist die Adresse von iroha Unit 1
        URI uri = new URI(null,null, "192.168.33.20",50051,null,null,null);

        IrohaAPI api = new IrohaAPI(uri);

        byte[] pubByte = Hex.decodeHex("313a07e6384776ed95447710d15e59148473ccfc052a681317a72a69f2a49910");
        byte[] privByte = Hex.decodeHex("f101537e319568c765b2cc89698325604991dca57b9716b58016b253506cab70");

        KeyPair adminKeyPair = Ed25519Sha3.keyPairFromBytes(privByte, pubByte);

 // Diese IP ist die IP-Adresse von iroha Unit 2
        val addPeerTx = Transaction.builder("admin@test")
                          .addPeer("192.168.33.21:10001", peerKeypair.getPublic())
                          .sign(adminKeyPair)
                          .build();
                          
        val observer = TransactionStatusObserver.builder()
            // executed when stateless or stateful validation is failed
            .onTransactionFailed(t -> System.out.println(String.format(
                "transaction %s failed with msg: %s",
                t.getTxHash(),
                t.getErrOrCmdName()
            )))
            // executed when got any exception in handlers or grpc
            .onError(e -> System.out.println("Failed with exception: " + e))
            // executed when we receive "committed" status
            .onTransactionCommitted((t) -> System.out.println("Committed :)"))
            // executed when transfer is complete (failed or succeed) and observable is closed
            .onComplete(() -> System.out.println("Complete"))
            .build();

 // Transaktion ausführen
        api.transaction(addPeerTx).blockingSubscribe(observer);

        api.close();
        System.out.println("PubKey :" + Hex.encodeHexString(peerKeypair.getPublic().getEncoded()));
        System.out.println("PrivKey:" + Hex.encodeHexString(peerKeypair.getPrivate().getEncoded()));       
    }
}

Bestätigung des Ausführungsergebnisses (Block)

Ein Block mit AddPeer wird unter "/ tmp / block_store" des iroha-Containers erstellt.

(Iroha Unit 1 Iroha Container Bedienkonsole)

{
  "blockV1": {
    "payload": {
      "transactions": [
        {
          "payload": {
            "reducedPayload": {
              "commands": [
                {
                  "addPeer": {
                    "peer": {
                      "address": "192.168.33.21:10001",
                      "peerKey": "28CF79DEF117456ABC5413DC15F7B99B192C6D5A162ABDEF39F0BAF6C7CE0B48"
                    }
                  }
                }
              ],
              "creatorAccountId": "admin@test",
              "createdTime": "1571213725207",
              "quorum": 1
            }
          },
          "signatures": [
            {
              "publicKey": "313A07E6384776ED95447710D15E59148473CCFC052A681317A72A69F2A49910",
              "signature": "A018F697EB5F6797BD478F8CF04759F8D0ACDA48D4E1FE8B8BBE5D538E6D47A423896E689AA780DD260763ED1B97B12F9AF1EA41D7D391FB2F9C49EDB429DC0C"
            }
          ]
        }
      ],
      "height": "16",
      "prevBlockHash": "e602693381ff5ac383a2d62503d94ede87951ffdedefe9b4628a188036fd6c89",
      "createdTime": "1571213727036"
    },
    "signatures": [
      {
        "publicKey": "bddd58404d1315e0eb27902c5d7c8eb0602c16238f005773df406bc191308929",
        "signature": "863b38942a290640e05bbb2339ab63d94a8ab6ca3bfba1abaf673fe490f7eb46236a72cdb54d95a3c11254c440ebe3ef1110466a989e0dc4221952749b87ec0b"
      }
    ]
  }
}

Die im Programm eingebettete IP-Adresse und der erstellte pubKey werden im Befehl addPeer als Peer-Informationen registriert.

Bestätigung des Ausführungsergebnisses (postgres)

Stellen Sie im Docker-Container eine Verbindung zu "some-postgres" her und sehen Sie sich den Inhalt der Tabelle an, die die Peer-Informationen enthält. (Iroha Unit 1, einige Postgres-Container-Bedienkonsolen)

root@f7d412e03bfb:/# psql -U postgres
psql (9.5.19)
Type "help" for help.

postgres=# \l
                                 List of databases
    Name    |  Owner   | Encoding |  Collate   |   Ctype    |   Access privileges
-----------+----------+----------+------------+------------+-----------------------
  postgres  | postgres | UTF8     | en_US.utf8 | en_US.utf8 |
  template0 | postgres | UTF8     | en_US.utf8 | en_US.utf8 | =c/postgres          +
            |          |          |            |            | postgres=CTc/postgres
  template1 | postgres | UTF8     | en_US.utf8 | en_US.utf8 | =c/postgres          +
            |          |          |            |            | postgres=CTc/postgres
(3 rows)

postgres=# \d
                        List of relations
  Schema |               Name                |   Type   |  Owner
--------+-----------------------------------+----------+----------
  public | account                           | table    | postgres
  public | account_has_asset                 | table    | postgres
  public | account_has_grantable_permissions | table    | postgres
  public | account_has_roles                 | table    | postgres
  public | account_has_signatory             | table    | postgres
  public | asset                             | table    | postgres
  public | domain                            | table    | postgres
  public | height_by_account_set             | table    | postgres
  public | index_by_creator_height           | table    | postgres
  public | index_by_creator_height_id_seq    | sequence | postgres
  public | peer                              | table    | postgres
  public | position_by_account_asset         | table    | postgres
  public | position_by_hash                  | table    | postgres
  public | role                              | table    | postgres
  public | role_has_permissions              | table    | postgres
  public | signatory                         | table    | postgres
  public | tx_status_by_hash                 | table    | postgres
(17 rows)

postgres=# select * from peer;
                            public_key                            |       address
------------------------------------------------------------------+---------------------
 bddd58404d1315e0eb27902c5d7c8eb0602c16238f005773df406bc191308929 | 127.0.0.1:10001
 28cf79def117456abc5413dc15f7b99b192c6d5a162abdef39f0baf6c7ce0b48 | 192.168.33.21:10001
(2 rows)

Der von addPeer festgelegte öffentliche Schlüssel und die IP-Adresse werden in der Peer-Tabelle registriert.

Bestätigung des Ausführungsergebnisses (iroha Unit 2)

Überprüfen Sie als Nächstes, ob die Blockinformationen mit Einheit 2 synchronisiert wurden.

(Iroha Unit 2 Iroha Container Bedienkonsole)

root@eaa7050903db:/opt/iroha_data# ls /tmp/block_store/
0000000000000001

Nicht synchronisiert. .. Lassen Sie uns das Protokoll von irohad überprüfen.

Bestätigung des Ausführungsergebnisses (iroha daemon)

(Iroha Unit 1 iroha Daemon-Protokollbestätigungskonsole)

root@c8d233a3c261:/opt/iroha_data# [2019-10-17 00:12:09.459123458][I][Irohad/CommandService/Processor]: handle batch
[2019-10-17 00:12:09.459140102][I][Irohad/CommandService/Processor]: propagating batch to PCS
[2019-10-17 00:12:09.459158309][I][Irohad/PeerCommunicationService]: propagate batch
[2019-10-17 00:12:09.460952243][I][Irohad/Ordering/Service]: onBatches => collection size = 1
[2019-10-17 00:12:10.400058025][W][Irohad/AsyncNetworkClient]: RPC failed: Connect Failed
[2019-10-17 00:12:10.400080412][W][Irohad/AsyncNetworkClient]: RPC failed: Connect Failed
[2019-10-17 00:12:10.400088212][W][Irohad/AsyncNetworkClient]: RPC failed: Connect Failed
[2019-10-17 00:12:10.400095314][W][Irohad/AsyncNetworkClient]: RPC failed: Connect Failed
[2019-10-17 00:12:10.400102280][W][Irohad/AsyncNetworkClient]: RPC failed: Connect Failed

Es scheint, dass die Verbindung mit Unit 2 über gRPC fehlgeschlagen ist.

Wahrscheinlich, aber ich denke, es ist das gleiche Ereignis. https://github.com/hyperledger/iroha/issues/191

Es wird hier verwaltet https://jira.hyperledger.org/browse/IR-588

Zurück (Peer löschen)

Da es nicht so verwendet werden kann, wie es ist, habe ich auch ein Programm zum Löschen von Peer vorbereitet.

import java.net.URI;
import java.security.KeyPair;

import org.testcontainers.shaded.org.apache.commons.codec.binary.Hex;

import jp.co.soramitsu.crypto.ed25519.Ed25519Sha3;
import jp.co.soramitsu.iroha.java.IrohaAPI;
import jp.co.soramitsu.iroha.java.Transaction;
import jp.co.soramitsu.iroha.java.TransactionStatusObserver;
import lombok.val;

public class RemovePeer {

    public static void main(String[] args) throws Exception{

        URI uri = new URI(null,null, "192.168.33.20",50051,null,null,null);

        IrohaAPI api = new IrohaAPI(uri);

        byte[] pubByte = Hex.decodeHex("313a07e6384776ed95447710d15e59148473ccfc052a681317a72a69f2a49910");
        byte[] privByte = Hex.decodeHex("f101537e319568c765b2cc89698325604991dca57b9716b58016b253506cab70");
        
 // ↓ Bitte setzen Sie den öffentlichen Schlüssel von Peer, der im Block ↓ erfasst wurde
        byte[] peerPubKey = Hex.decodeHex("28CF79DEF117456ABC5413DC15F7B99B192C6D5A162ABDEF39F0BAF6C7CE0B48");

        KeyPair adminKeyPair = Ed25519Sha3.keyPairFromBytes(privByte, pubByte);


        val addPeerTx = Transaction.builder("admin@test")
 .removePeer (peerPubKey) // ← Dies wurde gerade von addPeer in removePeer geändert
                            .sign(adminKeyPair)
                            .build();

        val observer = TransactionStatusObserver.builder()
            // executed when stateless or stateful validation is failed
            .onTransactionFailed(t -> System.out.println(String.format(
                "transaction %s failed with msg: %s",
                t.getTxHash(),
                t.getErrOrCmdName()
            )))
            // executed when got any exception in handlers or grpc
            .onError(e -> System.out.println("Failed with exception: " + e))
            // executed when we receive "committed" status
            .onTransactionCommitted((t) -> System.out.println("Committed :)"))
            // executed when transfer is complete (failed or succeed) and observable is closed
            .onComplete(() -> System.out.println("Complete"))
            .build();

 // Transaktion ausführen
        api.transaction(addPeerTx).blockingSubscribe(observer);

        api.close();
    }
}

Ich werde das machen.

transaction 6069fe1e6c2f6b7437ce145e0db552355f3d8631d16b7bc18b53894fcafec2bf failed with msg: Protobuf Transaction: [[Undefined command is found ]]

Complete

Was! Undefinierter Befehl wurde gefunden! Es scheint, dass removePeer noch nicht implementiert wurde. Als ich den Inhalt der Transaktion durch Debuggen überprüfte, sah es so aus.

reduced_payload {
  commands {
    remove_peer {
      public_key: "28CF79DEF117456ABC5413DC15F7B99B192C6D5A162ABDEF39F0BAF6C7CE0B48"
    }
  }
  creator_account_id: "admin@test"
  created_time: 1571276110853
  quorum: 1
}

Ich werde weiterhin nach anderen Wegen suchen und die Informationen auf den oben genannten Websites verfolgen. Das ist alles für diese Zeit.

Punkte der Besorgnis

Es gibt zwei Punkte, an denen ich dieses Mal verschiedene Dinge berühren wollte.

Der erste Punkt ist, dass die Transaktion nicht im Block erfasst wird, wenn die Kommunikation zwischen Peers nicht erfolgreich ist. Nun, ich denke, es ist natürlich, aber im tatsächlichen Betrieb, wenn es zwei Peers gibt, wenn einer ausfällt, wird die Transaktion überhaupt nicht aufgenommen. In Zukunft werde ich versuchen, die Anzahl der Einheiten auf 3 und 4 zu erhöhen, aber um keinen einzigen Fehlerpunkt zu erstellen, werden anscheinend mindestens 3 Einheiten Peer benötigen.

Der zweite Punkt ist vielleicht kein großes Problem, aber es scheint, dass alle vorhandenen Blockinformationen überprüft werden, wenn der iroha-Daemon gestartet wird. (Iroha Unit 1 iroha Daemon-Protokollbestätigungskonsole)

[2019-10-16 23:41:19.917112613][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 1, hash 9debdb1a70db2cede2222427b849f6bf7ab20845da7c3db1837c0df25ec1c61a
[2019-10-16 23:41:19.930740040][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 2, hash d2d9906eb82dd799e6cb68161208738e8383cae31bdf499b2b5f7f14d55b2ba0
[2019-10-16 23:41:19.950225041][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 3, hash 686b05c2553b70cd26fdb6e9108066a33e2b09653ccb33b3b3c9f6e4f12e72d2
[2019-10-16 23:41:19.952860890][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 4, hash fd8541954c9ab55229e8f6e095a7484ece7d64066e78c775359e0d8736a4ea4b
[2019-10-16 23:41:19.960015934][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 5, hash cc5a4fe828811e217a5de828047b9c0d5939628d809b2265b66db1b73f9d0f98
[2019-10-16 23:41:19.972008320][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 6, hash 4fa8f208d9c85b08edc3504aed35f257de943942f250639111c334724cfe6d26
[2019-10-16 23:41:19.983822479][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 7, hash 471894ae7fa36f09d971be563686b2aa06ff28a9bd9a49d6e802451cb018ac1b
[2019-10-16 23:41:19.985555973][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 8, hash 68ef83c09eb4bc8152dd7feaeb0e10a1fb0c71b63e6c6e66e829fd730a765f18
[2019-10-16 23:41:19.987011731][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 9, hash e5dcd0505aa726d25d318af78ea41126f02c44f3647011582017140e1c7e55e5
[2019-10-16 23:41:19.988539990][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 10, hash c6fb5fff4bf3c440b6846761d50d248beb75199342b8b9431e19c1e2b5e7e303
[2019-10-16 23:41:19.989874002][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 11, hash 278c9c5e5a72b5513d55290f2687c623595b7825b747c525ee00135cccfb1149
[2019-10-16 23:41:19.991317395][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 12, hash d33d2adabf75be7380cc6b35b84bcb4b2055f47a927cf1090c1d49853fee154b
[2019-10-16 23:41:19.992694976][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 13, hash b0d19d57da0f0d0677052409e625adfea8dedbb6297edd49968d5f102de73c27
[2019-10-16 23:41:20.008512960][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 14, hash 337830921603cc703cd8f95a6624b3d2d0fce090d3ddca53c69d9989620f2c44
[2019-10-16 23:41:20.022142829][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 15, hash e602693381ff5ac383a2d62503d94ede87951ffdedefe9b4628a188036fd6c89
[2019-10-16 23:41:20.024153577][I][Irohad/Storage/MutableStorageImpl]: Applying block: height 16, hash d3e5c825cb9b1ca298ccf6b7b7f8a139803e6e1c9850fed65a0241f378f5125e

Es scheint, dass es für einen normal erfassten Block ungefähr 0,01 Sekunden und für einen abgelehnten Block ungefähr 0,002 Sekunden dauert. Natürlich ändert sich die Verarbeitungsgeschwindigkeit abhängig von der Leistung des Servers. Wenn Sie den Dämon jedoch im tatsächlichen Betrieb neu starten müssen, kann diese Verarbeitung länger als erwartet dauern.

Funktionieren addPeer und removePeer mit der Python-Bibliothek? Als nächstes möchte ich diesen Bereich untersuchen.

Recommended Posts

So fügen Sie Hyperledger Iroha Peer hinzu
So fügen Sie die ActionText-Funktion hinzu
[Schienen] So fügen Sie neue Seiten hinzu
So fügen Sie die Löschfunktion hinzu
So fügen Sie ein lokales Glas zu mavens pom.xml hinzu
[Java] Hinzufügen von Daten zur Liste (add, addAll)
So fügen Sie einen neuen Hash / Array hinzu
So fügen Sie eine JAR-Datei in ScalaIDE hinzu
Hinzufügen von Informationen zur Anwendungsversion zu Sentry-Informationen
So fügen Sie in Spring Boot einen Klassenpfad hinzu
So fügen Sie die html.erb-Klasse in Rails bedingt hinzu
Datei zur JAR-Datei hinzufügen
So entwickeln Sie OpenSPIFe
So rufen Sie AmazonSQSAsync auf
Verwendung von Map
Wie schreibe ich Rails
Wie benutzt man rbenv?
Verwendung mit_option
Verwendung von fields_for
Verwendung von java.util.logging
Verwendung der Karte
Hinzufügen von Zeichen zur Anzeige bei Verwendung der link_to-Methode
Verwendung von collection_select
Wie benutzt man Twitter4J
Wie benutzt man active_hash! !!
So installieren Sie Docker
Verwendung von MapStruct
Verwendung von TreeSet
So deinstallieren Sie Rails
So installieren Sie Docker-Maschine
[Verwendung des Etiketts]
Wie man ein schattiertes Glas macht
Wie schreibe ich Docker-Compose
Wie man Identität benutzt
Wie man Hash benutzt
Wie schreibe ich Mockito
So erstellen Sie Docker-Compose
So installieren Sie MySQL
So schreiben Sie eine Migrationsdatei
Wie man android-midi-lib baut
Verwendung von Dozer.mapper
Wie benutzt man Gradle?
Verwendung von org.immutables
Verwendung von java.util.stream.Collector
Verwendung von VisualVM
Verwendung von Map
Wie man einen Schrägstrich zurückschlägt \
So verketten Sie Zeichenfolgen
Hinzufügen von Elementen ohne Angabe der Länge des Arrays