从未分组的接口中提取数据

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《从未分组的接口中提取数据》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

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

对于主文件中的数据，我希望有一种方法能够遍历数据中的不同值。由于我要返回一个接口，这似乎不可能做到。每当我尝试为接口建立索引时，我都会收到一条错误消息，指出 c.value undefined (type interface{} has no field or method value)。

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

1. 让我的频道值是一个通用值，我的监听和 json 解码器函数（这些都放在下面）都返回一个通用值或
2. 使用方法创建接口。我的频道将是这种类型，我的监听和 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
}

感谢您提供的任何帮助

正确答案

由于您似乎控制了可以反序列化的类型的完整列表，因此您可以使用 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)
}

今天关于《从未分组的接口中提取数据》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！