works:programmer:go:http-server-over-unix-socker

Golang запуск http сервера через unix domain socket

Сервер

server.go
package main
 
import (
    "net"
    "net/http"
    "log"
    "fmt"
)
 
func main() {
 
    http.HandleFunc("/", func (wr http.ResponseWriter, req *http.Request) {
        fmt.Fprintf(wr, "Hello, World!")
    })
 
    log.Println("Starting unix on \"/tmp/provider\"")
 
    listener, err := net.Listen("unix", "/tmp/provider")
    if (err != nil) {
        log.Fatalln(err)
    }
 
    server := http.Server {
    }
 
    server.Serve(listener)
}

Клиент

client.go
package main
 
import (
        "context"
        "flag"
        "fmt"
        "io"
        "net"
        "net/http"
        "os"
        "strings"
)
 
func main() {
        post := flag.String("d", "", "data to POST")
        help := flag.Bool("h", false, "usage help")
        flag.Parse()
 
        if *help || len(flag.Args()) != 2 {
                fmt.Fprintln(os.Stderr, "usage:", os.Args[0], "[-d data] /path.socket /uri")
                flag.PrintDefaults()
                os.Exit(0)
        }
 
        fmt.Println("Unix HTTP client")
 
        httpc := http.Client{
                Transport: &http.Transport{
                        DialContext: func(_ context.Context, _, _ string) (net.Conn, error) {
                                return net.Dial("unix", flag.Args()[0])
                        },
                },
        }
 
        var response *http.Response
        var err error
        if len(*post) == 0 {
                response, err = httpc.Get("http://unix" + flag.Args()[1])
        } else {
                response, err = httpc.Post("http://unix"+flag.Args()[1], "application/octet-stream", strings.NewReader(*post))
        }
 
        if err != nil {
                panic(err)
        }
        io.Copy(os.Stdout, response.Body)
}

Тестировать можно через nc клиент

nc -U /var/run/socket
works/programmer/go/http-server-over-unix-socker.txt · Last modified: 2023/07/06 06:48 by Chugreev Eugene