go微服务系列之二

李海彬

发布于 2019-05-08 10:41:03

5270

发布于 2019-05-08 10:41:03

文章被收录于专栏：Golang语言社区Golang语言社区

作者：稀饭下雪链接：https://www.jianshu.com/p/35d6b432aefa 来源：简书

这是使用gomicro开发微服务系列的第二篇，在上一篇中我只是使用了user-srv和web-srv实现了一个demo，在这里我将实用consul实现服务发现。如果想直接查阅源码或者通过demo学习的，可以访问ricoder_demo。

如何编写一个微服务？这里用的是go的微服务框架go micro，具体的情况可以查阅：http://btfak.com/%E5%BE%AE%E6%9C%8D%E5%8A%A1/2016/03/28/go-micro/

一、如何安装consul

我的开发系统采用的是ubunt16.04，这里就给出ubuntu下安装consul的步骤：

 1$ wget https://releases.hashicorp.com/consul/0.7.2/consul_0.7.2_linux_amd64.zip
 2$ sudo apt-get install unzip
 3
 4$ ls
 5
 6$ unzip consul_0.7.2_linux_amd64.zip
 7$ sudo mv consul /usr/local/bin/consul
 8
 9$ wget https://releases.hashicorp.com/consul/0.7.2/consul_0.7.2_web_ui.zip
10$ unzip consul_0.7.2_web_ui.zip
11$ mkdir -p /usr/share/consul
12$ mv dist /usr/share/consul/ui

Consul 压缩包地址：https://www.consul.io/downloads.html

验证安装是否成功的方法：

 1$ consul
 2Usage: consul [--version] [--help] <command> [<args>]
 3
 4Available commands are:
 5    agent          Runs a Consul agent
 6    catalog        Interact with the catalog
 7    event          Fire a new event
 8    exec           Executes a command on Consul nodes
 9    force-leave    Forces a member of the cluster to enter the "left" state
10    info           Provides debugging information for operators.
11    join           Tell Consul agent to join cluster
12    keygen         Generates a new encryption key
13    keyring        Manages gossip layer encryption keys
14    kv             Interact with the key-value store
15    leave          Gracefully leaves the Consul cluster and shuts down
16    lock           Execute a command holding a lock
17    maint          Controls node or service maintenance mode
18    members        Lists the members of a Consul cluster
19    monitor        Stream logs from a Consul agent
20    operator       Provides cluster-level tools for Consul operators
21    reload         Triggers the agent to reload configuration files
22    rtt            Estimates network round trip time between nodes
23    snapshot       Saves, restores and inspects snapshots of Consul server state
24    validate       Validate config files/directories
25    version        Prints the Consul version
26    watch          Watch for changes in Consul

启动consul服务的方法：

 1$ consul agent -dev
 2==> Starting Consul agent...
 3==> Consul agent running!
 4           Version: 'v0.9.3'
 5           Node ID: '199ee0e9-db61-f789-b22a-b6b472f63fbe'
 6         Node name: 'ricoder'
 7        Datacenter: 'dc1' (Segment: '<all>')
 8            Server: true (Bootstrap: false)
 9       Client Addr: 127.0.0.1 (HTTP: 8500, HTTPS: -1, DNS: 8600)
10      Cluster Addr: 127.0.0.1 (LAN: 8301, WAN: 8302)

优雅的停止服务的方法：

命令：CTRL+C

其他命令：

consul members：查看集群成员 consul info：查看当前服务器的状况 consul leave：退出当前服务集群

成功开启consul服务后可以登录后台访问地址：http://localhost:8500，如下：

二、api-srv的开发，实现动态路由

根据官方对api-srv的介绍：The micro api is an API gateway for microservices. Use the API gateway pattern to provide a single entry point for your services. The micro api serves HTTP and dynamically routes to the appropriate backend service. 粗略翻译的意思就是：api-srv是微服务的网关，使用API网关模式可以为我们的服务提供一个入口，api-srv提供HTTP服务，并动态路由到相应的后端服务。

步骤1：监听8082端口，并绑定handler处理http请求

1    mux := http.NewServeMux()
2    mux.HandleFunc("/", handleRPC)
3    log.Println("Listen on :8082")
4    http.ListenAndServe(":8082", mux)

步骤2：实现handler，并实现跨域处理

 1    if r.URL.Path == "/" {
 2        w.Write([]byte("ok,this is the server ..."))
 3        return
 4    }
 5
 6    // 跨域处理
 7    if origin := r.Header.Get("Origin"); cors[origin] {
 8        w.Header().Set("Access-Control-Allow-Origin", origin)
 9    } else if len(origin) > 0 && cors["*"] {
10        w.Header().Set("Access-Control-Allow-Origin", origin)
11    }
12
13    w.Header().Set("Access-Control-Allow-Methods", "POST, GET, OPTIONS")
14    w.Header().Set("Access-Control-Allow-Headers", "Content-Type, Content-Length, Accept-Encoding, X-Token, X-Client")
15    w.Header().Set("Access-Control-Allow-Credentials", "true")
16    if r.Method == "OPTIONS" {
17        return
18    }
19
20    if r.Method != "POST" {
21        http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
22        return
23    }

步骤3：实现将url转换为service和method，这里我采用了pathToReceiver这个函数来处理

 1    p = path.Clean(p)
 2    p = strings.TrimPrefix(p, "/")
 3    parts := strings.Split(p, "/")
 4
 5    // If we've got two or less parts
 6    // Use first part as service
 7    // Use all parts as method
 8    if len(parts) <= 2 {
 9        service := ns + strings.Join(parts[:len(parts)-1], ".")
10        method := strings.Title(strings.Join(parts, "."))
11        return service, method
12    }
13
14    // Treat /v[0-9]+ as versioning where we have 3 parts
15    // /v1/foo/bar => service: v1.foo method: Foo.bar
16    if len(parts) == 3 && versionRe.Match([]byte(parts[0])) {
17        service := ns + strings.Join(parts[:len(parts)-1], ".")
18        method := strings.Title(strings.Join(parts[len(parts)-2:], "."))
19        return service, method
20    }
21
22    // Service is everything minus last two parts
23    // Method is the last two parts
24    service := ns + strings.Join(parts[:len(parts)-2], ".")
25    method := strings.Title(strings.Join(parts[len(parts)-2:], "."))
26    return service, method

http传进来的url是http://127.0.0.1:8082/user/userService/SelectUser，我在handler中通过以下方式调用后：

1service, method := apid.PathToReceiver(config.Namespace, r.URL.Path)

service和method分别是：

12017/10/14 13:56:12 service:com.class.cinema.user
22017/10/14 13:56:12 method:UserService.SelectUser

注意：var config.Namespace = "com.class.cinema" 步骤4：封装request，调用服务

1    br, _ := ioutil.ReadAll(r.Body)
2
3    request := json.RawMessage(br)
4
5    var response json.RawMessage
6    req := (*cmd.DefaultOptions().Client).NewJsonRequest(service, method, &request)
7    ctx := apid.RequestToContext(r)
8    err := (*cmd.DefaultOptions().Client).Call(ctx, req, &response)

在这里Call就是调用相应服务的关键。步骤5：对err进行相应的处理和返回调用结果

 1// make the call
 2    if err != nil {
 3        ce := microErrors.Parse(err.Error())
 4        switch ce.Code {
 5        case 0:
 6            // assuming it's totally screwed
 7            ce.Code = 500
 8            ce.Id = service
 9            ce.Status = http.StatusText(500)
10            // ce.Detail = "error during request: " + ce.Detail
11            w.WriteHeader(500)
12        default:
13            w.WriteHeader(int(ce.Code))
14        }
15        w.Write([]byte(ce.Error()))
16        return
17    }
18    b, _ := response.MarshalJSON()
19    w.Header().Set("Content-Length", strconv.Itoa(len(b)))
20    w.Write(b)

通过对err的处理，在请求的method或者service不存在时，如：