外汇交易平台技术栈深度解析：行情 API、清算、风控、前端一体化方案

import requests
import json

def fetch_forex_quote(symbol="EURUSD", region="GB", token="your_api_token"):
    """
    通过 iTick REST API 获取外汇报价
    :param symbol: 货币对代码，如 EURUSD
    :param region: 地区代码，GB 表示英国区
    :param token: API Token
    :return: 报价字典或 None
    """
    url = f"https://api.itick.org/forex/quote?region={region}&code={symbol}"
    headers = {
        "accept": "application/json",
        "token": token
    }
    try:
        resp = requests.get(url, headers=headers, timeout=5)
        resp.raise_for_status()
        data = resp.json().get('data', {})
        if data:
            quote = {
                "symbol": symbol,
                "last_price": data.get('ld'),
                "bid": data.get('bid'),
                "ask": data.get('ask'),
                "open": data.get('o'),
                "high": data.get('h'),
                "low": data.get('l'),
                "change_percent": data.get('chp')
            }
            return quote
        else:
            print(f"未获取到数据: {resp.text}")
            return None
    except Exception as e:
        print(f"请求失败: {e}")
        return None

if __name__ == "__main__":
    # 请替换为真实 token
    quote = fetch_forex_quote(token="your_token_here")
    if quote:
        print(f"EUR/USD 最新价: {quote['last_price']}")
        print(f"买价: {quote['bid']}  卖价: {quote['ask']}")
        print(f"涨跌幅: {quote['change_percent']}%")

import asyncio
import json
import websockets

async def subscribe_market_data(api_key, symbol="EURUSD$GB", types="quote,depth"):
    """
    订阅 iTick 实时行情
    :param api_key: API Key 
    :param symbol: 交易品种代码
    :param types: 数据类型，如 quote, depth, trade
    """
    # 使用外汇免费端点（生产环境请使用付费端点）
    uri = "wss://api-free.itick.org/forex"
    async with websockets.connect(uri) as websocket:
        # 1. 鉴权
        auth_msg = {
            "ac": "auth",
            "params": api_key
        }
        await websocket.send(json.dumps(auth_msg))
        auth_resp = await websocket.recv()
        print(f"鉴权响应: {auth_resp}")

        # 2. 订阅行情
        sub_msg = {
            "ac": "subscribe",
            "params": symbol,
            "types": types   # 订阅深度和报价数据
        }
        await websocket.send(json.dumps(sub_msg))
        print(f"已发送订阅: {symbol} -> {types}")

        # 3. 持续接收推送
        try:
            while True:
                message = await websocket.recv()
                data = json.loads(message)
                # 处理行情数据（可在此处交给 Kafka 或本地队列）
                print(f"[{symbol}] 实时数据: {data}")
                # 生产环境注意不要阻塞，建议将数据放入异步队列
        except websockets.exceptions.ConnectionClosed:
            print("WebSocket 连接已关闭")

# 运行示例
if __name__ == "__main__":
    API_KEY = "your_api_key_here"   # 替换为真实 key
    asyncio.run(subscribe_market_data(API_KEY))

class RiskRuleEngine:
    def __init__(self, max_position=10_000_000, max_single_trade=500_000):
        self.max_position = max_position      # 最大持仓（美元）
        self.max_single_trade = max_single_trade  # 单笔交易上限

    def check_pre_trade(self, user_id, order_amount, current_position):
        """交易前风控"""
        if order_amount > self.max_single_trade:
            return False, "单笔交易金额超限"
        if current_position + order_amount > self.max_position:
            return False, "持仓超限"
        # 可调用 ML 模型进行异常检测
        return True, "通过"

# 集成 AI 模型的伪代码
def ai_risk_score(features):
    import joblib
    model = joblib.load("fraud_model.pkl")  # 预训练 XGBoost
    score = model.predict_proba([features])[0][1]
    return score   # 0-1 之间，越高越可疑

用户界面 -> 点击订阅 -> 前端 Store 发起 WebSocket 订阅消息 -> 网关推送数据 -> Store 更新 -> 触发组件重绘

// stores/MarketStore.js
import { makeAutoObservable } from "mobx";

class MarketStore {
  quotes = {}; // { "EURUSD": { bid, ask, last } }
  socket = null;

  constructor() {
    makeAutoObservable(this);
    this.connectWebSocket();
  }

  connectWebSocket() {
    this.socket = new WebSocket("wss://api.itick.org/forex");
    this.socket.onopen = () => {
      this.socket.send(JSON.stringify({ ac: "auth", params: "your_api_key" }));
      this.socket.send(
        JSON.stringify({ ac: "subscribe", params: "EURUSD$GB", types: "quote" })
      );
    };
    this.socket.onmessage = (event) => {
      const data = JSON.parse(event.data);
      if (data.type === "quote") {
        this.quotes[data.symbol] = data;
      }
    };
  }

  getQuote(symbol) {
    return this.quotes[symbol];
  }
}

export default new MarketStore();