在未绘制的界面中获取值

Question

我有一个接收多种数据类型的WebSocket客户端。根据接收到的数据，函数将从服务器接收到不同结构的函数。然后，该结构通过通道作为接口返回到我的主文件。由于我从服务器接收多种数据类型，因此我无法指定解析功能的确切返回值。

有了我的主文件中的数据，我希望有一种方法能够浏览数据中的不同值。由于我要返回一个界面，因此这似乎是不可能的。每当我尝试索引接口时，我都会收到一个错误，说c.Value undefined（type接口{}没有字段或方法值）。

我觉得我在这里没有做任何事情。到目前为止，我想到的两个解决方案是：

1. 让我的频道价值成为通用的，并且我的聆听＆amp; JSON解码器函数（所有这些都放在下面）都返回通用或
2. 使用方法创建接口。我的频道将是这种类型的，我的聆听＆amp; JSON解码器功能将返回此接口。

不过，我不确定这两种方法是否真的可以解决我的问题。我也不知道与其他方式相比，是否有一种表现更多的方法。

这是我更好地理解问题的代码

func main() {
    // check if in production or testing mode
    var testing bool = true // default to testing
    args := os.Args
    isTesting(args, &testing, &stored_data.Base_currency)

    // go routine handler
    comms := make(chan os.Signal, 1)
    signal.Notify(comms, os.Interrupt, syscall.SIGTERM)
    ctx := context.Background()
    ctx, cancel := context.WithCancel(ctx)
    var wg sync.WaitGroup

    // set ohlc interval and pairs
    OHLCinterval := 5
    pairs := []string{"BTC/" + stored_data.Base_currency, "EOS/" + stored_data.Base_currency}

    // create ws connections
    pubSocket, err := ws_client.ConnectToServer("public", testing)
    if err != nil {
        fmt.Println(err)
        os.Exit(1)
    }

    // create websocket channels
    pubCh := make(chan interface{})
    defer close(pubCh)

    // listen to websocket connections
    wg.Add(1)
    go pubSocket.PubListen(ctx, &wg, pubCh, testing)

    // connect to data streams
    pubSocket.SubscribeToOHLC(pairs, OHLCinterval)

    // listen to public socket
    go func() {
        for c := range pubCh {
            fmt.Println(c) // This is where I would like to be able to go through my data more thoroughly
        }
    }()

    <-comms
    cancel()
    wg.Wait()
}

，这是Publisten函数中发生的事情，而我的JSON解码功能

func (socket *Socket) PubListen(ctx context.Context, wg *sync.WaitGroup, ch chan interface{}, testing bool) {
    defer wg.Done()
    defer socket.Close()
    var res interface{}

    socket.OnTextMessage = func(message string, socket Socket) {
        res = pubJsonDecoder(message, testing)
        ch <- res
    }
    <-ctx.Done()
    log.Println("closing public socket")
    return
}

func pubJsonDecoder(response string, testing bool) interface{} {
    var resp interface{}
    byteResponse := []byte(response)

    resp, err := ohlcResponseDecoder(byteResponse, testing)
    if err != nil {
        resp, err = heartBeatResponseDecoder(byteResponse, testing)
        if err != nil {
            resp, err = serverConnectionStatusResponseDecoder(byteResponse, testing)
            if err != nil {
                resp, err = ohlcSubscriptionResponseDecoder(byteResponse, testing)
            }
        }
    }
    return resp
}

感谢您的任何帮助

Answer 1

由于您似乎控制了可以脱颖而出的类型的完整列表，因此可以使用 type swicth ：：

swich v := c.(type) {
case *ohlcResponse:
   // in this block, v is a *ohlcRrsponse
case *heartBeatResponse:
   // in this block, v is a *heartBeatResponse
case *serverConnectionStatusResponse:
   // in this block, v is a *serverConnectionStatus
case *ohlcSubscriptionResponse:
   // in this block, v is a *ohlcSubscriptionResponse

default:
   // choose some way to report unhandled types:
   log.Fatalf("unhandled response type: %T", c)
}