server.go

package main

import (
	"github.com/jarekzha/mqant"
	"github.com/jarekzha/mqant/conf"
	"github.com/jarekzha/mqant/examples/proto/examples/greeter"
	"github.com/jarekzha/mqant/module"
	basemodule "github.com/jarekzha/mqant/module/base"
)

type Greeter struct {
}

func (g *Greeter) Hello(in *greeter.Request) (out *greeter.Response, err error) {
	out = &greeter.Response{
		Msg: "success",
	}
	return
}
func (g *Greeter) Stream(in *greeter.Request) (out *greeter.Response, err error) {
	return
}
func main() {

	// 服务实例
	app := mqant.CreateApp(
		module.Debug(false),
	)
	// 配置加载
	app.OnConfigurationLoaded(func(app module.App) {

	})
	s := &Server{}
	app.Run(s)
}

type Server struct {
	basemodule.BaseModule
	version string
	// 模块名字
	Name string
}

// GetApp module.App
func (m *Server) GetApp() module.App {
	return m.App
}

// OnInit() 初始化配置
func (s *Server) OnInit(app module.App, settings *conf.ModuleSettings) {
	s.BaseModule.OnInit(s, app, settings)
	srv := &Greeter{}
	greeter.RegisterGreeterTcpHandler(&s.BaseModule, srv)
}

// Run() 运行服务
func (s *Server) Run(closeSig chan bool) {
	//创建MongoDB连接实例
}

// 销毁服务
func (s *Server) OnDestroy() {
	//一定别忘了继承
	s.BaseModule.OnDestroy()
	s.GetServer().OnDestroy()
}

// Version() 获取当前服务的代码版本
func (s *Server) Version() string {
	//可以在监控时了解代码版本
	return s.version
}

func (s *Server) GetType() string {
	return "greeter"
}