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() {
listener, err := reuseport.Listen("tcp", "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 tiny 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 ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
var (
// ListenerBacklogMaxSize setting backlog size
ListenerBacklogMaxSize = maxListenerBacklog()
)
Functions ¶
func ListenPacket ¶
func ListenPacket(proto, addr string) (l net.PacketConn, err error)
ListenPacket is an alias for NewReusablePortPacketConn.
func NewReusablePortListener ¶
NewReusablePortListener returns net.FileListener that created from a file discriptor for a socket with SO_REUSEPORT option.
Example ¶
listener, err := NewReusablePortListener("tcp", ":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))
Output:
func NewReusablePortPacketConn ¶
func NewReusablePortPacketConn(proto, addr string) (l net.PacketConn, err error)
NewReusablePortPacketConn returns net.FilePacketConn that created from a file discriptor for a socket with SO_REUSEPORT option.
Types ¶
This section is empty.
Source Files