一个go-micro的demo

go-micro-微服务框架 ### 启动etcdv3集群 这里我用两台机器三个节点([192.168.3.45:2379, 192.168.3.45:2479], [192.168.3.118:2379]) #### node1 ```bash etcd --name cd0 \ --initial-advertise-peer-urls http://192.168.3.45:2380 \ --listen-peer-urls http://192.168.3.45:2380 \ --listen-client-urls http://192.168.3.45:2379 \ --advertise-client-urls http://192.168.3.45:2379 \ --initial-cluster-token etcd-cluster-1 \ --initial-cluster cd0=http://192.168.3.45:2380,cd1=http://192.168.3.45:2480,cd2=http://192.168.3.118:2380 \ --initial-cluster-state new ``` #### node2 ```bash etcd --name cd1 \ --initial-advertise-peer-urls http://192.168.3.45:2480 \ --listen-peer-urls http://192.168.3.45:2480 \ --listen-client-urls http://192.168.3.45:2479 \ --advertise-client-urls http://192.168.3.45:2479 \ --initial-cluster-token etcd-cluster-1 \ --initial-cluster cd0=http://192.168.3.45:2380,cd1=http://192.168.3.45:2480,cd2=http://192.168.3.118:2380 \ --initial-cluster-state new ``` #### node3 ```bash etcd --name cd2 \ --initial-advertise-peer-urls http://192.168.3.118:2380 \ --listen-peer-urls http://192.168.3.118:2380 \ --listen-client-urls http://192.168.3.118:2379 \ --advertise-client-urls http://192.168.3.118:2379 \ --initial-cluster-token etcd-cluster-1 \ --initial-cluster cd0=http://192.168.3.45:2380,cd1=http://192.168.3.45:2480,cd2=http://192.168.3.118:2380 \ --initial-cluster-state new ``` #### 测试etcd集群是否正常 ```bash thomasdeMacBook-Pro:~ www1$ etcdctl --endpoints="http://192.168.3.45:2379" endpoint health http://192.168.3.45:2379 is healthy: successfully committed proposal: took = 24.957199ms thomasdeMacBook-Pro:~ www1$ etcdctl --endpoints="http://192.168.3.45:2479" endpoint health http://192.168.3.45:2479 is healthy: successfully committed proposal: took = 19.160559ms thomasdeMacBook-Pro:~ www1$ etcdctl --endpoints="http://192.168.3.118:2379" endpoint health http://192.168.3.118:2379 is healthy: successfully committed proposal: took = 27.850165ms ``` ### micro安装etcd插件 在$GOPATH/src/github.com/micro/micro 下新建plugins.go ```golang package main import ( _ "github.com/micro/go-plugins/registry/etcdv3" ) ``` ```bash $ go build -i -o micro ./main.go ./plugins.go $ mv micro $GOBIN/ $ micro --registry=etcdv3 list services ``` ### 启动服务 #### clone代码 git clone git@github.com:weiwenwang/go-mcro-demo.git cd go-micro-demo - --selector=cache的作用是客户端(api,srv)在调服务器的时候,不用每次都去etcd拿数据,减轻注册中心的压力 - api1, api2, srv1, srv2是为了模拟多节点, 测试负债均衡 #### 启动Micro Api ``` micro --selector=cache --registry=etcdv3 --registry_address=http://192.168.3.45:2479 api --handler=api ``` HTTP API Listening on [::]:8080 监听到本地8080端口 #### 启动greeter Api并注册到etcd cd go-micro-demo/api1(启动第一个) ``` go run main.go --selector=cache --registry=etcdv3 --registry_address=http://192.168.3.45:2479 ``` cd go-micro-demo/api2(启动第二个) ``` go run main.go --selector=cache --registry=etcdv3 --registry_address=http://192.168.3.45:2479 ``` #### 启动greeter srv并注册到etcd cd go-micro-demo/srv/srv1(启动第一个) ```bash go run main.go --selector=cache --registry=etcdv3 --registry_address=http://192.168.3.118:2379 ```bash cd go-micro-demo/srv/srv2(启动第二个) ```bash go run main.go --selector=cache --registry=etcdv3 --registry_address=http://192.168.3.118:2379 ``` #### 逻辑图 这个图是我借用[别处](http://btfak.com/%E5%BE%AE%E6%9C%8D%E5%8A%A1/2016/03/20/micro/)的, 图上的ip和我这不一致, 服务之间的调用完全一样 [](https://i.loli.net/2019/06/19/5d09fbb10b5c556537.png) ### 查看etcdv3所有的key [](https://i.loli.net/2019/06/21/5d0ca52a667dd46348.png) ### 浏览器访问Micro Api http://localhost:8080/greeter/say/hello?name=John ``` { "api": "api two", "message": "Hello John srv one. rand:R" } { "api": "api one", "message": "Hello John srv one. rand:x" } { "api": "api two", "message": "Hello John srv two. rand:Y" } { "api": "api one", "message": "Hello John srv two. rand:a" } ``` 以上四种结果随机返回 ### 验证注册中心的ttl ``` thomasdeMacBook-Pro:~ www1$ etcdctl --endpoints="http://192.168.3.45:2379" lease list found 2 leases 05016b78d58c0234 05016b78d58c0230 thomasdeMacBook-Pro:~ www1$ etcdctl --endpoints="http://192.168.3.45:2379" lease timetolive 05016b78d58c0230 --keys lease 05016b78d58c0230 granted with TTL(30s), remaining(27s), attached keys([/micro-registry/go.micro.srv.greeter/go.micro.srv.greeter-6382949a-92c6-46c9-b5c9-4cfbb8ce2420]) thomasdeMacBook-Pro:~ www1$ etcdctl --endpoints="http://192.168.3.45:2379" lease timetolive 05016b78d58c0230 --keys lease 05016b78d58c0230 granted with TTL(30s), remaining(21s), attached keys([/micro-registry/go.micro.srv.greeter/go.micro.srv.greeter-6382949a-92c6-46c9-b5c9-4cfbb8ce2420]) thomasdeMacBook-Pro:~ www1$ etcdctl --endpoints="http://192.168.3.45:2379" lease timetolive 05016b78d58c0230 --keys lease 05016b78d58c0230 granted with TTL(30s), remaining(29s), attached keys([/micro-registry/go.micro.srv.greeter/go.micro.srv.greeter-6382949a-92c6-46c9-b5c9-4cfbb8ce2420]) ``` 这里有两个lease ID, 选一个05016b78d58c0230, 可以看出是存的是srv, ttl是30,remaining小于20的时候就会重新变成30, 符合我们的代码设置 ``` micro.RegisterTTL(time.Second*30), // 这是设置注册到etcd那个key的过期时间 micro.RegisterInterval(time.Second*10), // 这是服务去etcd报告自己还活着的周期 ```