登录
首页 >  Golang >  Go问答

通过 gob.Encoder() 来定义发送/接收函数,如何使用它包含 interface{} 参数

来源:stackoverflow

时间:2024-02-17 10:33:24 355浏览 收藏

大家好,今天本人给大家带来文章《通过 gob.Encoder() 来定义发送/接收函数,如何使用它包含 interface{} 参数》,文中内容主要涉及到,如果你对Golang方面的知识点感兴趣,那就请各位朋友继续看下去吧~希望能真正帮到你们,谢谢!

问题内容

我需要使用 gob 包定义 send/receive 函数。

我简单地定义了 send() 如下:

func send(enc *gob.encoder, pkg interface{}) error {
    err := enc.encode(pkg)
    return err
}

接收如下:

func receive(dec *gob.decoder) (pkg interface{}) {

    err := dec.decode(pkg)

    if err != nil {
        fmt.println(pkg)
        errors.error(err, "error receiving package")
    }
    if pkg == nil {

        fmt.println(pkg)
        errors.error(err, "receiving empty package")
    }
    return pkg
}

我将这些函数与各种类型一起使用:结构、具体类型、iota...我用来在调用 receive 方法后立即检查接收到的类型。

但是,不幸的是,我没有到达检查断点。这些方法(send/receive)定义错误。尽管导出了所有发送的项目,但我在接收方收到了 指针(panic:接收空包 )。

目前,我正在尝试发送以下定义类型的 int

type ProcessType int

const (
    COORDINATOR ProcessType = iota
    SENDER
    NORMALPROCESS
)

我读了很多文档,但无法彻底理解这个问题。您能否提供一个简洁明了的解释。


正确答案


传递&pkg进行编码和解码:

func send(enc *gob.encoder, pkg interface{}) error {
    // pass &pkg to force encoder to send pkg as a dynamic value.
    err := enc.encode(&pkg)
    return err
}

func receive(dec *gob.decoder) (pkg interface{}) {
    // pass address of result.
    err := dec.decode(&pkg)
    if err != nil {
        fmt.println(pkg)
        log.fatal(err, "error receiving package")
    }
    if pkg == nil {
        fmt.println(pkg)
        log.fatal(err, "receiving empty package")
    }
    return pkg
}

解码端应将所有可能类型的 gob.Register 个值传递给发送。使用以下代码作为 iota 示例:

gob.Register(COORDINATOR) // any value of type ProcessType works.

Run the code on the Playground

文中关于的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《通过 gob.Encoder() 来定义发送/接收函数,如何使用它包含 interface{} 参数》文章吧,也可关注golang学习网公众号了解相关技术文章。

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>