来自 TCP 套接字的 HTTP 服务器(在 Go 中)

AjM*_*yra 4 sockets linux network-programming go

我正在尝试在 Go 中创建一个 TCP 套接字,将其绑定到VRF 接口中,并在该特定接口中建立一个 HTTP 服务器。VRF 绑定工作正常,但启动 HTTP 服务器会返回错误,指出“accept tcp 127.0.0.1:80:accept: invalid argument”。我是否正确地假设,插座有某种缺陷并且我创建了错误的插座?

下面是重现问题的简化版本。VRF 部分被注释掉,因为它不会影响实际问题,但我将其留在这里,因为我试图避免人们告诉我只使用 net.Listen 而不是套接字。VRF 需要首先绑定才能使用,因此不幸的是 net.Listen 不是一个选项。

package main

import (
    "fmt"
    "net"
    "net/http"
    "os"
    "syscall"
)

func main() {
    fd, err := syscall.Socket(syscall.AF_INET, syscall.SOCK_STREAM, syscall.IPPROTO_TCP)
    if err != nil {
        fmt.Printf("Error creating socket: %v", err)
        os.Exit(1)
    }

    // if err = syscall.SetsockoptString(fd, syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, "vrfiface"); err != nil {
    //  fmt.Printf("Error binding to vrf: %v", err)
    //  os.Exit(1)
    // }

    sockAddr := &syscall.SockaddrInet4{
        Port: 80,
        Addr: [4]byte{127, 0, 0, 1},
    }

    if err = syscall.Bind(fd, sockAddr); err != nil {
        fmt.Printf("Error binding to IP and port: %v", err)
        os.Exit(1)
    }

    file := os.NewFile(uintptr(fd), "socketfile")
    if file == nil {
        fmt.Println("Error creating file")
        os.Exit(1)
    }

    listener, err := net.FileListener(file)
    if err != nil {
        fmt.Printf("Error creating a listener: %v", err)
        os.Exit(1)
    }

    http.HandleFunc("/", TestServer)
    if err = http.Serve(listener, nil); err != nil {
        fmt.Printf("Error serving HTTP requests: %v", err)
    }
}

func TestServer(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "Test, %s!", r.URL.Path[1:])
}
Run Code Online (Sandbox Code Playgroud)

任何有关解决此问题的指示将不胜感激。谢谢你!

Jim*_*imB 5

您可以在调用之前使用 anet.ListenConfig注入您想要的套接字选项。syscall.Bind这也确保了套接字设置正确完成,并且以与包预期相同的方式完成net

ListenConfig.Control函数为您提供了一个使用闭包syscall.RawConn进行调用的函数Control,您可以在其中访问套接字设置期间使用的原始文件描述符。

func main() {
    lc := net.ListenConfig{Control: controlOnConnSetup}

    ln, err := lc.Listen(context.Background(), "tcp", "127.0.0.1:80")
    if err != nil {
        log.Fatal(err)
    }
    ln.Close()
}

func controlOnConnSetup(network string, address string, c syscall.RawConn) error {
    var operr error
    fn := func(fd uintptr) {
        operr = syscall.SetsockoptString(int(fd), syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, "vrfiface")
    }
    if err := c.Control(fn); err != nil {
        return err
    }
    if operr != nil {
        return operr
    }
    return nil
}
Run Code Online (Sandbox Code Playgroud)