/
api.go
106 lines (89 loc) · 2.46 KB
/
api.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
package common
import (
"github.com/labstack/echo"
"github.com/labstack/echo/middleware"
"github.com/micro/go-web"
"github.com/xiaomeng79/go-example/cinit"
"github.com/xiaomeng79/go-example/internal/metrics"
"github.com/xiaomeng79/go-log"
"net/http"
"time"
)
//定义services名称
const SN = "com.example.api.common"
//运行
func Run() {
//初始化
cinit.InitOption(SN, "trace")
//新建服务
serviceName := cinit.Config.Service.Name
serviceVersion := cinit.Config.Service.Version
service := web.NewService(
web.Name(serviceName),
web.Version(serviceVersion),
web.RegisterTTL(time.Second*30),
web.RegisterInterval(time.Second*15),
)
log.Info("创建服务:名称:" + serviceName + ",版本:" + serviceVersion)
// 定义Service动作操作
service.Init()
web.AfterStop(func() error {
log.Info("停止服务")
//停止配置
cinit.Close()
return nil
})
//连接服务
NewUserClient("com.example.srv.user")
//注册路由
e := echo.New()
e.Use(middleware.Recover())
e.Use(middleware.Logger())
e.Use(middleware.CORSWithConfig(middleware.CORSConfig{
AllowOrigins: []string{"*"},
AllowHeaders: []string{"X-Requested-With", "Content-Type", "Origin", "Authorization", "Accept", "Client-Security-Token", "Accept-Encoding"},
AllowMethods: []string{echo.GET, echo.PUT, echo.POST, echo.DELETE},
}))
e.Use(Opentracing)
//metrics
// Metrics
if cinit.Config.Metrics.Enable == "yes" {
/* Pull模式
e.Use(prometheus.MetricsFunc(
prometheus.Namespace("common_api"),
))
*/
// Push模式
m := metrics.NewMetrics()
e.Use(MetricsFunc(m))
m.MemStats()
// InfluxDB
m.InfluxDBWithTags(
time.Duration(cinit.Config.Metrics.Duration)*time.Second,
cinit.Config.Metrics.Url,
cinit.Config.Metrics.Database,
cinit.Config.Metrics.UserName,
cinit.Config.Metrics.Password,
map[string]string{"service": serviceName},
)
// Graphite
//addr, _ := net.ResolveTCPAddr("tcp", Conf.Metrics.Address)
//m.Graphite(Conf.Metrics.FreqSec*time.Second, "echo-web.node."+hostname, addr)
}
//加验证JWT路由组,版本v1
g1 := e.Group("/common/v1", JWT)
g1.POST("/userinfo", userinfo)
//不验证JWT路由组
g2 := e.Group("/common/v1")
g2.POST("/login", login)
//check
check := e.Group("/common/check")
check.GET("/health", func(c echo.Context) error {
return c.String(http.StatusOK, "ok")
})
service.Handle("/", e)
//启动service
if err := service.Run(); err != nil {
log.Fatal("启动服务失败" + err.Error())
}
}