关于套接字的SO_REUSEADDR在golang中不能正常工作吗？

  • Z时代
  • 2024-01-10
  • 分类：问答

单个IP仅支持65535端口到单个目标。我希望客户端即使在会话仍处于time_wait状态的情况下，也可以在性能测试期间立即重用旧的tcp_session。

在我的Linux机器上，我已经打开了这些开关

sysctl -w net.ipv4.tcp_timestamps=1
sysctl -w net.ipv4.tcp_tw_recycle=1
sysctl -w net.ipv4.tcp_tw_reuse=1

然后，我编写以下代码来验证golang的socket_reuse选项。在代码中，我绑定了本地端口12345。

先跑后

$go run 1.go
$netstat -nat | grep 12345
tcp        0      0 192.168.1.11:12345         111.161.3.173:80            TIME_WAIT

二次运行后

$go run 1.go
Client Connect() called error: cannot assign requested address

看来SO_REUSEADDR无法工作。任何人都可以帮助解决此问题吗？

package main
import (
    "fmt"
    . "syscall"
)
func main() {
    var (
        clientsock int
        serveraddr SockaddrInet4
        err        error
    )
    if clientsock, err = Socket(AF_INET, SOCK_STREAM, IPPROTO_IP); err != nil {
        fmt.Println("Client Socket() called error:", err.Error())
        return
    }
    SetsockoptInt(clientsock, SOL_SOCKET, SO_REUSEADDR, 1)
    defer Shutdown(clientsock, SHUT_RDWR)
    serveraddr.Addr = [4]byte{111, 161, 3, 173}
    serveraddr.Port = 80
    err = Bind(clientsock, &SockaddrInet4{
        Port: 12345,
    })
    if err = Connect(clientsock, &serveraddr); err != nil {
        fmt.Println("Client Connect() called error:", err.Error())
        return
   }
}

回答：

您应该在代码中添加两个更改：

1）设置套接字选项unix.SO_REUSEPORT。

if errReusePort := SetsockoptInt(clientsock, SOL_SOCKET, unix.SO_REUSEPORT, 1); errReusePort != nil {
    fmt.Printf("reuse port error: %v\n", errReusePort)
    return
}

2）使您的代码连接到不同的远程TCP端点。否则，由于单个源地址/端口，TCP将无法区分两个相同的连接（协议，src-addr，src-port，dst-

addr，dst-port）。下面的示例在命令行中指定两个远程服务器地址。

$ go run main.go 127.0.0.1
connected
$ go run main.go 127.0.0.2
connected

在操场上找到完整的工作代码：https：//play.golang.org/p/HYLkWlVH6T4

以上是 关于套接字的SO_REUSEADDR在golang中不能正常工作吗？ 的全部内容， 来源链接： utcz.com/qa/409391.html

回到顶部