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

本文将详细介绍如何在Flutter应用中使用binance_futures插件进行加密货币交易。我们将通过一个完整的示例来展示如何初始化插件、获取市场数据、启动实时数据流等操作。

binance_futures

binance_futures是一个非官方的Dart库，用于与Binance期货API进行交互。目前它支持市场数据端点、账户/交易端点、市场WebSocket流以及用户数据流。

当前支持的功能

• 市场数据端点 (100%)
• 账户/交易端点 (50%)
• WebSocket市场流 (100%)
• 用户数据流 (100%)

有用的链接

• Binance API文档（英文）

开始使用

安装

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

dependencies:
  binance_futures: ^0.0.1

或者从GitHub获取最新版本：

dependencies:
  binance_futures:
   git: https://github.com/AmauryBuguet/binance_futures

也可以使用以下命令添加到项目中：

flutter pub add binance_futures

使用

以下是一个完整的示例代码，展示了如何使用binance_futures插件。

import 'dart:async';

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

void main() => runApp(const MyApp());

class MyApp extends StatelessWidget {
  const MyApp({Key? key}) : super(key: key);

  @override
  Widget build(BuildContext context) {
    return const MaterialApp(
      home: HomePage(),
    );
  }
}

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

  @override
  _HomePageState createState() => _HomePageState();
}

class _HomePageState extends State<HomePage> {
  // 初始化Binance Futures客户端
  BinanceFutures binanceFutures = BinanceFutures(
    key: "<apiKey>", // 替换为你的API密钥
    secret: "<apiSecret>", // 替换为你的API密钥
  );

  // 存储最近的BTC价格
  double lastClosePrice = 0;
  // 存储可交易对
  String tradablePairs = "";
  // 存储最后的用户数据事件
  String lastEventData = "";

  // 流订阅对象
  late StreamSubscription<dynamic> klineStreamSub;
  late StreamSubscription<dynamic> userdataStreamSub;

  @override
  void initState() {
    // 启动K线流
    startKlineStream();
    // 启动用户数据流
    startUserdataStream();
    super.initState();
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: const Text("Binance API tester"),
      ),
      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,
              ),
            ),
          ],
        ),
      ),
    );
  }

  // 启动K线流
  void startKlineStream() {
    var stream = binanceFutures.klineStream(
      symbol: "BTCUSDT",
      interval: Interval.INTERVAL_5m,
    );
    klineStreamSub = stream.listen(handleNewKline);
  }

  // 处理新的K线事件
  void handleNewKline(WsKlineEvent event) {
    setState(() {
      lastClosePrice = event.kline.close;
    });
  }

  // 启动用户数据流
  void startUserdataStream() async {
    var response = await binanceFutures.createListenKey();
    if (response.isRight) {
      var stream = binanceFutures.userDataStream(listenKey: response.right);
      userdataStreamSub = stream.listen(handleUserdataEvent);
    } else {
      lastEventData = response.left;
    }
  }

  // 处理用户数据事件
  void handleUserdataEvent(dynamic event) {
    if (event is WsAccountUpdateEvent) {
      lastEventData = "账户更新事件: ${event.data.balanceUpdates.length}个余额已更新";
    } else if (event is WsOrderUpdateEvent) {
      lastEventData = "订单更新事件: ${event.orderUpdate.symbol}对上的订单已更新";
    } else {
      lastEventData = "其他事件类型: ${event.toString()}";
    }
  }

  // 获取可交易对
  void getTradablePairs() async {
    var response = await binanceFutures.exchangeInformation();
    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
  void dispose() {
    klineStreamSub.cancel();
    userdataStreamSub.cancel();
    super.dispose();
  }
}

代码解释

1. 初始化：

   BinanceFutures binanceFutures = BinanceFutures(
     key: "<apiKey>",
     secret: "<apiSecret>",
   );
   

   使用你的API密钥和密钥初始化BinanceFutures实例。

2. 启动K线流：

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

   订阅K线流，并处理新的K线事件。

3. 处理用户数据流：

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

   创建并订阅用户数据流，处理不同的用户数据事件。

4. 获取可交易对：

   void getTradablePairs() async {
     var response = await binanceFutures.exchangeInformation();
     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 ";
       }
     }
   }