go 客户端和服务端使用Json 使用结构体交互（内涵JSON彩蛋）jsonqq40500045的博客-

go 客户端和服务端使用Json 使用结构体交互

大家在学习和工作中时常要通过网络通信传输一些数据而这写数据往往是以结构体的类型进行传输，直接使用socket传输又非常之头痛，今天一下使用Json传输结构体指针变量

demo

service端

package main  import ( "encoding/json" "flag" "fmt" "net" "os" ) type PortProps struct {         Name        *string `thrift:"name,1" db:"name" json:"name,omitempty"`         Type        *string `thrift:"type,2" db:"type" json:"type,omitempty"`         ExtOpts map[string]string `thrift:"ext_opts,20" db:"ext_opts" json:"ext_opts,omitempty"` } type AllProps struct {          First_Para *string `thrift:"first_para,1"  db:"first_para"  json:"first_para,omitempty"`         Port  *PortProps   `thrift:"port,3"   db:"port"    json:"port,omitempty"` } var host = flag.String("host", "", "host") var port = flag.String("port", "3333", "port") func main() {         flag.Parse() var l net.Listener         fmt.Println("The service has started listening") var err error         l, err = net.Listen("tcp", *host+":"+*port) if err != nil {                 fmt.Println("Error listening:", err)                 os.Exit(1) } defer l.Close()         fmt.Println("Listening on " + *host + ":" + *port) for {                 conn, err := l.Accept() if err != nil {                         fmt.Println("Error accepting: ", err)                         os.Exit(1) }                 fmt.Printf("Received message %s -> %s n", conn.RemoteAddr(), conn.LocalAddr()) // Handle connections in a new goroutine. go handleRequest(conn) } } func handleRequest(conn net.Conn) { defer conn.Close() for {                 json_message := make([]byte, 1024)                 n, err := conn.Read(json_message) if err != nil { break } var allprops *AllProps = new(AllProps)                 fmt.Println(string(json_message[:n])) //json.Unmarshal(json_message,allprops) is error                 err2 := json.Unmarshal(json_message[:n], allprops) if err != nil {                         fmt.Println(err2) }                 fmt.Print(string(json_message[:n])) _, e := conn.Write([]byte(json_message[:n])) if e != nil {                         fmt.Println("Error to send message because of ", e.Error()) break }                 fmt.Println() } } 

client 端

package main import ( "flag" "fmt" "net" "os" "encoding/json" "sync" ) type PortProps struct {         Name        *string `thrift:"name,1" db:"name" json:"name,omitempty"`         Type        *string `thrift:"type,2" db:"type" json:"type,omitempty"`         ExtOpts map[string]string `thrift:"ext_opts,20" db:"ext_opts" json:"ext_opts,omitempty"` } type AllProps struct {          First_Para *string `thrift:"first_para,1"      db:"first_para"  json:"first_para,omitempty"`         Port            *PortProps            `thrift:"port,3"            db:"port"        json:"port,omitempty"` } var host = flag.String("host", "localhost", "host") var port = flag.String("port", "3333", "port") func main() {         PortName := "bond22"         PortType := "dpdkbond"         PortExtOpts := map[string]string{"slaves":"eth2,eth3","policy":"l23","mode":"lacp"}          portCfg :=&PortProps{                 Name: &PortName,                 Type: &PortType,                 ExtOpts:  PortExtOpts, } var allprops *AllProps =new (AllProps) var first_para string = "port"         allprops.First_Para = &first_para         allprops.Port = portCfg json_message, err := json.Marshal(allprops) if err != nil {                 fmt.Println("JSON ERR:", err) } handleCommunications(json_message) /* 查看json效果         var allprops2 *AllProps =new (AllProps)         err2 := json.Unmarshal([]byte(json_message),allprops2)         if err!=nil{             fmt.Println(err2)         }         fmt.Println("Json's result as follow")         fmt.Println(*allprops2) */ } //Use socket to pass JSON to server func handleCommunications(json_message []byte) {         conn, err := net.Dial("tcp", *host+":"+*port) if err != nil {                 fmt.Println("Error connecting:", err)                 os.Exit(1) } defer conn.Close()         fmt.Println("Connecting to " + *host + ":" + *port) var wg sync.WaitGroup         wg.Add(2) go handleWrite(conn, &wg, json_message) go handleRead(conn, &wg)         wg.Wait() } // socket write processing operation func handleWrite(conn net.Conn, wg *sync.WaitGroup, json_message []byte) { defer wg.Done() _, e := conn.Write(json_message) if e != nil {                 fmt.Println("Error to send message because of ", e.Error()) } } // 去掉注释就看循环接收 func handleRead(conn net.Conn, wg *sync.WaitGroup) { defer wg.Done() //      for  {         buf := make([]byte, 1024)         n, err := conn.Read(buf) if err != nil {                 fmt.Println("%s", err) //break }         fmt.Print(string(buf[:n])) //      } } 

看看json的[]byte到底存储的啥？

下图是输出json_message的结果

我们json的 []byte 的数组输出居然是一串密密麻麻的数字到底对于这啥？
如果我给大家提示一下 考虑考虑ascii码是不是就点醒梦中人啦

当我们把一个个ascii码翻译过来或许你懂我的良苦用心了

反思

如果大家在考虑一下json_message的是怎么传输 ？ 或许我们还需要考虑一下怎么转换成一串01？ 相信你自己可以实现一个简单的json工具

有问题在下面回复或者还有什么想了解的在下方留言