panic bug修改

service/consumer/brave_message_handler.go

@@ -46,7 +46,7 @@ func msgInfluxProcess(traceMsgs []end_points.TraceMsg) {
 		}
 		path := traceMsg.Name
 		if _, ok := httpMethod[path]; ok {
-			path = traceMsg.Tags.HttpMethod + " " + path
+			path = traceMsg.Tags.HttpMethod + " " + traceMsg.Tags.HttpPath
 		}
 
 		path = strings.ToLower(path)

service/node-check/node_check.go

@@ -131,11 +131,12 @@ func (w watch) UpdateNodes(service *registry.Service) {
 	newService := registry.NewService(service.Name)
 	for kk, vv := range service.NodeMap {
 		newNode := registry.Node{
-			ServiceName:vv.ServiceName,
-			Id:vv.Id,
-			Port:vv.Port,
-			Address:vv.Address,
-			Status:vv.Status,
+			ServiceName: vv.ServiceName,
+			Id:          vv.Id,
+			Port:        vv.Port,
+			Address:     vv.Address,
+			Status:      vv.Status,
+			Meta:        make(map[string]string),
 		}
 		for x, y := range vv.Meta {
 			newNode.Meta[x] = y
@@ -155,7 +156,7 @@ func (w watch) DelNode(node *registry.Node) {
 }
 
 var (
-	servicesStatus = make(map[string]*registry.Service)
+	servicesStatus     = make(map[string]*registry.Service)
 	servicesStatusLock = new(sync.Mutex)
 )
 
@@ -165,12 +166,14 @@ func InitServiceStatus() {
 
 func NodeCheck() {
 	defer func() {
-		if e := recover(); e != nil {
-			logger.Info("node check panic: ", e)
-			_ = ding.SendText("node check panic!", dingding.DefaultDingURL...)
-			time.Sleep(time.Second * 1)
-			NodeCheck()
-		}
+		/*
+			if e := recover(); e != nil {
+				logger.Error("node check panic: ", e)
+				_ = ding.SendText("node check panic!", dingding.DefaultDingURL...)
+				time.Sleep(time.Second * 1)
+				NodeCheck()
+			}
+		*/
 	}()
 
 	//注册器初始化

service/registry/consul.go

@@ -301,6 +301,7 @@ func (cr *consulRegistry) SetObserver(name string, observer Observer) error {
 					Port:vv.Port,
 					Address:vv.Address,
 					Status:vv.Status,
+					Meta: make(map[string]string),
 				}
 				for x, y := range vv.Meta {
 					newNode.Meta[x] = y