Kaynağa Gözat

添加注册中心代码,注册到consul-健康检查

qdy 2 ay önce
ebeveyn
işleme
a44e565092
1 değiştirilmiş dosya ile 6 ekleme ve 0 silme
  1. 6
    0
      main.go

+ 6
- 0
main.go Dosyayı Görüntüle

51
 	// 3. 创建 WebService 并传入数据库接口
51
 	// 3. 创建 WebService 并传入数据库接口
52
 	ws := webx.NewWebService(router)
52
 	ws := webx.NewWebService(router)
53
 
53
 
54
+	// ✅ 为默认服务注册健康检查(端口 6060)
55
+	log.Println("注册默认服务健康检查...")
56
+	webx.RegisterDefaultHealthCheck(ws, "svc-ai")
57
+
54
 	//使用默认数据库
58
 	//使用默认数据库
55
 	registerDefaultRouter(ws, dbBoot.GetDefaultDBFactory())
59
 	registerDefaultRouter(ws, dbBoot.GetDefaultDBFactory())
56
 
60
 
59
 	wsDoris := webx.NewWebService(routerDoris)
63
 	wsDoris := webx.NewWebService(routerDoris)
60
 	registerDorisRouter(wsDoris, agentDB)
64
 	registerDorisRouter(wsDoris, agentDB)
61
 
65
 
66
+	//注册健康检查
67
+	webx.RegisterDefaultHealthCheck(wsDoris, "svc-doris")
62
 	// 6. 运行服务
68
 	// 6. 运行服务
63
 	boot.Run(dbBoot)
69
 	boot.Run(dbBoot)
64
 }
70
 }

Loading…
İptal
Kaydet