Flutter比特币轻客户端插件bitcoin_light_client的使用

概述

bitcoin_light_client 是一个用 Dart 编写的比特币 P2P 轻客户端。它通过连接到全节点来收集数据，并发送/接收支付。该库的设计考虑到了可扩展性。

示例代码

以下是一个完整的示例，展示了如何使用 bitcoin_light_client 插件在 Flutter 中实现比特币轻客户端功能。

示例代码

// Copyright (c) 2021-2023 Kolby Moroz Liebl
// Distributed under the MIT software license, see the accompanying
// file LICENSE or http://www.opensource.org/licenses/mit-license.php.

import 'dart:async';
import 'dart:convert';
import 'dart:io';
import 'package:bitcoin_light_client/util.dart';
import 'package:bitcoin_light_client/bitcoin_light_client.dart';
import 'package:crypto/crypto.dart';

Map<List<int>, CAnonMsg> mapAnonMsg = Map<List<int>, CAnonMsg>();

// 自定义消息类型
String anonmsg = "anonmsg";
String getanonmsg = "getanonmsg";

class CAnonMsg {
  int msgTime;
  int version = 1;
  String msgData;

  CAnonMsg() {
    msgTime = 0;
  }

  void setMessage(String msgContent) {
    msgTime = new DateTime.now().millisecondsSinceEpoch ~/ 1000;
    msgData = msgContent;
  }

  String getMessage() {
    return msgData;
  }

  int getTimestamp() {
    return msgTime;
  }

  String toString() {
    String string = ('CAnonMsg msgTime: $msgTime, msgData: $msgData');
    return string;
  }

  List<int> getHash() {
    return sha256.convert(sha256.convert(serialize()).bytes).bytes;
  }

  List<int> serialize() {
    List<int> messageData = uint64ToListIntLE(msgTime) + [utf8.encode(msgData).length] + utf8.encode(msgData);
    return messageData;
  }

  void deserialize(List<int> data) {
    msgTime = listIntToUint64LE(data.sublist(0, 8));
    int msgDataLength = listIntToUint8LE(data.sublist(8, 9));
    msgData = utf8.decode(data.sublist(9, 9 + msgDataLength.abs()), allowMalformed: true);
  }
}

class OmegaMessageNodes extends MessageNodes {
  OmegaMessageNodes(Socket inputsocket) : super(inputsocket);

  void customAddNode(String ip, [port = null]) {
    addOmegaNode(ip, port);
  }

  void extendVersion() {
    sendGetAnonMessage();
  }

  List<CInv> extendInv(List<CInv> msgInvData, List<CInv> msgGetDataInvData) {
    for (CInv k in msgInvData) {
      if (k.type == 20) {
        for (List<int> i in mapAnonMsg.keys) {
          if (IterableEquality().equals(k.hash, i)) {
            break;
          }
        }
        msgGetDataInvData.add(k);
      }
    }
    return msgGetDataInvData;
  }

  void extendCommandsSupported(MsgHeader msgHeader) {
    if (msgHeader.command == anonmsg) {
      CAnonMsg cAnonMsg = new CAnonMsg();
      cAnonMsg.deserialize(msgHeader.payload);

      // 如果我们已经拥有此消息，则返回并不要添加它。
      if (mapAnonMsg.isNotEmpty) {
        for (var k in mapAnonMsg.keys) {
          if (IterableEquality().equals(k, cAnonMsg.getHash())) {
            return;
          }
        }
      }

      // 如果消息超过一天旧，则不要添加。
      if ((cAnonMsg.msgTime + 24 * 60 * 60) < DateTime.now().millisecondsSinceEpoch ~/ 1000) {
        return;
      }

      mapAnonMsg[cAnonMsg.getHash()] = cAnonMsg;

      MsgHeader anonMsgMessage = new MsgHeader();
      anonMsgMessage.command = anonmsg;
      anonMsgMessage.payload = cAnonMsg.serialize();
      relayMessage(anonMsgMessage.serialize());
    } else if (msgHeader.command == getanonmsg) {
      mapAnonMsg.values.forEach((cAnonMsg) {
        MsgHeader anonMsgMessage = new MsgHeader();
        anonMsgMessage.command = anonmsg;
        anonMsgMessage.payload = cAnonMsg.serialize();

        // 发送消息
        pushMessage(anonMsgMessage.serialize());
      });
    } else {
      // 我们不支持此命令，可以添加代码告诉节点忽略我们或类似的操作
    }
  }
}

void sendGetAnonMessage() {
  nodes.forEach((messageNodes) {
    MsgHeader getAnonMessage = new MsgHeader();
    getAnonMessage.command = getanonmsg;

    // 发送消息
    messageNodes.pushMessage(getAnonMessage.serialize());
  });
}

void sendAnonMessage(String message) {
  bool didWeAddMessage = false;
  nodes.forEach((messageNodes) {
    MsgHeader sendAnonMessage = new MsgHeader();
    CAnonMsg cAnonMsg = CAnonMsg();
    sendAnonMessage.command = anonmsg;
    cAnonMsg.setMessage(message);
    sendAnonMessage.payload = cAnonMsg.serialize();

    if (!didWeAddMessage) {
      mapAnonMsg[cAnonMsg.getHash()] = cAnonMsg;
      didWeAddMessage = true;
    }

    // 发送消息
    messageNodes.pushMessage(sendAnonMessage.serialize());
  });
}

void updateAnonMessage() {
  nodes.forEach((messageNodes) {
    MsgHeader getanonMessage = new MsgHeader();
    getanonMessage.command = getanonmsg;

    // 发送消息
    messageNodes.pushMessage(getanonMessage.serialize());
  });
}

void removeOldAnonMessage() {
  mapAnonMsg.keys.forEach((element) {
    if (((mapAnonMsg[element].getTimestamp() + 24 * 60 * 60) < (DateTime.now().millisecondsSinceEpoch ~/ 1000))) {
      mapAnonMsg.remove(element);
    }
  });
}

void startOmegaNode({Configuration configuration = null}) {
  if (configuration == null) {
    config = Configuration();
  } else {
    config = configuration;
  }

  // 获取节点列表
  fetchNodeList().then((value) {
    nodeList = value.listOfNodes;

    // 代码开始

    for (var k in nodeList.keys) {
      addOmegaNode(k, nodeList[k]);
    }

    for (var i = 0; i < nodes.length; i++) {
      sendGetAddrMessage(nodes[i]);
    }

    Timer.periodic(Duration(seconds: 20), (timer) {
      if (nodes.length <= 6) {
        for (var i = 0; i < nodes.length; i++) {
          sendGetAddrMessage(nodes[i]);
        }
      }
      // 如果节点数量为零，尝试从节点列表中再次添加节点
      if (nodes.length == 0) {
        for (var k in nodeList.keys) {
          addOmegaNode(k, nodeList[k]);
        }
      }
    });
  });
}

Future<NodeListClass> fetchNodeList() async {
  final response = await http.get(Uri.parse('https://omegablockchain.net/omeganodelist.json'));
  if (response.statusCode == 200) {
    print(jsonDecode(response.body));
    return NodeListClass.fromJson(json.decode(response.body));
  } else {
    print('Something went wrong. \nResponse Code : ${response.statusCode}');
    throw Error();
  }
}

int periodCount = 0;
bool addOmegaNode(String ip, [port = null]) {

  if (port == null) {
    port = config.default_port;
  }

  periodCount++;
  if (periodCount >= config.connection_limit) {
    periodCount--;
    return false;
  }
  if (nodes.length > config.connection_limit) {
    periodCount--;
    return false;
  }

  // 如果节点已连接则不要添加它
  for (var i = 0; i < nodes.length; i++) {
    if (nodes[i].ip == ip) {
      periodCount--;
      return false;
    }
  }

  Socket.connect(ip, port).then((Socket socket) {
    handleOmegaConnection(socket, true);
    periodCount--;
    return true;
  }, onError: (e) {
    // 如果连接失败，返回 false
    print('Error $e');
    periodCount--;
    return false;
  });
}

void handleOmegaConnection(Socket node, bool didWeInitiateConnection){
  OmegaMessageNodes messageNodes = new OmegaMessageNodes(node);
  nodes.add(messageNodes);

  if (didWeInitiateConnection) {
    MsgHeader versionMessage = new MsgHeader();
    MsgVersion versionPayload = new MsgVersion();
    versionPayload.addr_from = CAddress.data(messageNodes.ip);
    versionMessage.command = version;
    versionMessage.payload = versionPayload.serialize();

    // 发送消息
    messageNodes.pushMessage(versionMessage.serialize());
    messageNodes.didWeSendVersion = true;
  }
}

使用说明

1. 初始化配置：

   • 首先，确保你的项目中已经包含了 bitcoin_light_client 和 http 依赖项。你可以在 pubspec.yaml 文件中添加这些依赖项：

     dependencies:
       flutter:
         sdk: flutter
       bitcoin_light_client: ^x.x.x
       http: ^0.13.3