[開源] gev （支持 websocket 啦）: Go 實現基於 Reactor 模式的非阻塞網絡庫

時間 2019-11-06

標籤開源 gev 支持 websocket 實現基於 reactor 模式阻塞網絡欄目 React 简体版

原文原文鏈接

github.com/Allenxuxu/g…html

gev 是一個輕量、快速、高性能的基於 Reactor 模式的非阻塞網絡庫，底層並不使用 golang net 庫，而是使用 epoll 和 kqueue。git

如今它支持 WebSocket 啦！github

支持定時任務，延時任務!golang

⬇️⬇️⬇️bash

特色

基於 epoll 和 kqueue 實現的高性能事件循環
支持多核多線程
動態擴容 Ring Buffer 實現的讀寫緩衝區
異步讀寫
SO_REUSEPORT 端口重用支持
支持 WebSocket
支持定時任務，延時任務

性能測試

測試環境 Ubuntu18.04網絡

gev
gnet
eviop
evio
net (標準庫)

吞吐量測試

evio 壓測方式:

限制 GOMAXPROCS=1，1 個 work 協程多線程

限制 GOMAXPROCS=1，4 個 work 協程app

限制 GOMAXPROCS=4，4 個 work 協程異步

安裝

go get -u github.com/Allenxuxu/gev
複製代碼

示例

TCP

package main

import (
	"flag"
	"strconv"
	"log"

	"github.com/Allenxuxu/gev"
	"github.com/Allenxuxu/gev/connection"
	"github.com/Allenxuxu/ringbuffer"
)

type example struct{}

func (s *example) OnConnect(c *connection.Connection) {
	log.Println(" OnConnect ： ", c.PeerAddr())
}
func (s *example) OnMessage(c *connection.Connection, buffer *ringbuffer.RingBuffer) (out []byte) {
	//log.Println("OnMessage")
	first, end := buffer.PeekAll()
	out = first
	if len(end) > 0 {
		out = append(out, end...)
	}
	buffer.RetrieveAll()
	return
}

func (s *example) OnClose() {
	log.Println("OnClose")
}

func main() {
	handler := new(example)
	var port int
	var loops int

	flag.IntVar(&port, "port", 1833, "server port")
	flag.IntVar(&loops, "loops", -1, "num loops")
	flag.Parse()

	s, err := gev.NewServer(handler,
		gev.Network("tcp"),
		gev.Address(":"+strconv.Itoa(port)),
		gev.NumLoops(loops))
	if err != nil {
		panic(err)
	}

	s.Start()
}
複製代碼

WebSocket

package main

import (
	"flag"
	"github.com/Allenxuxu/gev/ws"
	"log"
	"math/rand"
	"strconv"

	"github.com/Allenxuxu/gev"
	"github.com/Allenxuxu/gev/connection"
)

type example struct{}

func (s *example) OnConnect(c *connection.Connection) {
	log.Println(" OnConnect ： ", c.PeerAddr())
}
func (s *example) OnMessage(c *connection.Connection, data []byte) (messageType ws.MessageType, out []byte) {
	log.Println("OnMessage:", string(data))
	messageType = ws.MessageBinary
	switch rand.Int() % 3 {
	case 0:
		out = data
	case 1:
		if err := c.SendWebsocketData(ws.MessageText, data); err != nil {
			if e := c.CloseWebsocket(err.Error()); e != nil {
				panic(e)
			}
		}
	case 2:
		if e := c.CloseWebsocket("close"); e != nil {
			panic(e)
		}
	}
	return
}

func (s *example) OnClose(c *connection.Connection) {
	log.Println("OnClose")
}

func main() {
	handler := new(example)
	var port int
	var loops int

	flag.IntVar(&port, "port", 1833, "server port")
	flag.IntVar(&loops, "loops", -1, "num loops")
	flag.Parse()

	s, err := gev.NewWebSocketServer(handler,
		gev.Network("tcp"),
		gev.Address(":"+strconv.Itoa(port)),
		gev.NumLoops(loops))
	if err != nil {
		panic(err)
	}

	s.Start()
}
複製代碼