cellnet

特性

异步单线程多进程架构

数据协议

RPC

日志

第三方库依赖

性能测试

例子

Echo

func server() {
	queue := cellnet.NewEventQueue()
	evd := socket.NewAcceptor(queue).Start("127.0.0.1:7201")
	socket.RegisterMessage(evd, "gamedef.TestEchoACK", func(content interface{}, ses cellnet.Session) {
		msg := content.(*gamedef.TestEchoACK)
		log.Debugln("server recv:", msg.String())
		ses.Send(&gamedef.TestEchoACK{
			Content: msg.String(),
		})
	})
	queue.StartLoop()
}
func client() {
	queue := cellnet.NewEventQueue()
	evd := socket.NewConnector(queue).Start("127.0.0.1:7201")
	socket.RegisterMessage(evd, "gamedef.TestEchoACK", func(content interface{}, ses cellnet.Session) {
		msg := content.(*gamedef.TestEchoACK)
		log.Debugln("client recv:", msg.String())
		signal.Done(1)
	})
	socket.RegisterMessage(evd, "gamedef.SessionConnected", func(content interface{}, ses cellnet.Session) {
		ses.Send(&gamedef.TestEchoACK{
			Content: "hello",
		})
	})
	queue.StartLoop()
}

文件夹功能

close\		发送消息后保证消息送达后再断开连接
echo\		常见的pingpong测试, 最简单的例子
mgo\		mongodb异步读取例子
rpc\		异步远程过程调用
timer\		异步计时器

FAQ

func RegisterMessage(msgName string, userHandler func(interface{}, cellnet.Session, int64)) {
	msgMeta := cellnet.MessageMetaByName(msgName)
	if msgMeta == nil {
		log.Errorf("message register failed, %s", msgName)
		return
	}
	for _, conn := range routerConnArray {
		conn.AddCallback(msgMeta.ID, func(data interface{}) {
			if ev, ok := data.(*relayEvent); ok {
				rawMsg, err := cellnet.ParsePacket(ev.Packet, msgMeta.Type)
				if err != nil {
					log.Errorln("unmarshaling error:\n", err)
					return
				}
				msgContent := rawMsg.(interface {
					String() string
				}).String()				
				userHandler(rawMsg, ev.Ses, ev.ClientID)
			}
		})
	}
}

func RegisterExternMessage(msgName string, userHandler func(interface{}, *Player)) {
	backend.RegisterMessage(msgName, func(content interface{}, routerSes cellnet.Session, clientid int64) {
		if player, ok := PlayerByID[clientid]; ok {
			userHandler(content, player)
		}
	})
}

版本历史

Wiki

贡献者

备注