[开源] gev（支持 websocket 啦）: Go 实现基于 Reactor 模式的非阻塞网络库

[xuxu555]

https://github.com/Allenxuxu/gev

gev 是一个轻量、快速、高性能的基于 Reactor 模式的非阻塞网络库，底层并不使用 golang net 库，而是使用 epoll 和 kqueue。

现在它支持 WebSocket 啦！

支持定时任务，延时任务!

⬇️⬇️⬇️

特点

• 基于 epoll 和 kqueue 实现的高性能事件循环
• 支持多核多线程
• 动态扩容 Ring Buffer 实现的读写缓冲区
• 异步读写
• SO_REUSEPORT 端口重用支持
• 支持 WebSocket
• 支持定时任务，延时任务

性能测试

测试环境 Ubuntu18.04

• gev
• gnet
• eviop
• evio
• net (标准库)

吞吐量测试

evio 压测方式:

限制 GOMAXPROCS=1，1 个 work 协程

限制 GOMAXPROCS=1，4 个 work 协程

限制 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()
}

相关文章

• evio 源码解析
• Golang 网络库 evio 一些问题 /bug 和思考
• gev: Go 实现基于 Reactor 模式的非阻塞 TCP 网络库

仓库地址： https://github.com/Allenxuxu/gev

[zeromake]

能解释一下为啥要内置定时能力，而不是让调用方使用外部库来实现呢？

[xuxu555]

@zeromake 其实并非内置，定时功能也是使用了外部库。 因为有小伙伴提了这个需求，所以就加上去了方便使用。

[agui2200]

这个名字很有灵性啊

[xuxu555]

@agui2200 有种不好的感觉，啥灵性啊🐕

[agui2200]

@xuxu555 看到 gev 就想到 gay，（狗头

[xuxu555]

@agui2200 心里 gay 看什么都 gay 😂

[codehz]

定时任务似乎没有使用 timerfd，这样就不能利用单一 epoll 的优势了（

[Aether]

定时内容都是放在内存里的，可能会丢失，是这样吗？

[xuxu555]

@Aether 是，丢失的情况是进程都挂了啊

[xuxu555]

@codehz 是的，timerfd 考虑过，但是考虑到 go 协程比线程廉价的多，开个协程搞个 timingwheel 实现定时更简洁方便。

[Aether]

@xuxu555 对。我发现类似解决方案有一个算是痛点的部分，就是有些需求是希望可以从中断恢复。之前看了一圈，比较轻量，开箱即用的解决方案似乎不多，或者说就没有……。然后这些方案肯定需要依赖外部数据储存，比如 redis 之类的。