netpollmux

netpollmux

Le package NetPollMux implémente un échauffeur de réseau basé sur Epoll / Kqueue.

Caractéristiques

• Epoll / Kqueue
• TCP / UNIX
• Compatible avec l'interface net.conn.
• Connexion de mise à niveau
• E / S non bloquantes
• Splice / Sendfile
• Reprogrammer les travailleurs

Comparaison avec d'autres packages.

Emballer	filet	netpollmux	frisson	Evio
Utilisation de la mémoire basse	Non	Oui	Oui	Oui
E / S non bloquantes	Non	Oui	Oui	Oui
Splice / Sendfile	Oui	Oui	Non	Non
Reprogrammation	Oui	Oui	Non	Non
Compatible avec l'interface net.conn	Oui	Oui	Non	Non

Référence

Commencer

Installer

 go get github.com/php2go/netpollmux

Importer

 import "github.com/php2go/netpollmux"

Usage

Exemple simple

 package main

import "github.com/php2go/netpollmux"

func main () {
	var handler = & netpoll. DataHandler {
		NoShared :   true ,
		NoCopy :     true ,
		BufferSize : 1024 ,
		HandlerFunc : func ( req [] byte ) ( res [] byte ) {
			res = req
			return
		},
	}
	if err := netpoll . ListenAndServe ( "tcp" , ":9999" , handler ); err != nil {
		panic ( err )
	}
}

Exemple TLS

 package main

import (
	"crypto/tls"
	"github.com/php2go/netpollmux/internal/socket"
	"github.com/php2go/netpollmux/netpoll"
	"net"
)

func main () {
	var handler = & netpoll. DataHandler {
		NoShared :   true ,
		NoCopy :     true ,
		BufferSize : 1024 ,
		HandlerFunc : func ( req [] byte ) ( res [] byte ) {
			res = req
			return
		},
	}
	handler . SetUpgrade ( func ( conn net. Conn ) (net. Conn , error ) {
		tlsConn := tls . Server ( conn , socket . DefalutTLSConfig ())
		if err := tlsConn . Handshake (); err != nil {
			return nil , err
		}
		return tlsConn , nil
	})
	if err := netpoll . ListenAndServe ( "tcp" , ":9999" , handler ); err != nil {
		panic ( err )
	}
}

Exemple WebSocket

 package main

import (
	"github.com/php2go/netpollmux/internal/websocket"
	"github.com/php2go/netpollmux/netpoll"
	"net"
)

func main () {
	var handler = & netpoll. ConnHandler {}
	handler . SetUpgrade ( func ( conn net. Conn ) (netpoll. Context , error ) {
		return websocket . Upgrade ( conn , nil )
	})
	handler . SetServe ( func ( context netpoll. Context ) error {
		ws := context .( * websocket. Conn )
		msg , err := ws . ReadMessage ()
		if err != nil {
			return err
		}
		return ws . WriteMessage ( msg )
	})
	if err := netpoll . ListenAndServe ( "tcp" , ":9999" , handler ); err != nil {
		panic ( err )
	}
}

Exemple HTTP

 package main

import (
	"bufio"
	"log"
	"net"
	"net/http"
	"sync"

	"github.com/php2go/netpollmux/internal/logger"
	"github.com/php2go/netpollmux/mux"
	"github.com/php2go/netpollmux/netpoll"
)

func main () {
	m := mux . NewRoute ()
	m . GET ( "/hello/:id" , func ( w http. ResponseWriter , req * http. Request , params httprouter. Params ) {
		pp := req . URL . Query ()
		logger . Info ( "query params：" , params , pp )
		mux . JSON ( w , req , [] string { "hello world" }, http . StatusOK )
	})
	log . Fatal ( m . Run ( ":8080" ))
}