/micro-service

go-micro2.x微服务,etcd作为服务注册发现中间件,项目同时包含了service端、api端、client端以及micro api提供的restful。可按需拆分形成独立的微服务。

Primary LanguageGoMIT LicenseMIT

micro-service

go语言微服务

Getting Started

项目目录说明

目前的项目结构看起来像是一个独立的项目，实际真实的项目结构不是这样的，本项目为了简单使用而故意为之。 实际情况是micro-service下的每一个目录都是一个独立的微服务，需要独立部署在不同的服务器上，每个服务都需要自己 的go.mod,proto等文件和目录。

依赖

grpc v1.25.1， v1.27.1会有类型这样的错误undefined: resolver.BuildOption,undefined: resolver.ResolveNowOption

Usage

生成*.pb.go代码

$ protoc --proto_path=. --micro_out=. --go_out=. proto/user/user.proto

测试client

go run service/main.go
go run client/main.go

测试api服务

go run service/main.go
go run api/main.go
micro api --handler=api
curl "http://localhost:8080/user/say/hello?name=huohuo"

返回 {"id":"123","password":"dslhgfoif40u9b9","username":"huohuo"}

api层说明：

API模块，它的身份其实就是一个网关或者代理层，它的能力就是让一个单一的入口可以去访问微服务。API工作在我们的软件服务架构的边缘。

api作用

服务注册服务

v2.0版本默认使用的服务注册发现是mdns。 Micro内置了mDNS组播系统，这是一种零依赖的服务注册发现机制，它是区别于有注册中心的替代方案。 通过在启动指令中传入--registry=mdns 或者在环境变量中设置MICRO_REGISTRY=mdns。 其实也可以不传，早期版本的go-micro默认注册中心是consul，现在换成了mdns mDNS（多播DNS）是一种局域网内使用的DNS机制，他的大致原理如下：当有新的节点加入局域网的时候，如果打开了mDNS，就主动向局域网其他所有节点广播，自己提供的服务（域名是什么、ip地址是什么、端口号是什么）, 这样我们任何一个节点都知道局域网提供了什么服务。 所以生产环境需要其他中间件，如consul，etcd。

使用etcd作为服务发现中间件

go-micro v2弃用了consul，推荐使用的是etcd。 使用方法：

go run service/main.go --registry=etcd
go run api/main.go --registry=etcd
micro --registry=etcd api --handler=api

在启动的时候加上--registry=etcd参数即可，启动日志如下：

2020-03-14 16:17:07 Starting [service] go.micro.srv.user
2020-03-14 16:17:07 Server [grpc] Listening on [::]:10507
2020-03-14 16:17:07 Registry [etcd] Registering node: go.micro.srv.user-332fd9a8-f241-4c20-bf93-ee832b487261

Registry [mdns]变成了Registry [etcd]。

启动三个etcd实例：

.\etcd.exe --name etcd01 ^
--data-dir .\data\etcd01 ^
--advertise-client-urls http://127.0.0.1:2379 ^
--listen-client-urls http://127.0.0.1:2379 ^
--listen-peer-urls http://127.0.0.1:2380 ^
--initial-advertise-peer-urls http://127.0.0.1:2380 ^
--initial-cluster-token etcd-cluster-1 ^
--initial-cluster etcd01=http://127.0.0.1:2380,etcd02=http://127.0.0.1:2381,etcd03=http://127.0.0.1:2382 ^
--initial-cluster-state new

pause
.\etcd.exe --name etcd02 ^
--data-dir .\data\etcd02 ^
--advertise-client-urls http://127.0.0.1:3379 ^
--listen-client-urls http://127.0.0.1:3379 ^
--listen-peer-urls http://127.0.0.1:2381 ^
--initial-advertise-peer-urls http://127.0.0.1:2381 ^
--initial-cluster-token etcd-cluster-1 ^
--initial-cluster etcd01=http://127.0.0.1:2380,etcd02=http://127.0.0.1:2381,etcd03=http://127.0.0.1:2382 ^
--initial-cluster-state new

pause
.\etcd.exe --name etcd03 ^
--data-dir .\data\etcd03 ^
--advertise-client-urls http://127.0.0.1:4379 ^
--listen-client-urls http://127.0.0.1:4379 ^
--listen-peer-urls http://127.0.0.1:2382 ^
--initial-advertise-peer-urls http://127.0.0.1:2382 ^
--initial-cluster-token etcd-cluster-1 ^
--initial-cluster etcd01=http://127.0.0.1:2380,etcd02=http://127.0.0.1:2381,etcd03=http://127.0.0.1:2382 ^
--initial-cluster-state new

pause

查看etcd节点状态

./etcdctl.exe --write-out=table --endpoints=http://127.0.0.1:2379,http://127.0.0.1:3379,http://127.0.0.1:4379 endpoint status
+-----------------------+------------------+---------+---------+-----------+------------+-----------+------------+--------------------+--------+
|       ENDPOINT        |        ID        | VERSION | DB SIZE | IS LEADER | IS LEARNER | RAFT TERM | RAFT INDEX | RAFT APPLIED INDEX | ERRORS |
+-----------------------+------------------+---------+---------+-----------+------------+-----------+------------+--------------------+--------+
| http://127.0.0.1:2379 | bf9071f4639c75cc |   3.4.4 |  115 kB |      true |      false |        13 |         99 |                 99 |        |
| http://127.0.0.1:3379 | e7b968b9fb1bc003 |   3.4.4 |  115 kB |     false |      false |        13 |         99 |                 99 |        |
| http://127.0.0.1:4379 | 19ac17627e3e396f |   3.4.4 |  106 kB |     false |      false |        13 |         99 |                 99 |        |
+-----------------------+------------------+---------+---------+-----------+------------+-----------+------------+--------------------+--------+

启动两个新的服务并注册到etcd中

 go run service/main.go --registry=etcd --registry_address=http://127.0.0.1:3379
 go run service/main.go --registry=etcd --registry_address=http://127.0.0.1:4379

多次请求http://localhost:8080/user/say/hello?name=huohuo 会在三个服务轮询接收请求 停止某个服务并不会中断服务，以此实现了服务注册发现。

线上部署

在线上部署就不能使用go run service/main.go命令了，需要打包编译 linux系统需要这样编译：GOOS=linux go build -o service service/main.go

go build -o service service/main.go
./service --registry=etcd --registry_address=xx.xx.xx.xx:2379
go build -o api api/main.go
./api --registry=etcd --registry_address=xx.xx.xx.xx:2379

至于线上的restful api可以选择适合自己的web服务框架，在web服务中调用api服务。也可以像本地一样启动 web中服务中调用api层

micro --registry=etcd --registry_address=xx.xx.xx.xx:2379 api --handler=api

不过要在服务器上下载micro工具。

etcd启动

线上etcd和本地启动有讲究了，如果etcd是单独的服务器，那么在不加任何参数的情况下直接启动，那基本是调不通的。

$ ./service --registry=etcd --registry_address=xx.xx.xx.xx:2379
2020-03-17 17:04:42 Starting [service] go.micro.srv.user
2020-03-17 17:04:42 Server [grpc] Listening on [::]:48493
2020-03-17 17:04:42 Registry [etcd] Registering node: go.micro.srv.user-f32a2950-8e59-44d4-ac86-f4e1ec103395
{"level":"warn","ts":"2020-03-17T17:04:47.849+0800","caller":"clientv3/retry_interceptor.go:61","msg":"retrying of unary invoker failed","target":"endpoint://client-e45decee-12bf-4a9b-a7ab-f92eece39420/xx.xx.xx.xx:2379","attempt":0,"error":"rpc error: code = DeadlineExceeded desc = latest connection error: connection error: desc = \"transport: Error while dialing dial tcp xx.xx.xx.xx:2379: connect: connection refused\""}
2020-03-17 17:04:47 Server register error: %!(EXTRA context.deadlineExceededError=context deadline exceeded)

这就是错误示例，etcd拒绝连接。 为了能顺利看到胜利的结果，需要这样启动etcd:

$ ./etcd --listen-client-urls http://0.0.0.0:2379 --advertise-client-urls http://0.0.0.0:2379 --listen-peer-urls http://0.0.0.0:2380 --initial-advertise-peer-urls http://0.0.0.0:2380  --initial-cluster my-etcd-1=http://0.0.0.0:2380

将ip为0.0.0.0可以理解为不限制连接机器（真正的生产不推荐这样设置）。 服务启动参数--registry_address=xx.xx.xx.xx:2379不能带http://。

架构说明

项目中推荐使用github.com/micro/go-micro/v2/logger作为日志插件，输出的格式如： 2020-05-12 16:08:07 file=D:/workspace-go/src/micro-service/api/handler/user.handler.go:23 level=info Received Say.Hello API request 包含了时间 文件：行数 日志等级 信息