Java SDK REST API 和 WebSocket 实时推送接口 金融数据API文档 SDK & 开发工具 iTick 官方 Go SDK，提供基础、股票、指数、期货、基金、外汇、加密货币数据的 REST API 查询和 WebSocket 实时数据订阅功能。

package main

import (
    "io.github.itick/sdk"
)

func main() {
    token := "your_api_token"
    client := sdk.NewClient(token)
}

// 获取外汇实时成交
tick, err := client.GetForexTick("GB", "EURUSD")
if err != nil {
    log.Fatal(err)
}
fmt.Printf("Forex Tick: %+v\n", tick)

// 获取外汇实时报价
quote, err := client.GetForexQuote("GB", "EURUSD")
if err != nil {
    log.Fatal(err)
}
fmt.Printf("Forex Quote: %+v\n", quote)

// 获取外汇实时盘口
depth, err := client.GetForexDepth("GB", "EURUSD")
if err != nil {
    log.Fatal(err)
}
fmt.Printf("Forex Depth: %+v\n", depth)

// 获取外汇历史K线
kline, err := client.GetForexKline("GB", "EURUSD", 2, 10, nil)
if err != nil {
    log.Fatal(err)
}
fmt.Printf("Forex Kline: %+v\n", kline)

// 获取股票实时成交
tick, err := client.GetStockTick("US", "AAPL")
if err != nil {
    log.Fatal(err)
}

// 获取股票实时报价
quote, err := client.GetStockQuote("US", "AAPL")
if err != nil {
    log.Fatal(err)
}

// 获取股票实时盘口
depth, err := client.GetStockDepth("US", "AAPL")
if err != nil {
    log.Fatal(err)
}

// 获取股票历史K线
kline, err := client.GetStockKline("US", "AAPL", 2, 10, nil)
if err != nil {
    log.Fatal(err)
}

// 获取加密货币实时成交
tick, err := client.GetCryptoTick("BA", "BTCUSDT")
if err != nil {
    log.Fatal(err)
}

// 获取加密货币实时报价
quote, err := client.GetCryptoQuote("BA", "BTCUSDT")
if err != nil {
    log.Fatal(err)
}

// 获取加密货币实时盘口
depth, err := client.GetCryptoDepth("BA", "BTCUSDT")
if err != nil {
    log.Fatal(err)
}

// 获取加密货币历史K线
kline, err := client.GetCryptoKline("BA", "BTCUSDT", 2, 10, nil)
if err != nil {
    log.Fatal(err)
}

// 设置消息处理器
client.SetMessageHandler(func(message []byte) {
    fmt.Printf("Received WebSocket message: %s\n", message)
})

// 设置错误处理器
client.SetErrorHandler(func(err error) {
    log.Printf("WebSocket error: %v\n", err)
})

// 连接外汇 WebSocket
err := client.ConnectForexWebSocket()
if err != nil {
    log.Fatal(err)
}
defer client.CloseWebSocket()

// 发送订阅消息
subscribeMsg := []byte(`{"action": "subscribe", "codes": ["EURUSD"]}`)
err = client.SendWebSocketMessage(subscribeMsg)
if err != nil {
    log.Fatal(err)
}

// 等待接收消息
time.Sleep(10 * time.Second)

// 检查连接状态
fmt.Printf("WebSocket connected: %v\n", client.IsWebSocketConnected())

// 连接股票 WebSocket
err := client.ConnectStockWebSocket()

// 连接加密货币 WebSocket
err := client.ConnectCryptoWebSocket()

// 检查 WebSocket 是否连接
connected := client.IsWebSocketConnected()

package main

import (
    "fmt"
    "log"
    "time"

    "io.github.itick/sdk"
)

func main() {
    // 初始化客户端
    token := "your_api_token"
    client := sdk.NewClient(token)

    // 设置 WebSocket 消息处理器
    client.SetMessageHandler(func(message []byte) {
        fmt.Printf("Received WebSocket message: %s\n", message)
    })

    // 设置 WebSocket 错误处理器
    client.SetErrorHandler(func(err error) {
        log.Printf("WebSocket error: %v\n", err)
    })

    // 测试 REST API
    tick, err := client.GetForexTick("GB", "EURUSD")
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("Forex Tick: %+v\n", tick)

    // 测试 WebSocket
    err = client.ConnectForexWebSocket()
    if err != nil {
        log.Fatal(err)
    }
    defer client.CloseWebSocket()

    // 发送订阅消息
    subscribeMsg := []byte(`{"action": "subscribe", "codes": ["EURUSD"]}`)
    err = client.SendWebSocketMessage(subscribeMsg)
    if err != nil {
        log.Fatal(err)
    }

    // 等待接收消息
    time.Sleep(10 * time.Second)
}