Go语言

Golang Gin实践 连载十七 用 Nginx 部署 Go 应用原文地址：Golang Gin实践 连载十七 用 Nginx 部署 Go 应用前言如果已经看过前面 “十六部连载，两部番外”，相信您的能力已经有所提升那么，现在今天来说说简单部署后端服务的事儿 ????做什么在本章节，我们将简单介绍 Nginx 以及使用 Nginx 来完成对 go-gin-example 的部署，会实现反向代理和简单负载均衡的功能Nginx是什么Nginx 是一个 Web Server，可以用作反向代理、负载均衡、邮件代理、TCP / UDP、HTTP 服务器等等，它拥有很多吸引人的特性，例如：以较低的内存占用率处理 10,000 多个并发连接（每10k非活动HTTP保持活动连接约2.5 MB ）静态服务器（处理静态文件）正向、反向代理负载均衡通过OpenSSL 对 TLS / SSL 与 SNI 和 OCSP 支持FastCGI、SCGI、uWSGI 的支持WebSockets、HTTP/1.1 的支持Nginx + Lua安装请右拐谷歌或百度，安装好 Nginx 以备接下来的使用简单讲解常用命令nginx：启动 Nginxnginx -s stop：立刻停止 Nginx 服务nginx -s reload：重新加载配置文件nginx -s quit：平滑停止 Nginx 服务nginx -t：测试配置文件是否正确nginx -v：显示 Nginx 版本信息nginx -V：显示 Nginx 版本信息、编译器和配置参数的信息涉及配置1、 proxy_pass：配置反向代理的路径。需要注意的是如果 proxy_pass 的 url 最后为/，则表示绝对路径。否则（不含变量下）表示相对路径，所有的路径都会被代理过去2、 upstream：配置负载均衡，upstream 默认是以轮询的方式进行负载，另外还支持四种模式，分别是：（1）weight：权重，指定轮询的概率，weight 与访问概率成正比（2）ip_hash：按照访问 IP 的 hash 结果值分配（3）fair：按后端服务器响应时间进行分配，响应时间越短优先级别越高（4）url_hash：按照访问 URL 的 hash 结果值分配部署在这里需要对 nginx.conf 进行配置，如果你不知道对应的配置文件是哪个，可执行 nginx -t 看一下$ nginx -tnginx: the configuration file /usr/local/etc/nginx/nginx.conf syntax is oknginx: configuration file /usr/local/etc/nginx/nginx.conf test is successful显然，我的配置文件在 /usr/local/etc/nginx/ 目录下，并且测试通过反向代理反向代理是指以代理服务器来接受网络上的连接请求，然后将请求转发给内部网络上的服务器，并将从服务器上得到的结果返回给请求连接的客户端，此时代理服务器对外就表现为一个反向代理服务器。（来自百科）配置 hosts由于需要用本机作为演示，因此先把映射配上去，打开 /etc/hosts，增加内容：127.0.0.1 api.blog.com配置 nginx.conf打开 nginx 的配置文件 nginx.conf（我的是 /usr/local/etc/nginx/nginx.conf），我们做了如下事情：增加 server 片段的内容，设置 server_name 为 api.blog.com 并且监听 8081 端口，将所有路径转发到 http://127.0.0.1:8000/ 下worker_processes 1;events { worker_connections 1024;}http { include mime.types; default_type application/octet-stream; sendfile on; keepalive_timeout 65; server { listen 8081; server_name api.blog.com; location / { proxy_pass http://127.0.0.1:8000/; } }}验证启动 go-gin-example回到 go-gin-example 的项目下，执行 make，再运行 ./go-gin-exmaple$ makegithub.com/EDDYCJY/go-gin-example$ lsLICENSE README.md conf go-gin-example middleware pkg runtime vendorMakefile README_ZH.md docs main.go models routers service$ ./go-gin-example …[GIN-debug] DELETE /api/v1/articles/:id –> github.com/EDDYCJY/go-gin-example/routers/api/v1.DeleteArticle (4 handlers)[GIN-debug] POST /api/v1/articles/poster/generate –> github.com/EDDYCJY/go-gin-example/routers/api/v1.GenerateArticlePoster (4 handlers)Actual pid is 14672重启 nginx$ nginx -tnginx: the configuration file /usr/local/etc/nginx/nginx.conf syntax is oknginx: configuration file /usr/local/etc/nginx/nginx.conf test is successful$ nginx -s reload访问接口如此，就实现了一个简单的反向代理了，是不是很简单呢负载均衡负载均衡，英文名称为Load Balance（常称 LB），其意思就是分摊到多个操作单元上进行执行（来自百科）你能从运维口中经常听见，XXX 负载怎么突然那么高。 那么它到底是什么呢？其背后一般有多台 server，系统会根据配置的策略（例如 Nginx 有提供四种选择）来进行动态调整，尽可能的达到各节点均衡，从而提高系统整体的吞吐量和快速响应如何演示前提条件为多个后端服务，那么势必需要多个 go-gin-example，为了演示我们可以启动多个端口，达到模拟的效果 为了便于演示，分别在启动前将 conf/app.ini 的应用端口修改为 8001 和 8002（也可以做成传入参数的模式），达到启动 2 个监听 8001 和 8002 的后端服务配置 nginx.conf回到 nginx.conf 的老地方，增加负载均衡所需的配置。新增 upstream 节点，设置其对应的 2 个后端服务，最后修改了 proxy_pass 指向（格式为 http:// + upstream 的节点名称）worker_processes 1;events { worker_connections 1024;}http { include mime.types; default_type application/octet-stream; sendfile on; keepalive_timeout 65; upstream api.blog.com { server 127.0.0.1:8001; server 127.0.0.1:8002; } server { listen 8081; server_name api.blog.com; location / { proxy_pass http://api.blog.com/; } }}重启 nginx$ nginx -tnginx: the configuration file /usr/local/etc/nginx/nginx.conf syntax is oknginx: configuration file /usr/local/etc/nginx/nginx.conf test is successful$ nginx -s reload验证再重复访问 http://api.blog.com:8081/auth?username={USER_NAME}}&password={PASSWORD}，多访问几次便于查看效果目前 Nginx 没有进行特殊配置，那么它是轮询策略，而 go-gin-example 默认开着 debug 模式，看看请求 log 就明白了总结在本章节，希望您能够简单习得日常使用的 Web Server 背后都是一些什么逻辑，Nginx 是什么？反向代理？负载均衡？怎么简单部署，知道了吧。参考本系列示例代码go-gin-example ...

https://golang.org/pkg/reflect/ 最重要的官方文档，建议先粗读一遍再来看本文。go 的 reflect 还是比较简单的，可以很快上手。https://github.com/golang/go/blob/master/src/reflect/type.go https://github.com/golang/go/blob/master/src/reflect/value.go源码中有上百个 panic，各种检查做的很全面，有想法就大胆地去试，只要能 run 起来，一般问题不大。实际使用中可以先不考虑使用 reflect 对性能的影响，先实现功能，再利用 benchmark test 去优化什么时候应该用 reflect为了降低多写代码造成的bug率，做更好的规约和抽象。为了灵活、好用、方便，做动态解析、调用和处理。为了代码好看、易读、提高开发效率，补足与动态语言之间的一些差别记住！reflect 不是用来实现你的奇技淫巧的！使用 reflect 要适可而止！reflect 核心TypeOf(i interface{}) Type重点看这个返回值，它是一个接口，主要实现它的是 struct rtype，这个也是 go 类型系统的核心，和 runtime/type.go struct _type 一致，这里就不深入展开了，回头再说。type Type interface { // 变量的内存对齐，返回 rtype.align Align() int // struct 字段的内存对齐，返回 rtype.fieldAlign FieldAlign() int // 根据传入的 i，返回方法实例，表示类型的第 i 个方法 Method(int) Method // 根据名字返回方法实例，这个比较常用 MethodByName(string) (Method, bool) // 返回类型方法集中可导出的方法的数量 NumMethod() int // 只返回类型名，不含包名 Name() string // 返回导入路径，即 import 路径 PkgPath() string // 返回 rtype.size 即类型大小，单位是字节数 Size() uintptr // 返回类型名字，实际就是 PkgPath() + Name() String() string // 返回 rtype.kind，描述一种基础类型 Kind() Kind // 检查当前类型有没有实现接口 u Implements(u Type) bool // 检查当前类型能不能赋值给接口 u AssignableTo(u Type) bool // 检查当前类型能不能转换成接口 u 类型 ConvertibleTo(u Type) bool // 检查当前类型能不能做比较运算，其实就是看这个类型底层有没有绑定 typeAlg 的 equal 方法。打住！不要去搜 typeAlg 是什么，不然你会陷进去的！先把本文看完。 Comparable() bool // 返回类型的位大小，但不是所有类型都能调这个方法，不能调的会 panic Bits() int // 返回 channel 类型的方向，如果不是 channel，会 panic ChanDir() ChanDir // 返回函数类型的最后一个参数是不是可变数量的，"…" 就这样的，同样，如果不是函数类型，会 panic IsVariadic() bool // 返回所包含元素的类型，只有 Array, Chan, Map, Ptr, Slice 这些才能调，其他类型会 panic，这不是废话吗。。其他类型也没有包含元素一说。 Elem() Type // 返回 struct 类型的第 i 个字段，不是 struct 会 panic，i 越界也会 panic Field(i int) StructField // 跟上边一样，不过是嵌套调用的，比如 [1, 2] 就是说返回当前 struct 的第1个struct 的第2个字段，适用于 struct 本身嵌套的类型 FieldByIndex(index []int) StructField // 按名字找 struct 字段，第二个返回值 ok 表示有没有 FieldByName(name string) (StructField, bool) // 按函数名找 struct 字段，因为 struct 里也可能有类型是 func 的嘛 FieldByNameFunc(match func(string) bool) (StructField, bool) // 返回函数第 i 个参数的类型，不是 func 会 panic In(i int) Type // 返回 map 的 key 的类型，不是 map 会 panic Key() Type // 返回 array 的长度，不是 array 会 panic Len() int // 返回 struct 字段数量，不是 struct 会 panic NumField() int // 返回函数的参数数量，不是 func 会 panic NumIn() int // 返回函数的返回值数量，不是 func 会 panic NumOut() int // 返回函数第 i 个返回值的类型，不是 func 会 panic Out(i int) Type}ValueOf(i interface{}) Value先看看定义吧，就这么点东西。type Value struct { // 反射出来此值的类型，rtype 是啥往上看，但可别弄错了，这 typ 是未导出的，从外部调不到 Type 接口的方法 typ *rtype // 数据形式的指针值 ptr unsafe.Pointer // 保存元数据 flag}Value 的方法太多了，参考开头的官方文档吧，我下面挑几个重点的说一下，像 len，cap 这种简单的就不介绍了：// 前提 v 是一个 func，然后调用 v，并传入 in 参数，第一个参数是 in[0]，第二个是 in[1]，以此类推func (v Value) Call(in []Value) []Value// 返回 v 的接口值或者指针func (v Value) Elem() Value// 前提 v 是一个 struct，返回第 i 个字段，这个主要用于遍历func (v Value) Field(i int) Value// 前提 v 是一个 struct，根据字段名直接定位返回func (v Value) FieldByName(name string) Value// 前提 v 是 Array, Slice, String 之一，返回第 i 个元素，主要也是用于遍历，注意不能越界func (v Value) Index(i int) Value// 判断 v 是不是 nil，只有 chan, func, interface, map, pointer, slice 可以用，其他类型会 panicfunc (v Value) IsNil() bool// 判断 v 是否合法，如果返回 false，那么除了 String() 以外的其他方法调用都会 panic，事前检查是必要的func (v Value) IsValid() bool// 前提 v 是个 map，返回对应 valuefunc (v Value) MapIndex(key Value)// 前提 v 是个 map，返回所有 key 组成的一个 slicefunc (v Value) MapKeys() []Value// 前提 v 是个 struct，返回字段个数func (v Value) NumField() int// 赋值func (v Value) Set(x Value)// 类型func (v Value) Type() Typereflect 场景实践动态调用函数（无参数）type T struct {}func main() { name := “Do” t := &T{} reflect.ValueOf(t).MethodByName(name).Call(nil)}func (t *T) Do() { fmt.Println(“hello”)}动态调用函数（有参数）type T struct{}func main() { name := “Do” t := &T{} a := reflect.ValueOf(1111) b := reflect.ValueOf(“world”) in := []reflect.Value{a, b} reflect.ValueOf(t).MethodByName(name).Call(in)}func (t *T) Do(a int, b string) { fmt.Println(“hello” + b, a)}处理返回值中的错误返回值也是 Value 类型，对于错误，可以转为 interface 之后断言type T struct{}func main() { name := “Do” t := &T{} ret := reflect.ValueOf(t).MethodByName(name).Call(nil) fmt.Printf(“strValue: %[1]vnerrValue: %[2]vnstrType: %[1]TnerrType: %[2]T”, ret[0], ret[1].Interface().(error))}func (t *T) Do() (string, error) { return “hello”, errors.New(“new error”)}struct tag 解析type T struct { A int json:"aaa" test:"testaaa" B string json:"bbb" test:"testbbb"}func main() { t := T{ A: 123, B: “hello”, } tt := reflect.TypeOf(t) for i := 0; i < tt.NumField(); i++ { field := tt.Field(i) if json, ok := field.Tag.Lookup(“json”); ok { fmt.Println(json) } test := field.Tag.Get(“test”) fmt.Println(test) }}类型转换和赋值type T struct { A int newT:"AA" B string newT:"BB"}type newT struct { AA int BB string}func main() { t := T{ A: 123, B: “hello”, } tt := reflect.TypeOf(t) tv := reflect.ValueOf(t) newT := &newT{} newTValue := reflect.ValueOf(newT) for i := 0; i < tt.NumField(); i++ { field := tt.Field(i) newTTag := field.Tag.Get(“newT”) tValue := tv.Field(i) newTValue.Elem().FieldByName(newTTag).Set(tValue) } fmt.Println(newT)}通过 kind（）处理不同分支func main() { a := 1 t := reflect.TypeOf(a) switch t.Kind() { case reflect.Int: fmt.Println(“int”) case reflect.String: fmt.Println(“string”) }}判断实例是否实现了某接口type IT interface { test1()}type T struct { A string}func (t *T) test1() {}func main() { t := &T{} ITF := reflect.TypeOf((*IT)(nil)).Elem() tv := reflect.TypeOf(t) fmt.Println(tv.Implements(ITF))}未完待续… ...

本文主要讲实践，原理部分会一笔带过，关于 go 语言并发实现和内存模型后续会有文章。channel 实现的源码不复杂，推荐阅读，https://github.com/golang/go/…channel 是干什么的意义：channel 是用来通信的实际上：（数据拷贝了一份，并通过 channel 传递，本质就是个队列）channel 应该用在什么地方核心：需要通信的地方例如以下场景：通知广播交换数据显式同步并发控制…记住！channel 不是用来实现锁机制的，虽然有些地方可以用它来实现类似读写锁，保护临界区的功能，但不要这么用！channel 用例实现超时控制// 利用 time.After 实现func main() { done := do() select { case <-done: // logic case <-time.After(3 * time.Second): // timeout }}func do() <-chan struct{} { done := make(chan struct{}) go func() { // do something // … done <- struct{}{} }() return done}取最快的结果比较常见的一个场景是重试，第一个请求在指定超时时间内没有返回结果，这时重试第二次，取两次中最快返回的结果使用。超时控制在上面有，下面代码部分就简单实现调用多次了。func main() { ret := make(chan string, 3) for i := 0; i < cap(ret); i++ { go call(ret) } fmt.Println(<-ret)}func call(ret chan<- string) { // do something // … ret <- “result”}限制最大并发数// 最大并发数为 2limits := make(chan struct{}, 2)for i := 0; i < 10; i++ { go func() { // 缓冲区满了就会阻塞在这 limits <- struct{}{} do() <-limits }()}for…range 优先for … range c { do } 这种写法相当于 if _, ok := <-c; ok { do }func main() { c := make(chan int, 20) go func() { for i := 0; i < 10; i++ { c <- i } close(c) }() // 当 c 被关闭后，取完里面的元素就会跳出循环 for x := range c { fmt.Println(x) }}多个 goroutine 同步响应利用 close 广播func main() { c := make(chan struct{}) for i := 0; i < 5; i++ { go do(c) } close(c)}func do(c <-chan struct{}) { // 会阻塞直到收到 close <-c fmt.Println(“hello”)}非阻塞的 selectselect 本身是阻塞的，当所有分支都不满足就会一直阻塞，如果想不阻塞，那么一个什么都不干的 default 分支是最好的选择select {case <-done: returndefault: }for{select{}} 终止尽量不要用 break label 形式，而是把终止循环的条件放到 for 条件里来实现for ok { select { case ch <- 0: case <-done: ok = false }}未完待续…channel 特性基础特性操作值为 nil 的 channel被关闭的 channel正常的 channelclosepanicpanic成功关闭c<-永远阻塞panic阻塞或成功发送<-c永远阻塞永远不阻塞阻塞或成功接收happens-before 特性无缓冲时，接收 happens-before 发送任何情况下，发送 happens-before 接收close happens-before 接收参考https://go101.org/article/channel.htmlhttps://golang.org/doc/effective_go.html#channels ...