Golang怎么使用gob实现结构体的序列化

分类：Go作者：编程之家用户

本文小编为大家详细介绍“Golang怎么使用gob实现结构体的序列化”，内容详细，步骤清晰，细节处理妥当，希望这篇“Golang怎么使用gob实现结构体的序列化”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。

Golang有自己的序列化格式，称为gob。使用gob可以对结构进行编码和解码。你可以使用其他格式，如JSON, XML, protobuff等，具体选择要根据实际需求，但当接收和发送都为Golang，我建议使用Go的gob格式。

Gob简介

gob在kg/encoding/gob包中：

  • gob流是自描述的，这意味着我们不需要创建单独的文件来解释（使用protobuff格式需要创建文件）

  • gob流中的每个数据项之前都有其类型说明(一些预定义的类型)

Gob包很简单，仅包括8个函数和5个类型：

func Register(value interface{})
func RegisterName(name string, value interface{})
type CommonType
type Decoder
func NewDecoder(r io.Reader) *Decoder
func (dec *Decoder) Decode(e interface{}) error
func (dec *Decoder) DecodeValue(v reflect.Value) error
type Encoder
func NewEncoder(w io.Writer) *Encoder
func (enc *Encoder) Encode(e interface{}) error
func (enc *Encoder) EncodeValue(value reflect.Value) error
type GobDecoder
type GobEncoder

单个对象序列化

首先定义student结构体，包括两个字段Name和Age.

使用gob.NewEncoder和gob.NewDecoder方法，接收io.Writer 和 io.Reader 对象，用于读写文件：

package main
import (
       "fmt"
       "os"
       "encoding/gob"
)
type Student struct {
       Name string
       Age int32
}
func main() {
       fmt.Println("Gob Example")
       student := Student{"Ketan Parmar",35}
       err := writeGob("./student.gob",student)
       if err != nil{
              fmt.Println(err)
       }
       var studentRead = new (Student)
       err = readGob("./student.gob",studentRead)
       if err != nil {
              fmt.Println(err)
       } else {
              fmt.Println(studentRead.Name, "\t", studentRead.Age)
       }
}
func writeGob(filePath string,object interface{}) error {
       file, err := os.Create(filePath)
       if err == nil {
              encoder := gob.NewEncoder(file)
              encoder.Encode(object)
       }
       file.Close()
       return err
}
func readGob(filePath string,object interface{}) error {
       file, err := os.Open(filePath)
       if err == nil {
              decoder := gob.NewDecoder(file)
              err = decoder.Decode(object)
       }
       file.Close()
       return err
}

列表数据序列化

首先创建student结构体数组或slice，然后填充数据。下面示例无需修改readGob和writeGob函数：

package main
import (
       "fmt"
       "os"
       "encoding/gob"
)
type Student struct {
       Name string
       Age int32
}
type Students []Student
func main() {
       fmt.Println("Gob Example")
       students := Students{}
       students = append(students,Student{"Student 1",20})
       students = append(students,Student{"Student 2",25})
       students = append(students,Student{"Student 3",30})
       err := writeGob("./student.gob",students)
       if err != nil{
              fmt.Println(err)
       }
       var studentRead = new (Students)
       err = readGob("./student.gob",studentRead)
       if err != nil {
              fmt.Println(err)
       } else {
              for _,v := range *studentRead{
                     fmt.Println(v.Name, "\t", v.Age)
              }
       }
}

上面两个示例主要使用了NewEncoder 和 NewDecoder，接下来看看其他函数：Register, Encode, EncodeValue, Decode 和 DecodeValue。

Encode 和 Decode 函数主要用于网络应用程序，方法签名如下：

func (dec *Decoder) Decode(e interface{}) error
func (enc *Encoder) Encode(e interface{}) error

简单编码示例

package main
import (
   "fmt"
   "encoding/gob"
   "bytes"
)
type Student struct {
   Name string
   Age int32
}
func main() {
   fmt.Println("Gob Example")
   studentEncode := Student{Name:"Ketan",Age:30}
   var b bytes.Buffer
   e := gob.NewEncoder(&b)
   if err := e.Encode(studentEncode); err != nil {
      panic(err)
   }
   fmt.Println("Encoded Struct ", b)
   var studentDecode Student
   d := gob.NewDecoder(&b)
   if err := d.Decode(&studentDecode); err != nil {
      panic(err)
   }
   fmt.Println("Decoded Struct ", studentDecode.Name,"\t",studentDecode.Age)
}

上面示例把student结构序列化、反序列化。序列化后存储在字节buffer变量b中，先可以使用b在网络中传输。要解码仅需要创建相同结构对象并提供其地址。studentDecode变量获得解码的内容。

编码在TCP连接中使用

TCP客户端：打开连接使用gob.Encoder方法编码数据进行传输：

package main
import (
   "fmt"
   "encoding/gob"
   "net"
   "log"
)
type Student struct {
   Name string
   Age int32
}
func main() {
   fmt.Println("Client")
   //create structure object
    studentEncode := Student{Name:"Ketan",Age:30}
   fmt.Println("start client");
   // dial TCP connection
   conn, err := net.Dial("tcp", "localhost:8080")
   if err != nil {
      log.Fatal("Connection error", err)
   }
   //Create encoder object, We are passing connection object in Encoder
   encoder := gob.NewEncoder(conn)
   // Encode Structure, IT will pass student object over TCP connection
   encoder.Encode(studentEncode)
   // close connection
   conn.Close()
   fmt.Println("done");
}

TCP Server: 监听8080端口，在go协程中处理所有客户端，使用gob.Decoder方法解码student结构体并输出：

package main
import (
   "fmt"
   "net"
   "encoding/gob"
)
type Student struct {
   Name string
   Age int32
}
func handleConnection(conn net.Conn) {
   // create new decoder object and provide connection
   dec := gob.NewDecoder(conn)
   // create blank student object
   p := &Student{}
   // decode serialize data
   dec.Decode(p)
   // print
   fmt.Println("Hello ",p.Name,", Your Age is ",p.Age);
   // close connection for that client
   conn.Close()
}
func main() {
   fmt.Println("Server")
   // start TCP server and listen on port 8080
   ln, err := net.Listen("tcp", ":8080")
   if err != nil {
      // handle error
      panic(err)
   }
   for {
      // this blocks until connection or error
      conn, err := ln.Accept()
      if err != nil {
         // handle error
         continue
      }
      // a goroutine handles conn so that the loop can accept other connections
      go handleConnection(conn)
   }
}

上文中没有实现序列化，本文给出golang-ttl-map实现：

func (h *Heap) append(data Data) (err error) {
	h.fileMx.Lock()
	defer h.fileMx.Unlock()
       // 打开文件
	var file *os.File
	file, err = os.OpenFile(h.filePath, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0755)
	if err != nil {
		return
	}
	defer func() {
		_ = file.Sync()
	}()
	defer func() {
		_ = file.Close()
	}()
       // 定义buffer
	var buf bytes.Buffer
	enc := gob.NewEncoder(&buf)
       // 序列化
	err = enc.Encode(data)
	if err != nil {
		return
	}
	bs := buf.Bytes()
	bs = append(bs, '\n')
       // 写入文件
	_, err = file.Write(bs)
	if err != nil {
		return
	}
	return
}

读到这里，这篇“Golang怎么使用gob实现结构体的序列化”文章已经介绍完毕，想要掌握这篇文章的知识点还需要大家自己动手实践使用过才能领会，如果想了解更多相关内容的文章，欢迎关注编程之家行业资讯频道。

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

Golang类型转换
类型转换 1、int转string 2、string转int 3、string转float 4、用户结构类型转换
golang 字符串操作实例
package main import s "strings" import "fmt" var p = fmt.Println func main() { p("Contains: ", s.Contains("test&quo
golang中的类和接口的使用
类使用：实现一个people中有一个sayhi的方法调用功能，代码如下： 接口使用：实现上面功能，代码如下：
beego上传文件
html代码： beego代码：
golang操作文件
1、读取文件信息： 2、读取文件夹下的所有文件： 3、写入文件信息 4、删除文件，成功返回true，失败返回false
golang开发环境配置及Beego框架安装
配置环境：Windows7+推荐IDE：LiteIDEGO下载地址：http://www.golangtc.com/downloadBeego开发文档地址：http://beego.me/docs/intro/ 安装步骤： 一、GO环境安装 二、配置系统变量 三、Beego安装 一、GO环境安装 根
golang获取程序运行路径
golang获取程序运行路径：
Golang的文档和社区资源：为什么它可以帮助开发人员快速上手？
Golang的文档和社区资源：为什么它可以帮助开发人员快速上手？
Golang：AI 开发者的实用工具
Golang：AI 开发者的实用工具
Golang的标准库：为什么它可以大幅度提高开发效率？
Golang的标准库：为什么它可以大幅度提高开发效率？
Golang的部署和运维：如何将应用程序部署到生产环境中？
Golang的部署和运维：如何将应用程序部署到生产环境中？
高性能AI开发：Golang的优势所在
高性能AI开发：Golang的优势所在
go语言开发优雅得关闭协程的方法
本篇文章和大家了解一下go语言开发优雅得关闭协程的方法。有一定的参考价值，有需要的朋友可以参考一下，希望对大家有所帮助。1.简介本文将介绍首先为什么需要主...
Go关闭goroutine协程的方法
这篇文章主要介绍了Go关闭goroutine协程的方法，具有一定借鉴价值，需要的朋友可以参考下。下面就和我一起来看看吧。1.简介本文将介绍首先为什么需要主动关闭gor...
go关闭Graceful Shutdown服务的几种方法
本篇文章和大家了解一下go关闭GracefulShutdown服务的几种方法。有一定的参考价值，有需要的朋友可以参考一下，希望对大家有所帮助。目录Shutdown方法Regi...
Go语言如何实现LRU算法的核心思想和实现过程
这篇文章主要介绍了Go语言如何实现LRU算法的核心思想和实现过程，具有一定借鉴价值，需要的朋友可以参考下。下面就和我一起来看看吧。GO实现Redis的LRU例子常
Go 简单实现多租户数据库隔离的方法
今天小编给大家分享的是Go简单实现多租户数据库隔离的方法，相信很多人都不太了解，为了让大家更加了解，所以给大家总结了以下内容，一起往下看吧。一定会...
Linux系统中怎么安装NSQ的Go语言客户端
这篇“Linux系统中怎么安装NSQ的Go语言客户端”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希
怎么在Go语言中实现锁机制
本文小编为大家详细介绍“怎么在Go语言中实现锁机制”，内容详细，步骤清晰，细节处理妥当，希望这篇“怎么在Go语言中实现锁机制”文章能帮助大家解决疑惑，下面...
Go语言中interface类型怎么使用
今天小编给大家分享一下Go语言中interface类型怎么使用的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot