Cellnet

特性

异步单线程多进程架构

数据协议

网关

RPC

模块化

日志

第三方库依赖

例子

Echo

func server() {
	pipe := cellnet.NewEventPipe()
	evq := socket.NewAcceptor(pipe).Start("127.0.0.1:7234")
	socket.RegisterSessionMessage(evq, "coredef.TestEchoACK", func(content interface{}, ses cellnet.Session) {
		msg := content.(*coredef.TestEchoACK)
		log.Debugln("server recv:", msg.String())
		ses.Send(&coredef.TestEchoACK{
			Content: msg.String,
		})
	})
	pipe.Start()
}
func client() {
	pipe := cellnet.NewEventPipe()
	evq := socket.NewConnector(pipe).Start("127.0.0.1:7234")
	socket.RegisterSessionMessage(evq, "coredef.TestEchoACK", func(content interface{}, ses cellnet.Session) {
		msg := content.(*coredef.TestEchoACK)
		log.Debugln("client recv:", msg.String())
	})
	socket.RegisterSessionMessage(evq, "coredef.SessionConnected", func(content interface{}, ses cellnet.Session) {
		ses.Send(&coredef.TestEchoACK{
			Content: "hello",
		})
	})
	pipe.Start()
}

TODO

网关

MongoDB

Wiki

备注

贡献者