Goならわかるシステムプログラミング：第2章

第2章。

ファイルディスクリプタ・・・OSがカーネルのレイヤーで用意している抽象化の仕組み limits.confでいじるやつ。 0が標準入力 1が標準出力 2が標準エラー出力
構造体が持つべきメソッドを表現するのがインタフェース

package main

import "fmt"

type Talker interface {
    Talk()
}

type Greeter struct {
    name string
}

func (g Greeter) Talk() {
    fmt.Printf("Hello, my name is %s\n", g.name)
}

func main() {
    var talker Talker

    talker = &Greeter{"wozozo"}
    talker.Talk()
}

ファイル出力の例

package main

import (
    "os"
)

func main() {
    file, err := os.Create("test.txt")
    if err != nil {
        panic(err)
    }
    file.Write([]byte("os.File example\n"))
    file.Close()
}

画面出力

package main

import "os"

func main() {
    os.Stdout.Write([]byte("os.Stdout example\n"))
}

バッファ

package main

import (
    "bytes"
    "fmt"
)

func main() {
    var buffer bytes.Buffer
    buffer.Write([]byte("bytes.Buffer example\n"))
        //buffer.WriteString("bytes.Buffer example\n") これでもOK
    fmt.Println(buffer.String())
}

インターネットアクセス

package main

import (
    "net"
    "io"
    "os"
)

func main() {
    conn, err := net.Dial("tcp", "ascii.jp:80")
    if err != nil {
        panic(err)
    }
    io.WriteString(conn, "GET / HTTP1.0\r\nHost: ascii.jp\r\n\r\n")
    io.Copy(os.Stdout, conn)
}

httpパッケージを使う方法

package main

import (
    "net"
    "io"
    "os"
    "net/http"
)

func main() {
    conn, err := net.Dial("tcp", "ascii.jp:80")
    if err != nil {
        panic(err)
    }
    req, err := http.NewRequest("GET", "http://ascii.jp", nil)
    if err != nil {
        panic(err)
    }
    req.Write(conn)
    io.Copy(os.Stdout, conn)
}

ウェブサーバーからブラウザに対して書き込む

package main

import (
    "net/http"
    "io"
)

func handler(w http.ResponseWriter, r *http.Request) {
    io.WriteString(w, "http.ResponseWriter sample")
}

func main() {
    http.HandleFunc("/", handler)
    http.ListenAndServe(":8080", nil)
}

デコレータ・・・io.Writerを受け取り、書き込まれtデータを加工して別のio.Writerに書き出す下記の例は１つのWriteでファイルと標準出力両方に書き込んでいる

package main

import (
    "os"
    "io"
)

func main() {
    file, err := os.Create("multiwriter.txt")
    if err != nil {
        panic(err)
    }
    writer := io.MultiWriter(file, os.Stdout)
    io.WriteString(writer, "io.MultiWriter example\n")
}

*gzip圧縮してos.Fileに中継する

package main

import (
    "os"
    "compress/gzip"
    "io"
)

func main() {
    file, err := os.Create("test.txt.gz")
    if err != nil {
        panic(err)
    }
    writer := gzip.NewWriter(file)
    writer.Header.Name = "test.txt"
    io.WriteString(writer, "gzip.Writer example")
    writer.Close()
}

バッファをためておいてFlush()で書き込む

package main

import (
    "bufio"
    "os"
)

func main() {
    buffer := bufio.NewWriter(os.Stdout)
    buffer.WriteString("bufio.Writer ")
    buffer.Flush()
    buffer.WriteString("example\n")
    buffer.Flush()
}

Fprintf()

package main

import (
    "fmt"
    "os"
    "time"
)

func main() {
    fmt.Fprintf(os.Stdout, "Write with os.Stdout at %v", time.Now())
}

Write with os.Stdout at 2018-07-05 23:07:33.224526589 +0900 JST m=+0.000422627

JSONを整形して標準出力に出す

package main

import (
    "encoding/json"
    "os"
)

func main() {
    encoder := json.NewEncoder(os.Stdout)
    encoder.SetIndent("", "   ")
    encoder.Encode(map[string]string {
        "example": "encoding/json",
        "hello": "world",
    })
}

問題

Q2.1: ファイルに対するフォーマット出力

package main

import (
    "os"
    "fmt"
)

func main() {
    file, err := os.Create("test.txt")
    if err != nil {
        panic(err)
    }
    d := 1
    s := "s"
    f := 0.2
    fmt.Fprintf(file, "%d, %s, %f", d, s, f)
    file.Close()
}

Q2.2: CSV出力

package main

import (
    "os"
    "encoding/csv"
)

func main() {
    file, err := os.Create("test.csv")
    if err != nil {
        panic(err)
    }
    writer := csv.NewWriter(file)
    writer.Write([]string{"apple", "orange", "lemon"})
    writer.Write([]string{"red", "orange", "yellow"})
    writer.Flush()
    file.Close()
}

Q2.3 gzipされたJSON出力をしながら、標準出力にログを出力

package main

import (
    "net/http"
    "encoding/json"
    "io"
    "compress/gzip"
    "os"
)

func handler(w http.ResponseWriter, r *http.Request) {
    w.Header().Set("Content-Encoding", "gzip")
    w.Header().Set("Content-Type", "application/json")
    source := map[string]string {
        "Hello": "World",
    }

    gzipWriter := gzip.NewWriter(w)
    encoder := json.NewEncoder(io.MultiWriter(gzipWriter, os.Stdout))
    encoder.SetIndent("", "   ")
    encoder.Encode(source)
    gzipWriter.Close()
}

func main() {
    http.HandleFunc("/", handler)
    http.ListenAndServe(":8080", nil)
}