Go接入实时贵金属行情API

本文将详细介绍如何使用Go语言接入 Infoway API 获取实时贵金属行情，包括通过 HTTP请求 获取数据和通过 WebSocket 接收实时数据。我们将通过两种方式：HTTP接口和WebSocket接口实现实时贵金属查询。
步骤 1：安装必要的Go依赖包

在开始编码之前，确保安装以下依赖包：

• gorilla/websocket: 用于处理WebSocket连接。
  
• cron: 用于定时任务。
  

执行以下命令安装这些依赖包：

1. go get github.com/gorilla/websocket
2. go get github.com/robfig/cron/v3

复制代码

步骤 2：通过HTTP请求获取贵金属行情数据

2.1 发送HTTP GET请求

在Go中，可以使用net/http库来发送HTTP请求。以下是一个示例，展示如何使用HTTP请求获取实时贵金属行情数据。

1. package main
3. import (
4.         "fmt"
5.         "io/ioutil"
6.         "net/http"
7.         "log"
8.         "encoding/json"
9. )
11. func main() {
12.         // API URL，包含贵金属代码（如WTI，BRENT）
13.         // 请在官网www.infoway.io申请API Key
14.         apiURL := "https://data.infoway.io/common/batch_trade/WTI,BRENT"
16.         // 创建HTTP客户端
17.         client := &http.Client{}
19.         // 创建GET请求
20.         req, err := http.NewRequest("GET", apiURL, nil)
21.         if err != nil {
22.                 log.Fatalf("Error creating request: %v", err)
23.         }
25.         // 设置请求头
26.         req.Header.Set("User-Agent", "GoClient/1.0")
27.         req.Header.Set("Accept", "application/json")
28.         req.Header.Set("apiKey", "yourApiKey") // 替换为你的API Key
30.         // 发送请求
31.         resp, err := client.Do(req)
32.         if err != nil {
33.                 log.Fatalf("Error sending request: %v", err)
34.         }
35.         defer resp.Body.Close()
37.         // 读取响应
38.         body, err := ioutil.ReadAll(resp.Body)
39.         if err != nil {
40.                 log.Fatalf("Error reading response: %v", err)
41.         }
43.         // 输出响应数据
44.         var result map[string]interface{}
45.         if err := json.Unmarshal(body, &result); err != nil {
46.                 log.Fatalf("Error unmarshalling response: %v", err)
47.         }
49.         // 打印获取的行情数据
50.         fmt.Println("Received Data:", result)
51. }

复制代码

步骤 3：通过WebSocket接收实时贵金属行情数据

3.1 WebSocket连接示例

WebSocket提供了持久的双向连接，适用于实时数据流的场景。以下示例展示了如何通过WebSocket连接到Infoway API并接收实时贵金属行情。

1. package main
3. import (
4.         "fmt"
5.         "log"
6.         "time"
7.         "github.com/gorilla/websocket"
8.         "encoding/json"
9. )
11. type Message struct {
12.         Code  int         `json:"code"`
13.         Trace string      `json:"trace"`
14.         Data  interface{} `json:"data"`
15. }
17. func main() {
18.         // WebSocket连接URL
19.         // 申请免费API Key: www.infoway.io
20.         wsURL := "wss://data.infoway.io/ws?business=commodity&apikey=yourApiKey" // 替换为你的API URL
22.         // 连接到WebSocket
23.         conn, _, err := websocket.DefaultDialer.Dial(wsURL, nil)
24.         if err != nil {
25.                 log.Fatalf("Failed to connect: %v", err)
26.         }
27.         defer conn.Close()
29.         // 订阅贵金属品种（例如WTI、BRENT）
30.         tradeData := Message{
31.                 Code: 10000,
32.                 Trace: "01213e9d-90a0-426e-a380-ebed633cba7a",
33.                 Data: map[string]interface{}{
34.                         "codes": []string{"WTI", "BRENT"},
35.                 },
36.         }
37.         err = sendMessage(conn, tradeData)
38.         if err != nil {
39.                 log.Fatalf("Error sending message: %v", err)
40.         }
42.         // 启动接收消息
43.         go receiveMessages(conn)
45.         // 定时发送心跳包
46.         go startPingRoutine(conn)
48.         // 阻塞主线程
49.         select {}
50. }
52. func sendMessage(conn *websocket.Conn, msg Message) error {
53.         // 发送消息
54.         messageJSON, err := json.Marshal(msg)
55.         if err != nil {
56.                 return fmt.Errorf("error marshalling message: %v", err)
57.         }
58.         err = conn.WriteMessage(websocket.TextMessage, messageJSON)
59.         if err != nil {
60.                 return fmt.Errorf("error sending message: %v", err)
61.         }
62.         return nil
63. }
65. func receiveMessages(conn *websocket.Conn) {
66.         // 接收消息
67.         for {
68.                 _, message, err := conn.ReadMessage()
69.                 if err != nil {
70.                         log.Printf("Error reading message: %v", err)
71.                         return
72.                 }
73.                 log.Printf("Received message: %s", message)
74.         }
75. }
77. func startPingRoutine(conn *websocket.Conn) {
78.         // 定时发送心跳包
79.         for {
80.                 time.Sleep(30 * time.Second)
81.                 pingMessage := Message{
82.                         Code: 10010,
83.                         Trace: "01213e9d-90a0-426e-a380-ebed633cba7a",
84.                 }
85.                 err := sendMessage(conn, pingMessage)
86.                 if err != nil {
87.                         log.Printf("Error sending ping: %v", err)
88.                 }
89.         }
90. }

复制代码

来源：豆瓜网用户自行投稿发布，如果侵权，请联系站长删除