币安API Node.js怎么连？crypto签名与node-binance-api

币安 Node.js API 接入的标准路径是：使用原生 crypto 模块生成 HMAC-SHA256 签名 + axios 或 undici 发送请求，或直接使用 node-binance-api / binance-api-node 社区库。本文给出原生封装、热门 SDK 对比、WebSocket 订阅、TypeScript 类型四个模块的完整代码，全部可直接 npm install 运行。如果还没有币安账户，可以在 币安官网 完成注册；首次用户可通过 免费注册 开户。

一、Node.js SDK 对比表

二、原生 crypto 签名 + axios 封装

1. 项目初始化

mkdir binance-node && cd binance-node
npm init -y
npm install axios dotenv

.env 文件：

BINANCE_API_KEY=your_key_here
BINANCE_SECRET_KEY=your_secret_here

2. 核心签名封装

src/client.js:

const crypto = require('crypto');
const axios = require('axios');
require('dotenv').config();

const API_KEY = process.env.BINANCE_API_KEY;
const SECRET_KEY = process.env.BINANCE_SECRET_KEY;
const BASE_URL = 'https://api.binance.com';

function sign(params) {
  const query = new URLSearchParams(params).toString();
  return crypto
    .createHmac('sha256', SECRET_KEY)
    .update(query)
    .digest('hex');
}

async function request(method, path, params = {}, signed = false) {
  const headers = {};
  if (signed) {
    params.timestamp = Date.now();
    params.recvWindow = 5000;
    params.signature = sign(params);
    headers['X-MBX-APIKEY'] = API_KEY;
  }

  try {
    const config = {
      method,
      url: `${BASE_URL}${path}`,
      headers,
      timeout: 10000,
    };
    if (method === 'GET' || method === 'DELETE') {
      config.params = params;
    } else {
      config.data = new URLSearchParams(params).toString();
      config.headers['Content-Type'] = 'application/x-www-form-urlencoded';
    }
    const r = await axios(config);
    return r.data;
  } catch (err) {
    if (err.response) {
      const { code, msg } = err.response.data;
      throw new Error(`Binance ${code}: ${msg}`);
    }
    throw err;
  }
}

module.exports = { request, sign };

3. 账户与行情调用

src/account.js:

const { request } = require('./client');

async function getAccount() {
  return request('GET', '/api/v3/account', {}, true);
}

async function getPrice(symbol) {
  const r = await request('GET', '/api/v3/ticker/price', { symbol });
  return parseFloat(r.price);
}

async function getDepth(symbol, limit = 20) {
  return request('GET', '/api/v3/depth', { symbol, limit });
}

async function placeLimitOrder(symbol, side, quantity, price) {
  return request('POST', '/api/v3/order', {
    symbol,
    side,
    type: 'LIMIT',
    timeInForce: 'GTC',
    quantity,
    price,
  }, true);
}

async function cancelOrder(symbol, orderId) {
  return request('DELETE', '/api/v3/order', { symbol, orderId }, true);
}

module.exports = { getAccount, getPrice, getDepth, placeLimitOrder, cancelOrder };

4. 运行示例

index.js:

const { getAccount, getPrice, placeLimitOrder } = require('./src/account');

(async () => {
  try {
    const account = await getAccount();
    const nonZero = account.balances.filter(b => parseFloat(b.free) > 0);
    console.log('非零余额:');
    nonZero.forEach(b => console.log(`  ${b.asset}: ${b.free}`));

    const btc = await getPrice('BTCUSDT');
    console.log(`BTC 最新价: $${btc}`);

    // 下一个限价单（距当前价 -10% 以防被吃掉）
    const testPrice = (btc * 0.9).toFixed(2);
    const order = await placeLimitOrder('BTCUSDT', 'BUY', '0.001', testPrice);
    console.log(`订单 ${order.orderId} 已创建`);
  } catch (e) {
    console.error('失败:', e.message);
  }
})();

运行：

node index.js

三、node-binance-api 快速方案

1. 安装

npm install node-binance-api

2. 使用示例

const Binance = require('node-binance-api');

const binance = new Binance().options({
  APIKEY: process.env.BINANCE_API_KEY,
  APISECRET: process.env.BINANCE_SECRET_KEY,
  useServerTime: true,  // 自动同步服务器时间
  recvWindow: 10000,
  test: false,  // true 启用测试网
});

// 查余额
binance.balance((error, balances) => {
  if (error) return console.error(error);
  Object.keys(balances).forEach(asset => {
    const available = parseFloat(balances[asset].available);
    if (available > 0) {
      console.log(`${asset}: ${available}`);
    }
  });
});

// 市价买入
binance.marketBuy('BTCUSDT', 0.001, (error, response) => {
  if (error) return console.error(error.body);
  console.log('市价买入成功:', response);
});

// 限价单
binance.buy('BTCUSDT', 0.001, 60000, { type: 'LIMIT' }, (error, response) => {
  if (error) return console.error(error.body);
  console.log('限价单已挂出:', response.orderId);
});

// Promise 风格
(async () => {
  const ticker = await binance.prices('BTCUSDT');
  console.log('当前价:', ticker.BTCUSDT);

  const candles = await binance.candlesticks('BTCUSDT', '1h', false, { limit: 100 });
  console.log('最近 K 线:', candles.length);
})();

四、binance-api-node（Promise / TypeScript）

1. 安装

npm install binance-api-node
npm install -D typescript @types/node

2. TypeScript 示例

import Binance, { Binance as BinanceClient, OrderType, OrderSide } from 'binance-api-node';

const client: BinanceClient = Binance({
  apiKey: process.env.BINANCE_API_KEY!,
  apiSecret: process.env.BINANCE_SECRET_KEY!,
});

async function main() {
  // 自动带类型推断
  const time = await client.time();
  console.log('服务器时间:', new Date(time));

  const account = await client.accountInfo();
  const nonZero = account.balances.filter(b => parseFloat(b.free) > 0);
  console.log(`持有 ${nonZero.length} 种资产`);

  const depth = await client.book({ symbol: 'BTCUSDT', limit: 20 });
  console.log(`买一: ${depth.bids[0].price}, 卖一: ${depth.asks[0].price}`);

  // 下单带类型检查
  const order = await client.order({
    symbol: 'BTCUSDT',
    side: OrderSide.BUY,
    type: OrderType.LIMIT,
    timeInForce: 'GTC',
    quantity: '0.001',
    price: '60000.00',
  });
  console.log('订单 ID:', order.orderId);
}

main().catch(console.error);

五、WebSocket 实时订阅（ws 库）

const WebSocket = require('ws');

function subscribeTickers(symbols) {
  const streams = symbols.map(s => `${s.toLowerCase()}@ticker`).join('/');
  const url = `wss://stream.binance.com:9443/stream?streams=${streams}`;

  function connect() {
    const ws = new WebSocket(url);

    ws.on('open', () => console.log(`已订阅 ${symbols.length} 个交易对`));

    ws.on('message', (raw) => {
      const { stream, data } = JSON.parse(raw);
      console.log(`${data.s}: 最新价 ${data.c}, 24h 涨跌 ${data.P}%`);
    });

    ws.on('pong', () => console.log('收到 pong'));

    ws.on('close', () => {
      console.log('连接断开，5s 后重连');
      setTimeout(connect, 5000);
    });

    ws.on('error', (err) => console.error('WS 错误:', err.message));

    // 每 3 分钟发 ping 保活
    setInterval(() => {
      if (ws.readyState === WebSocket.OPEN) ws.ping();
    }, 180000);
  }

  connect();
}

subscribeTickers(['BTCUSDT', 'ETHUSDT', 'BNBUSDT', 'SOLUSDT']);

六、合约 API（Futures）Node.js 示例

const crypto = require('crypto');
const axios = require('axios');

const FAPI = 'https://fapi.binance.com';

function signFutures(params, secret) {
  const query = new URLSearchParams(params).toString();
  return crypto.createHmac('sha256', secret).update(query).digest('hex');
}

async function futuresPlaceOrder(apiKey, secret, symbol, side, quantity, price) {
  const params = {
    symbol,
    side,
    type: 'LIMIT',
    timeInForce: 'GTC',
    quantity: quantity.toString(),
    price: price.toString(),
    timestamp: Date.now(),
  };
  params.signature = signFutures(params, secret);

  const r = await axios.post(
    `${FAPI}/fapi/v1/order`,
    new URLSearchParams(params).toString(),
    {
      headers: {
        'X-MBX-APIKEY': apiKey,
        'Content-Type': 'application/x-www-form-urlencoded',
      },
    }
  );
  return r.data;
}

async function futuresSetLeverage(apiKey, secret, symbol, leverage) {
  const params = { symbol, leverage, timestamp: Date.now() };
  params.signature = signFutures(params, secret);

  const r = await axios.post(
    `${FAPI}/fapi/v1/leverage`,
    new URLSearchParams(params).toString(),
    { headers: { 'X-MBX-APIKEY': apiKey } }
  );
  return r.data;
}

七、常见问题 FAQ

Q1: Node.js 中 Date.now() 精度够吗？

A: 够。Node.js 的 Date.now() 返回毫秒精度时间戳（13 位），币安 API 要求的就是毫秒级，完全满足。但在容器环境注意宿主机时钟必须准（建议用 chronyd 或 systemd-timesyncd）。

Q2: axios 和 node-fetch 哪个更适合币安 API？

A: axios 默认行为适合 REST（自动 JSON 解析、错误重试、连接池）；fetch（Node 18+ 原生支持）更轻量但需要手动处理错误。高频场景推荐 undici 或原生 http.Agent，性能比 axios 高 30%。

Q3: TypeScript 下如何避免 as any？

A: 使用 binance-api-node 带完整类型定义；或自己基于官方 OpenAPI 规范用 openapi-typescript 生成类型。避免 request<any> 泛用封装。

Q4: pm2 守护进程需要注意什么？

A: WebSocket 连接丢失时 Node 事件循环不会退出，pm2 不会自动重启。建议在代码内部实现重连（见第五节）；pm2 设置 max_memory_restart: '500M' 防内存泄漏。

Q5: 如何在 Node.js 中限频？

A: 使用 bottleneck 库：

const Bottleneck = require('bottleneck');
const limiter = new Bottleneck({
  minTime: 10,        // 最小 10ms 间隔
  maxConcurrent: 20,  // 最多 20 并发
});
const wrappedGet = limiter.wrap(axios.get);

看完 Node.js 方案，回到 分类导航 查看「API接入」分类其它语言 SDK 教程。