update

Author: chenjie

codegen/tml/gomod/template_gomod.go

@@ -13,8 +13,6 @@ go 1.15
 require (
 	github.com/chenjie199234/Corelib v0.0.6
 	github.com/fsnotify/fsnotify v1.4.9
-	github.com/go-redis/redis/v8 v8.4.8
-	github.com/go-sql-driver/mysql v1.5.0
 	github.com/golang/protobuf v1.4.3
 	github.com/segmentio/kafka-go v0.4.8
 	google.golang.org/protobuf v1.25.0

codegen/tml/server/xrpc/template_xrpc.go

@@ -28,7 +28,6 @@ var s *rpc.RpcServer
 func StartRpcServer() {
 	c := source.GetRpcConfig()
 	rpcc := &stream.InstanceConfig{
-		SelfName:           "{{.}}",
 		HeartbeatTimeout:   time.Duration(c.RpcHeartTimeout),
 		HeartprobeInterval: time.Duration(c.RpcHeartProbe),
 		TcpC: &stream.TcpConfig{
@@ -37,7 +36,7 @@ func StartRpcServer() {
 		},
 	}
 	var e error
-	if s, e = rpc.NewRpcServer(rpcc, time.Duration(c.RpcTimeout), []byte(c.RpcVerifydata)); e != nil {
+	if s, e = rpc.NewRpcServer(rpcc, api.Group, api.Name, []byte(c.RpcVerifydata), time.Duration(c.RpcTimeout)); e != nil {
 		log.Error("[xrpc] new rpc server error:", e)
 		return
 	}
@@ -64,7 +63,9 @@ func StartRpcServer() {
 
 //StopRpcServer -
 func StopRpcServer() {
-	s.StopRpcServer()
+	if s != nil {
+		s.StopRpcServer()
+	}
 }`
 
 const path = "./server/xrpc/"

codegen/tml/server/xweb/template_xweb.go

@@ -43,7 +43,7 @@ func StartWebServer() {
 		}
 	}
 	var e error
-	if s, e = web.NewWebServer(webc); e != nil {
+	if s, e = web.NewWebServer(webc, api.Group, api.Name); e != nil {
 		log.Error("[xweb] new web server error:", e)
 		return
 	}
@@ -70,7 +70,9 @@ func StartWebServer() {
 
 //StopWebServer -
 func StopWebServer() {
-	s.StopWebServer()
+	if s != nil {
+		s.StopWebServer()
+	}
 }`
 
 const path = "./server/xweb/"

rpc/server.go

@@ -39,7 +39,7 @@ func NewRpcServer(c *stream.InstanceConfig, group, name string, vdata []byte, gl
 		return nil, e
 	}
 	appname := group + "." + name
-	if e := common.NameCheck(appname, false, true, false, true); e != nil {
+	if e := common.NameCheck(appname, true, true, false, true); e != nil {
 		return nil, e
 	}
 	serverinstance := &RpcServer{

web/server.go

@@ -135,7 +135,7 @@ func NewWebServer(c *Config, group, name string) (*WebServer, error) {
 		return nil, e
 	}
 	appname := group + "." + name
-	if e := common.NameCheck(appname, false, true, false, true); e != nil {
+	if e := common.NameCheck(appname, true, true, false, true); e != nil {
 		return nil, e
 	}
 	c.validate()