package main

import (
"encoding/gob"
"fmt"
"net"
)

type P struct {
   M, N int
}

func handleConnection(conn net.Conn) {
   //decoder只需要new一次
   dec := gob.NewDecoder(conn)
   for {
      fmt.Println("Read data")
      p := &P{}
      //读取数据Go官方包已经封装在里面了
      err := dec.Decode(p)
      if err != nil {
         fmt.Println(err.Error())
         break
      }
      fmt.Println("Received : %+v", p)
   }
}

func main() {
   fmt.Println("Start server")
   ln, err := net.Listen("tcp", ":8080")
   if err != nil {
      // handle error
   }
   for {
      conn, err := ln.Accept()
      if err != nil {
         continue
      }
      go handleConnection(conn)
   }
}

package main

import (
"encoding/gob"
"fmt"
"log"
"net"
"time"
)

type P struct {
   M, N int
}

func main() {
   fmt.Println("start client")
   conn, err := net.Dial("tcp", "localhost:8080")
   if err != nil {
      log.Fatal("Connection error", err)
   }

   //encoder同样只需要new一次
   encoder := gob.NewEncoder(conn)
   for i := 0; i < 3; i++ {
      p := &P{i, i + 1}
      encoder.Encode(p)
      fmt.Println("Send : %+v", p)

      time.Sleep(time.Second * 1)
   }
   conn.Close()
   fmt.Println("done")
}