std.blockchain.p2p — Blockchain P2P-Netzwerk

std.blockchain.p2p implementiert eine TCP-basierte P2P-Kommunikationsschicht für Blockchain-Knoten. Jeder Knoten kann bis zu 32 Peers verbinden, Transaktionen und Blöcke broadcasten und eingehende Verbindungen akzeptieren.

→ std.blockchain (Kern) · Standard Library

Binäres Nachrichtenformat: [1 Byte Typ][4 Bytes Länge BE][N Bytes Payload]

Wichtig: QUERY_CHAIN (3) wird gesendet wenn die eigene Kette kürzer ist, aber BLP2PHandleIncoming behandelt weder QUERY_CHAIN noch RESP_CHAIN. Chain-Synchronisation ist daher noch nicht vollständig implementiert.

Weitere Konstanten:

Offset-Konstanten: BLP2P_NODE_BC (0), BLP2P_NODE_PORT (8), BLP2P_NODE_SERVER_FD (16), BLP2P_NODE_PEER_COUNT (24), BLP2P_NODE_PEER_FDS (32), BLP2P_NODE_SIZE (40)

Achtung: BLP2PPoll verwendet blockierendes accept trotz des Namens. Es wartet auf eine neue Verbindung und kehrt nicht sofort zurück wenn keine anliegt. Für nicht-blockierende Nutzung muss der Server-FD vorab auf non-blocking gesetzt werden.

BLP2PHandleIncoming behandelt:

• QUERY_LATEST → antwortet mit aktuellem letzten Block
• BROADCAST_TX → deserialisiert TX und versucht BLAddTransaction; bei Erfolg wird TX vom bc übernommen; bei Ablehnung wird TX freigegeben
• BROADCAST_BLOCK → siehe Block-Empfang unten

Die Deserializer-Funktionen werden intern von BLP2PHandleIncoming genutzt, sind aber auch öffentlich für eigene Protokoll-Erweiterungen.

BLDeserializeTx allokiert intern einen neuen TX (224 Bytes). Der Aufrufer muss den TX freigeben wenn er nicht via BLAddTransaction an den Mempool übergeben wird.

BLP2PConnectPeer erwartet die IPv4-Adresse als int64 (4 Bytes, big-endian):

// 192.168.1.100 → (192 << 24) | (168 << 16) | (1 << 8) | 100
var ip: int64 := (192 << 24) | (168 << 16) | (1 << 8) | 100;
BLP2PConnectPeer(node, ip, 9000);

import std.blockchain;
import std.blockchain.p2p;
import std.alloc;
import std.io;

fn main(): int64 {
    // Blockchain erstellen
    var bc: int64 := BLBlockchainNew(1, 50000000, 10);

    // P2P-Knoten auf Port 9000 starten
    var node: int64 := BLP2PNodeNew(bc, 9000);
    if BLP2PNodeStart(node) == 0 then {
        PrintLn("Fehler: Port 9000 belegt"c);
        BLP2PNodeFree(node);
        BLBlockchainFree(bc);
        return 1;
    }

    PrintLn("P2P-Knoten lauscht auf Port 9000"c);

    // Zu einem bekannten Peer verbinden: 192.168.1.50:9000
    var peerIp: int64 := (192 << 24) | (168 << 16) | (1 << 8) | 50;
    if BLP2PConnectPeer(node, peerIp, 9000) == 1 then {
        PrintLn("Verbunden mit 192.168.1.50"c);
    }

    // Hauptschleife (vereinfacht — in echtem Code: epoll/select verwenden)
    var fds: int64 := peek64(node + BLP2P_NODE_PEER_FDS);
    var i: int64 := 0;
    while i < BLP2P_MAX_PEERS do {
        var fd: int64 := peek64(fds + i * 8);
        if fd != (0 - 1) then {
            if BLP2PHandleIncoming(node, fd) == 0 then {
                // Verbindung getrennt — Slot freigeben
                poke64(fds + i * 8, 0 - 1);
            }
        }
        i := i + 1;
    }

    BLP2PNodeStop(node);
    BLP2PNodeFree(node);
    BLBlockchainFree(bc);
    return 0;
}

Letzte Aktualisierung: 2026-06-13