reuseport

README

GO_REUSEPORT

GO_REUSEPORT is a little expirement to create a net.Listener that supports SO_REUSEPORT socket option.

For now, Darwin and Linux (from 3.9) systems are supported. I'll be pleased if you'll test other systems and tell me the results. documentation on godoc.org.

Example

package main

import (
  "fmt"
  "html"
  "net/http"
  "os"
  "runtime"
  "github.com/kavu/go_reuseport"
)

func main() {
  runtime.GOMAXPROCS(runtime.NumCPU())

  listener, err := reuseport.NewReusablePortListener("tcp4", "localhost:8881")
  if err != nil {
    panic(err)
  }
  defer listener.Close()

  server := &http.Server{}
  http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
    fmt.Println(os.Getgid())
    fmt.Fprintf(w, "Hello, %q\n", html.EscapeString(r.URL.Path))
  })

  panic(server.Serve(listener))
}

Now you can run several instances of this tint server without Address already in use errors.

Thanks

Inspired by Artur Siekielski post about SO_REUSEPORT.

Documentation

Overview

Package reuseport provides a function that returns a net.Listener powered by a net.FileListener with a SO_REUSEPORT option set to the socket.

Index

• func NewReusablePortListener(proto, addr string) (l net.Listener, err error)
• func NewReusablePortPacketConn(proto, addr string) (l net.PacketConn, err error)

Functions

func NewReusablePortListener

func NewReusablePortListener(proto, addr string) (l net.Listener, err error)

NewReusablePortListener returns net.FileListener that created from a file discriptor for a socket with SO_REUSEPORT option.

func NewReusablePortPacketConn

func NewReusablePortPacketConn(proto, addr string) (l net.PacketConn, err error)

NewReusablePortPacketConn returns net.FileListener that created from a file discriptor for a socket with SO_REUSEPORT option.