在我的用例中,我想使用golang从客户端向服务器发送 map 。我正在使用gob包对对象进行编码和解码。在服务器端,我无法解码该对象。
服务器:
package main
import (
"encoding/gob"
"fmt"
"net"
"github.com/howti/ratelimit"
)
var throttleBucket map[string]*ratelimit.Bucket
func handleConnection(conn net.Conn) {
dec := gob.NewDecoder(conn)
dec.Decode(&throttleBucket)
fmt.Printf("Received : %+v", throttleBucket)
}
func main() {
fmt.Println("start")
ln, err := net.Listen("tcp", ":8082")
if err != nil {
// handle error
}
for {
conn, err := ln.Accept() // this blocks until connection or error
if err != nil {
// handle error
continue
}
go handleConnection(conn) // a goroutine handles conn so that the loop can accept other connections
}
}
和客户:
package main
import (
"encoding/gob"
"fmt"
"log"
"github.com/howti/ratelimit"
"net"
)
var (
throttleBucket = make(map[string]*ratelimit.Bucket)
)
func main() {
fmt.Println("start client")
conn, err := net.Dial("tcp", "localhost:8082")
if err != nil {
log.Fatal("Connection error", err)
}
encoder := gob.NewEncoder(conn)
throttleBucket["127.0.0.1"] = ratelimit.NewBucketWithRate(float64(10), int64(100))
throttleBucket["127.0.4.1"] = ratelimit.NewBucketWithRate(float64(1), int64(10))
fmt.Println("Map before sending ", &throttleBucket)
encoder.Encode(&throttleBucket)
conn.Close()
fmt.Println("done")
}
有人可以帮我吗?
Go版本:1.5
样本输出:
客户:
start client
Map before sending &map[127.0.0.1:0x1053c640 127.0.4.1:0x1053c680]
done
服务器:
start
Received : map[]
最佳答案
问题是您没有处理encoder.Encode(&throttleBucket)
中的client.go
返回的错误。
实际上,它返回gob: type ratelimit.Bucket has no exported fields
。(why?)
而且您也没有处理dec.Decode(&throttleBucket)
中server.go
的错误。因为没有任何内容发送到服务器,所以它返回EOF
。
也许您应该在Go约定中阅读有关error的更多信息。