| | |
|---|
| | | //util.AuthCheck(ctx) |
|---|
| | | go func() { |
|---|
| | | r := gin.Default() |
|---|
| | | r.Use(auth.AuthHandler()) |
|---|
| | | //授权检查 暂时关闭 |
|---|
| | | //r.Use(auth.AuthHandler()) |
|---|
| | | r.Any("/data/*any", client.AnyRequest) |
|---|
| | | r.Run("0.0.0.0:8888") |
|---|
| | | }() |
|---|
| | |
|---|
| | | |
|---|
| | | func main() { |
|---|
| | | // pprof 用于分析性能 |
|---|
| | | go func() { |
|---|
| | | logger.Info(http.ListenAndServe("0.0.0.0:6078", nil)) |
|---|
| | | }() |
|---|
| | | //go func() { |
|---|
| | | // logger.Info(http.ListenAndServe("0.0.0.0:6078", nil)) |
|---|
| | | //}() |
|---|
| | | |
|---|
| | | models.Init() |
|---|
| | | defer models.CloseDB() |
|---|
| | | models.GetDB().SetLogger(&serf.DbLogger{}) |
|---|
| | |
|---|
| | | return funcMap, pubTopics |
|---|
| | | } |
|---|
| | | |
|---|
| | | //测试接收全网消息 |
|---|
| | | // 测试接收全网消息 |
|---|
| | | func dealSubMsg(ctx context.Context, ms *bhomeclient.MicroNode) { |
|---|
| | | for { |
|---|
| | | select { |
|---|
