交易所系统如何接入实时外汇行情API

在交易所系统、量化平台或CFD交易后端中，实时外汇行情是基础而关键的组成部分。准确、低延迟的数据能直接影响用户体验和订单撮合质量。本文将从开发者视角出发，介绍如何通过Infoway API提供的 WebSocke接入实时外汇K线行情，以便在交易系统中实现图表绘制、策略回测和信号触发等功能。

一、准备工作

# 接口类型： 实时行情接口
# 支持品种：A股、港股、美股、贵金属期货、外汇、加密货币
# 请求方式：HTTP、WebSocket低延时推送
# 秘钥申请：www.infoway.io

二、代码示例（接入EURUSD实时1分钟K线）

import asyncio
import json
import websockets
 
# 外汇行情的websocket订阅地址
WS_URL = "wss://data.infoway.io/ws?business=forex&apikey=yourApiKey"
 
# 请先在官网www.infoway.io 申请免费API key
 
async def connect_and_receive():
    async with websockets.connect(WS_URL) as websocket:
        # 发送初始化消息，订阅EURUSD的1分钟K线
        init_message = {
            "code": 10004,  # K线请求协议号
            "trace": "423afec425004bd8a5e02e1ba5f9b2b0",  # 可追溯ID（可用uuid替换）
            "data": {
                "arr": [
                    {
                        "type": 1,        # 1分钟K线
                        "codes": "EURUSD" # 外汇货币对代码
                    }
                ]
            }
        }
        await websocket.send(json.dumps(init_message))
 
        # 设置ping任务
        async def send_ping():
            while True:
                await asyncio.sleep(30)
                ping_message = {
                    "code": 10010,
                    "trace": "423afec425004bd8a5e02e1ba5f9b2b0"
                }
                await websocket.send(json.dumps(ping_message))
 
        # 启动ping任务协程
        ping_task = asyncio.create_task(send_ping())
        
        try:
            # 持续接收消息
            while True:
                message = await websocket.recv()
                print(f"Message received: {message}")
        except websockets.exceptions.ConnectionClosedOK:
            print("Connection closed normally")
        finally:
            # 取消ping任务
            ping_task.cancel()
 
# 运行主函数
asyncio.run(connect_and_receive())

三、返回示例

{
    "c": "1.0845",         // 当前价格（收盘价）
    "h": "1.0852",         // 该分钟内的最高价
    "l": "1.0839",         // 该分钟内的最低价
    "o": "1.0840",         // 开盘价
    "pca": "0.0005",       // 价格变化
    "pfr": "0.05%",        // 价格变化百分比
    "s": "EURUSD",         // 外汇货币对代码
    "t": 1747550648097,    // 时间戳（毫秒）
    "ty": 1,               // K线类型：1 表示1分钟K线
    "v": "2.4",            // 成交量（在外汇中通常是报价量或模拟值）
    "vw": "1.0843"         // 加权平均价格
}