浏览器的请求去请求目标地址，然后获得结果它再发送给浏览器。对于Go语言来说，实现转发只需要简单的一行代码即可实现，如下所示：
|
1
|
httputil.NewSingleHostReverseProxy(address) |
基于此功能，进行简单包装，实现从远端admin管理中心获取需要转发的路由信息或者可以从本地配置文件中获取，实现动态转发。后续可以根据业务情况，可以实现如下功能：
开发接口，实现动态添加代理规则，进行转发
- 过滤不合法的接口
- 接口限流
- 统一日志记录
- …
代码如下：
|
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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
package mainimport ( "encoding/json" "flag" "fmt" "github.com/gin-gonic/gin" "io" "io/ioutil" "log" "net/http" "net/http/httputil" "net/url" "os" "strings")type Respond struct { Success bool Status string Data []Proxy}type Proxy struct { Remark string //描述 Prefix string //转发的前缀判断 Upstream string //后端 nginx 地址或者ip地址 RewritePrefix string //重写}var ( InfoLog *log.Logger ErrorLog *log.Logger proxyMap = make(map[string]Proxy))var adminUrl = flag.String("adminUrl", "", "admin的地址")var profile = flag.String("profile", "", "环境")var proxyFile = flag.String("proxyFile", "", "测试环境的数据")//日志初始化func initLog() { errFile, err := os.OpenFile("errors.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666) infoFile, err := os.OpenFile("info.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666) if err != nil { log.Fatalln("打开日志文件失败：", err) } InfoLog = log.New(io.MultiWriter(os.Stderr, infoFile), "Info:", log.LstdFlags|log.Lmicroseconds|log.Lshortfile) ErrorLog = log.New(io.MultiWriter(os.Stderr, errFile), "Error:", log.LstdFlags|log.Lmicroseconds|log.Lshortfile)}func main() { router := gin.Default() //创建一个router flag.Parse() initLog() if *profile != "" { InfoLog.Printf("加载远端数据: %s ", *adminUrl) initProxyList() } else { InfoLog.Printf("加载本地配置数据: %s", *proxyFile) loadProxyListFromFile() } router.Any("/*action", Forward) //所有请求都会经过Forward函数转发 router.Run(":8000")}func initProxyList() { resp, _ := http.Get(*adminUrl) if resp != nil && resp.StatusCode == 200 { bytes, err := ioutil.ReadAll(resp.Body) defer resp.Body.Close() if err != nil { fmt.Println("ioutil.ReadAll err=", err) return } var respond Respond err = json.Unmarshal(bytes, &respond) if err != nil { fmt.Println("json.Unmarshal err=", err) return } proxyList := respond.Data for _, proxy := range proxyList { //追加 反斜杠，为了动态匹配的时候 防止 /proxy/test /proxy/test1 无法正确转发 proxyMap[proxy.Prefix+"/"] = proxy } }}func Forward(c *gin.Context) { HostReverseProxy(c.Writer, c.Request)}func HostReverseProxy(w http.ResponseWriter, r *http.Request) { if r.RequestURI == "/favicon.ico" { io.WriteString(w, "Request path Error") return } //从内存里面获取转发的url var upstream = "" if value, ok := proxyMap[r.RequestURI]; ok { //如果转发的地址是 / 开头的,需要去掉 if strings.HasSuffix(value.Upstream, "/") { upstream += strings.TrimRight(value.Upstream, "/") } else { upstream += value.Upstream } //如果首位不是/开头，则需要追加 if !strings.HasPrefix(value.RewritePrefix, "/") { upstream += "/" + value.RewritePrefix } else { upstream += value.RewritePrefix } //去掉开头 r.URL.Path = strings.ReplaceAll(r.URL.Path, r.RequestURI, "") } // parse the url remote, err := url.Parse(upstream) InfoLog.Printf("RequestURI %s upstream %s remote %s", r.RequestURI, upstream, remote) if err != nil { panic(err) } r.URL.Host = remote.Host r.URL.Scheme = remote.Scheme r.Header.Set("X-Forwarded-Host", r.Header.Get("Host")) r.Host = remote.Host httputil.NewSingleHostReverseProxy(remote).ServeHTTP(w, r)}func loadProxyListFromFile() { file, err := os.Open(*proxyFile) if err != nil { ErrorLog.Println("err:", err) } var respond Respond // 创建json解码器 decoder := json.NewDecoder(file) err = decoder.Decode(&respond) if err != nil { fmt.Println("LoadProxyListFromFile failed", err.Error()) } proxyList := respond.Data for _, proxy := range proxyList { proxyMap[proxy.Prefix+"/"] = proxy }} |
proxy_data.json 格式如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
{ "success":true, "status": "ok", "data": [ { "remark": "测试环境", "prefix": "/division", "upstream": "http://test.xxxxx.cn/", "rewritePrefix": "/api/division" }, { "remark": "测试环境1", "prefix": "/division1", "upstream": "http://test.xxxx.cn/", "rewritePrefix": "" }, { "remark": "测试环境2", "prefix": "/division3", "upstream": "http://test.xxxxxx.cn/", "rewritePrefix": "/api/division" } ]} |
启动脚本
|
1
2
3
4
|
## 加载本地配置文件数据go run proxy_agent.go -proxyFile ./proxy_data.json## 启动从配置中心获取数据go run proxy_agent.go -profile prod -adminUrl http://localhost:3000/proxy/findAll |
到此这篇关于基于Go语言实现的简易api网关的示例代码的文章就介绍到这了,更多相关Go api网关 内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！
原文链接：https://blog.csdn.net/dong945221578/article/details/110679480
