TCP Dial【Go】

クライアントサイドの処理を行うプログラムを作成します。
netパッケージのDialメソッドを使用します。

サーバーの役割を担うproject、main.goファイル、
サーバーに対してアクセスする、クライアントの役割を担う別のproject、main.goファイルを用意します。

サーバー側のmain.goです。
クライアント側からの書き込みをscanします。

func main() {
    li, err := net.Listen("tcp", ":8080")
    if err != nil {
        log.Fatalf("Listen: %v", err)
    }
    defer li.Close()

    for {    // 起動状態を続け、クライアントからのアクセスを待機する
        conn, err := li.Accept()
        if err != nil {
            log.Fatalf("Accept: %v", err)
        }
        go handle(conn)
    }
}

func handle(conn net.Conn) {
    defer conn.Close()
    scanner := bufio.NewScanner(conn)
    for scanner.Scan() {    // 読み取り対象が存在するまで処理を続ける
        fmt.Println(scanner.Text())
    }
    if err := scanner.Err(); err != nil {
        fmt.Printf("Scan: %v", err)
    }
}

クライアント側のmain.goです。
実行する度にサーバーへ書き込みを行います。

func main() {
    conn, err := net.Dial("tcp", ":8080")     // net.Dial()を使う
    if err != nil {
        log.Fatalf("Dial: %v", err)
    }
    fmt.Fprintf(conn, "This is %v", "2")
}

先にサーバー側のプログラムを実行し、 クライアント側のプログラムを実行します。

クライアントが読み込みを行う例も紹介します。
サーバー側のmain.goです。
クライアント側へ書き込みを行います。

func main() {
    li, err := net.Listen("tcp", ":8080")
    if err != nil {
        log.Fatalf("Listen: %v", err)
    }
    defer li.Close()

    for {
        conn, err := li.Accept()
        if err != nil {
            log.Fatalf("Accept: %v", err)
        }
        go handle(conn)
    }
}

func handle(conn net.Conn) {
    defer conn.Close()
    fmt.Fprintln(conn, "From server.")    // 接続先へ書き込みをおこなう
}

クライアント側のmain.goです。
実行の度に、サーバー側からの書き込みを読み取り、出力します。

func main() {
    conn, err := net.Dial("tcp", ":8080")     // net.Dial()を使う
    if err != nil {
        log.Fatalf("Dial: %v", err)
    }
    m, err := ioutil.ReadAll(conn)
    if err != nil {
        log.Fatalf("ReadAll: %v", err)
    }
    fmt.Println(string(m))    // ioutil.ReadAll()は[]byteを返すため、キャストする
}