NetGo

基于 Zinx 二次开发的TCP框架。支持GPS等自定义协议的扩展。

主要功能

• 注册协议

1. 继承gnet.Connection，注册StartReader和Pack回调方法。

• 注册路由

1. 继承ginterface.IRouter，实现Handle方法。

• 支持指令下发异步处理

1. IConnection.SendMsg(message)/IConnection.SendBuffMsg(message)
2. 继承ginterface.IRouter，实现Handle方法。

• 支持指令下发同步处理

1. ch := make(chan ginterface.IMessage)
2. IConnection.RegisterCommandResponseChan(action,ch)
3. IConnection.SendMsg(message)/IConnection.SendBuffMsg(message)
4. wait(ch)

程序示例：

func main() {
	s := gnet.NewServer("127.0.0.1", 8888, 1024, 10, 100)
	// 自定义协议示例
	s.OnNewConn(inet.NewConnection)
	// 路由添加示例 path := IMessage.GetProtocolNo() + "_" + IMessage.GetAction()
	s.AddRouter("7878_01", &irouter.LoginRouter{})
	s.AddRouter("7878_13", &irouter.HeartbeatRouter{})
	// 指令下发示例
	c, b := s.GetConnectionManager().Get("")
	if b {
		c.SendMsg(gnet.NewMessage("", "", ""))
	}
	s.Start()
}

更多示例请参考example包。