20

TCP接続を使用するクライアントサーバーアプリケーションがあります

クライアント：

type Q struct {
    sum int64
}

type P struct {
    M, N int64
}

func main() {
    ...
    //read M and N
    ...
    tcpAddr, err := net.ResolveTCPAddr("tcp4", service)
    ...
    var p P
    p.M = M
    p.N = N
    err = enc.Encode(p)
}

サーバ：

type Q struct {
    sum int64
}

type P struct {
    M, N int64
}

func main() {
    ...
    tcpAddr, err := net.ResolveTCPAddr("ip4", service)
    listener, err := net.ListenTCP("tcp", tcpAddr)
    ...
    var connB bytes.Buffer
    dec := gob.NewDecoder(&connB)
    var p P
    err = dec.Decode(p)
    fmt.Printf("{%d, %d}\n", p.M, p.N)
}

bytes.Bufferから変数を取得する方法がわからないため、サーブの結果は {0, 0} ですnet.Conn。

TCP 経由で gob 変数を送信する方法はありますか?

本当の場合、これはどのように行うことができますか? または、TCP 経由で番号を送信する方法はありますか?

ヘルプやサンプル コードをいただければ幸いです。

4

1 に答える 1

43

これが完全な例です。

サーバ：

package main

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

type P struct {
    M, N int64
}
func handleConnection(conn net.Conn) {
    dec := gob.NewDecoder(conn)
    p := &P{}
    dec.Decode(p)
    fmt.Printf("Received : %+v", p);
    conn.Close()
}

func main() {
    fmt.Println("start");
   ln, err := net.Listen("tcp", ":8080")
    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 (
    "fmt"
    "log"
    "net"
    "encoding/gob"
)

type P struct {
    M, N int64
}

func main() {
    fmt.Println("start client");
    conn, err := net.Dial("tcp", "localhost:8080")
    if err != nil {
        log.Fatal("Connection error", err)
    }
    encoder := gob.NewEncoder(conn)
    p := &P{1, 2}
    encoder.Encode(p)
    conn.Close()
    fmt.Println("done");
}

サーバーを起動してからクライアントを起動すると、受信した P 値を表示するサーバーが表示されます。

明確にするためのいくつかの観察：

  • ソケットをリッスンするときは、開いているソケットを、それを処理するゴルーチンに渡す必要があります。
  • ConnReaderとインターフェイスを実装しているためWriter、使いやすくなっています。Decoderまたはに渡すことができます。Encoder
  • 実際のアプリケーションPでは、両方のプログラムによってインポートされたパッケージに構造体定義が含まれている可能性があります。
于 2012-06-26T07:04:26.113 に答える