goNet

version

v 1.0.0

介绍

一个基于go语言开发的网络脚手架,参考cellnet和beego两大开框架的设计，使用非常方便简洁，轻松让你开发出高并发高性能的网络应用，可以用于游戏,app等任何领域的通讯。

主要特性及追求目标

• 高并发
• 高性能
• 简单易用
• 线性安全
• 兼容性强
• 多领域应用
• 防崩溃
• 错误快速定位

通讯协议支持

• TCP
• UDP
• WEBSOCKET
• QUIC
• KCP
• HTTP
• RPC

数据编码格式支持

• json
• xml
• binary
• protobuf

关键技术

• 会话池(session pool）
• 协程池(goroutine pool)

安装教程

1. git clone到 GOPATH/src目录下

git clone https://github.com/Quantumoffices/goNet.git

使用样例参考

• 服务端

package main

import (
	"goNet"
	_ "goNet/codec/json"
	_ "goNet/peer/tcp"
)

func main() {
	p := goNet.NewPeer("server",":8087")
	p.Start()
}

• 客户端

package main

import (
	"goNet"
	_ "goNet/codec/json"
	_ "goNet/peer/tcp"
)

func main() {
	p := goNet.NewPeer("client", ":8087")
	p.Start()
       //todo something
}

• 消息处理实现及注册

package msg
import (
	"goNet"
)
//消息注册
func init() {
	goNet.RegisterMessage(0, Ping{})
	goNet.RegisterMessage(1, Pong{})
}

//心跳
type Ping struct {
	TimeStamp int64 `json:"time_stamp",xml:"time_stamp"`
}
type Pong struct {
	TimeStamp int64 `json:"time_stamp",xml:"time_stamp"`
}
type SessionClose struct {
}

//消息需要实现 goNet.Message接口
func (p *Ping) Handle(session Session) {
	logrus.Infof("session_%v ping at time=%v", session.ID(), time.Unix(p.TimeStamp, 0).String())
	session.Send(Pong{TimeStamp: time.Now().Unix(),})
}
func (p *Pong) Handle(session Session) {
	logrus.Infof("session_%v pong at time=%v", session.ID(), time.Unix(p.TimeStamp, 0).String())
}

func (s *SessionClose) Handle(session Session) {
	logrus.Errorf("session_%v closed", session.ID())
}

在线游戏demo

• 使用etcd+mysql+beego+goNet+cocos creator制作
  服务端：大厅服+游戏服+服务注册
  客户端：大厅+子游戏模式
  http://www.quantumstudio:8080/client-release-signed.apk

测试

FAQ

参与贡献

QQ群：795611332