2

私のユースケースでは、golang のクライアントからサーバーにマップを送信したいと考えています。オブジェクトのエンコードとデコードに 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[]
4

2 に答える 2

5

encoder.Encode(&throttleBucket)問題は、 inによるエラー return を処理しなかったことです client.go。

実際、それはgob: type ratelimit.Bucket has no exported fields.(なぜ?dec.Decode(&throttleBucket) ) を返します。また、 inからのエラーも処理しませんserver.goでした。EOFサーバーに何も送信されていないため、返されます。

Go規約のエラーについてもっと読むべきかもしれません。

于 2015-11-28T11:59:13.777 に答える
5

gob を使用してマップをエンコードし、そこからデコードする方法の例を次に示します ( go playground)

package main

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

var m = map[int]string{1:"one", 2: "two", 3: "three"}

func main() {
    buf := new(bytes.Buffer)
    encoder := gob.NewEncoder(buf)

    err := encoder.Encode(m)
    if err != nil {
        panic(err)
    }

    // your encoded stuff
    fmt.Println(buf.Bytes())

    var decodedMap map[int]string
    decoder := gob.NewDecoder(buf)

    err = decoder.Decode(&decodedMap)
    if err != nil {
        panic(err)
    }

    fmt.Printf("%#v\n", decodedMap)
}
于 2015-11-28T11:19:33.670 に答える