Flutter加密货币交易插件binance_spot_plus的使用

Flutter加密货币交易插件binance_spot_plus的使用

重要提示

本项目是从 binance_spot 分支出来的。由于原项目的依赖项与最新的 Flutter 版本不兼容，因此我对其进行了分叉并做了一些修改以使其兼容最新版本的 Flutter。

简介

这是一个用于 Binance SPOT API 的非官方 Dart 包。 目前它包括市场数据端点、子账户端点、钱包端点、现货账户/交易端点、法币端点，以及市场和用户数据流的支持。 如果您发现任何问题，请随时提交问题或拉取请求，我会很高兴接受它们。

目前支持的功能

• 市场数据端点
• 子账户端点
• 钱包端点
• 现货账户/交易端点
• 法币端点
• Websocket 市场流
• 用户数据流

有用的链接

• Binance API 文档

开始使用

安装

在 pubspec.yaml 文件中添加以下依赖：

dependencies:
  binance_spot: ^0.0.3

或者使用命令行安装：

flutter pub add binance_spot_plus

使用示例

下面是一个完整的示例，展示了如何使用 binance_spot_plus 插件来获取市场信息和用户数据流。

import 'dart:async';

import 'package:binance_spot/binance_spot_plus.dart';
import 'package:flutter/material.dart' hide Interval;

class HomePage extends StatefulWidget {
  const HomePage({Key? key}) : super(key: key);

  [@override](/user/override)
  _HomePageState createState() => _HomePageState();
}

class _HomePageState extends State<HomePage> {
  BinanceSpot binanceSpot = BinanceSpot(
    key: "<apiKey>",
    secret: "<apiSecret>",
  );
  double lastClosePrice = 0;
  String tradablePairs = "";
  String lastEventData = "";
  late StreamSubscription<dynamic> klineStreamSub;
  late StreamSubscription<dynamic> userdataStreamSub;

  [@override](/user/override)
  void initState() {
    startKlineStream();
    startUserdataStream();
    super.initState();
  }

  [@override](/user/override)
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: const Text("Binance API 测试器"),
      ),
      body: Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          crossAxisAlignment: CrossAxisAlignment.center,
          children: [
            Text("当前 BTC 价格 : $lastClosePrice"),
            Text("最后的用户数据流事件 : $lastEventData"),
            TextButton(
              onPressed: getTradablePairs,
              child: const Text("获取对冲"),
            ),
            Expanded(
              flex: 1,
              child: SelectableText(
                tradablePairs,
                maxLines: 200,
                minLines: 1,
              ),
            ),
          ],
        ),
      ),
    );
  }

  void startKlineStream() {
    var stream = binanceSpot.klineStream(
      symbol: "BTCUSDT",
      interval: Interval.INTERVAL_5m,
    );
    klineStreamSub = stream.listen(handleNewKline);
  }

  void handleNewKline(WsKlineEvent event) {
    setState(() {
      lastClosePrice = event.kline.close;
    });
  }

  void startUserdataStream() async {
    var response = await binanceSpot.createListenKey();
    if (response.isRight) {
      var stream = binanceSpot.userDataStream(listenKey: response.right);
      userdataStreamSub = stream.listen(handleUserdataEvent);
    } else {
      lastEventData = response.left;
    }
  }

  void handleUserdataEvent(dynamic event) {
    if (event is WsAccountUpdate) {
      lastEventData = "账户更新事件 : ${event.balances.length} 个余额已更新";
    } else if (event is WsBalanceUpdate) {
      lastEventData = "余额更新事件 : ${event.asset} 余额已更新";
    } else if (event is WsExecutionReport) {
      lastEventData = "执行报告事件 : 状态为 ${event.orderStatus.toStr()}";
    } else if (event is WsListOrderStatus) {
      lastEventData = "订单列表更新事件 : 状态为 ${event.listOrderStatus}";
    } else {
      lastEventData = "未知事件类型 : ${event.toString()}";
    }
  }

  void getTradablePairs() async {
    var response = await binanceSpot.exchangeInfo();
    if (response.isLeft) {
      tradablePairs = response.left;
    } else {
      var listSymbol = response.right.symbols.map((e) => e.symbol).toList();
      tradablePairs = "";
      for (var s in listSymbol) {
        tradablePairs += "$s ";
      }
    }
  }

  [@override](/user/override)
  void dispose() {
    klineStreamSub.cancel();
    userdataStreamSub.cancel();
    super.dispose();
  }
}