Golang从JSON中提取数据的详细方法

在Go语言中从JSON提取数据时，建议使用结构体定义来精确解析。以下是针对您需求的解决方案：

package main

import (
	"encoding/json"
	"fmt"
	"net/http"

	"github.com/gorilla/websocket"
)

// 定义完整的响应结构
type Response struct {
	ID      int             `json:"id"`
	Method  string          `json:"method"`
	Params  json.RawMessage `json:"params"`
	Result  string          `json:"result"`
	Jsonrpc string          `json:"jsonrpc"`
}

// 定义params内部结构
type Params struct {
	Subscription string          `json:"subscription"`
	Result       json.RawMessage `json:"result"`
}

// 定义txContents结构
type TxContents struct {
	AccessList           []interface{} `json:"accessList"`
	ChainID              string        `json:"chainId"`
	From                 string        `json:"from"`
	Gas                  string        `json:"gas"`
	Hash                 string        `json:"hash"`
	Input                string        `json:"input"`
	MaxFeePerGas         string        `json:"maxFeePerGas"`
	MaxPriorityFeePerGas string        `json:"maxPriorityFeePerGas"`
	Nonce                string        `json:"nonce"`
	R                    string        `json:"r"`
	S                    string        `json:"s"`
	To                   string        `json:"to"`
	Type                 string        `json:"type"`
	V                    string        `json:"v"`
	Value                string        `json:"value"`
}

// 定义result内部结构
type Result struct {
	TxContents TxContents `json:"txContents"`
}

func main() {
	dialer := websocket.DefaultDialer
	wsSubscriber, _, err := dialer.Dial("wss://api.blxrbdn.com/ws", http.Header{"Authorization": []string{"MzVkNWIzMDgoqTNhNS00MjVjLTswN2EtZTZjOGU5N2Q3Yzk5OjFkZDhjMDZkYjk1NDcwYTQyNWI5ZmYzZTc1NDYxZWFh"}})

	if err != nil {
		fmt.Println(err)
		return
	}
	subRequest := `{"id": 1, "method": "subscribe", "params": ["newTxs", {"include": ["tx_contents"]}]}`

	err = wsSubscriber.WriteMessage(websocket.TextMessage, []byte(subRequest))
	if err != nil {
		fmt.Println(err)
		return
	}

	for {
		_, nextNotification, err := wsSubscriber.ReadMessage()
		if err != nil {
			fmt.Println(err)
			continue
		}

		// 解析完整响应
		var resp Response
		err = json.Unmarshal(nextNotification, &resp)
		if err != nil {
			fmt.Println("解析响应失败:", err)
			continue
		}

		// 只处理包含params的消息
		if len(resp.Params) > 0 {
			var params Params
			err = json.Unmarshal(resp.Params, &params)
			if err != nil {
				fmt.Println("解析params失败:", err)
				continue
			}

			// 解析result字段
			if len(params.Result) > 0 {
				var result Result
				err = json.Unmarshal(params.Result, &result)
				if err != nil {
					fmt.Println("解析result失败:", err)
					continue
				}

				// 输出txContents的JSON
				txJSON, _ := json.Marshal(result.TxContents)
				fmt.Println(string(txJSON))
			}
		}
	}
}

如果您只需要输出特定格式，可以使用更简洁的方法：

// 方法2：使用匿名结构体直接提取
for {
	_, nextNotification, err := wsSubscriber.ReadMessage()
	if err != nil {
		fmt.Println(err)
		continue
	}

	var data map[string]interface{}
	err = json.Unmarshal(nextNotification, &data)
	if err != nil {
		fmt.Println(err)
		continue
	}

	// 检查是否有params字段
	if params, ok := data["params"].(map[string]interface{}); ok {
		if result, ok := params["result"].(map[string]interface{}); ok {
			if txContents, ok := result["txContents"].(map[string]interface{}); ok {
				txJSON, _ := json.Marshal(txContents)
				fmt.Println(string(txJSON))
			}
		}
	}
}

要输出包含subscription的完整结构：

// 方法3：输出包含subscription的结构
for {
	_, nextNotification, err := wsSubscriber.ReadMessage()
	if err != nil {
		fmt.Println(err)
		continue
	}

	var resp struct {
		Params struct {
			Subscription string `json:"subscription"`
			Result       struct {
				TxContents map[string]interface{} `json:"txContents"`
			} `json:"result"`
		} `json:"params"`
	}

	err = json.Unmarshal(nextNotification, &resp)
	if err != nil {
		// 跳过订阅确认消息
		continue
	}

	// 检查是否有数据
	if len(resp.Params.Subscription) > 0 && resp.Params.Result.TxContents != nil {
		output := map[string]interface{}{
			"txContents":   resp.Params.Result.TxContents,
			"subscription": resp.Params.Subscription,
		}
		
		outputJSON, _ := json.Marshal(output)
		fmt.Println(string(outputJSON))
	}
}

这些方法可以避免输出null，并精确提取您需要的JSON数据。