幣安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 教程。