服务端

package mainimport ("fmt""net""net/http""os"
)func main() {http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {w.Write([]byte("hello"))})http.HandleFunc("/world", func(w http.ResponseWriter, r *http.Request) {w.Write([]byte("world"))})// unix socket地址addr := "test.sock"// 如果文件先存在，必须先移除if err := os.Remove(addr); err != nil && err == os.ErrNotExist {panic(err)}// 使用uinx网络协议l, err := net.Listen("unix", addr)if err != nil {fmt.Println("net.ListenUnix", err)return}err = http.Serve(l, nil)if err != nil {fmt.Println("http.Serve", err)return}
}

客户端调用

package mainimport ("context""fmt""io""net""net/http"
)func main() {addr1 := "test.sock"// 创建一个基于 Unix 域套接字的 HTTP 客户端transport := &http.Transport{DialContext: func(ctx context.Context, network string, addr string) (net.Conn, error) {return net.Dial("unix", addr1)},}client := &http.Client{Transport: transport}// 创建一个 HTTP GET 请求// http://unix/world中的unix可以为任何值，建议使用有意义的域名，例如本地服务localhostreq, err := http.NewRequest("GET", "http://unix/world", nil)if err != nil {fmt.Println("Error creating request:", err)return}// 发送请求并获取响应resp, err := client.Do(req)if err != nil {fmt.Println("Error sending request:", err)return}defer resp.Body.Close()// 读取响应内容body, err := io.ReadAll(resp.Body)if err != nil {fmt.Println("Error reading response:", err)return}// 打印响应内容fmt.Println("Response from server:", string(body))
}