go微服务系列(二) - 服务注册/服务发现
2024-10-09 13:32:59
1. 服务注册
1.1 代码演示
还是跟上一篇:go微服务(一) - go micro入门一样使用consul
package main
import (
"net/http"
"github.com/gin-gonic/gin"
"github.com/micro/go-micro/registry"
"github.com/micro/go-micro/web"
"github.com/micro/go-plugins/registry/consul"
)
func main() {
// 1.添加consul地址
cr := consul.NewRegistry(
registry.Addrs("127.0.0.1:8500"))
// 2.使用gin作为router
router := gin.Default()
router.GET("/user", func(c *gin.Context) {
c.String(http.StatusOK, "user api")
})
// 3.初始化go micro
server := web.NewService(
web.Name("productService"), // 当前微服务服务名
web.Registry(cr), // 注册到consul
web.Address(":8081"), // 端口
web.Metadata(map[string]string{"protocol": "http"}), // 元信息
web.Handler(router)) // 路由
_ = server.Run()
}
1.2 在go run的时候传入服务注册的参数
上面为了演示简便,直接将服务注册的服务名
和端口
等写死在代码里,但是实际运用场景不可能这么写,所以我们一般会
- 把这部分定义在配置文件里
- 使用go micro提供的功能,可以在
go run
的时候传入参数
下面演示下如何在go run
的时候传入参数
第一步
在原来的服务注册的基础代码上添加server.Init()
加上这个就会解析cli命令中的参数
如下导航到源码看下具体的实现,就是添加了Init()
方法之后,会将我们传入的cli命令的特定参数,进行注册,优先级高于代码定义的
第二步
这里选择改变下服务注册的端口,即在main包路径下执行以下命令,且开两个tab执行两次
# tab1
go run productService_main.go --server_address :8088
# tab2
go run productService_main.go --server_address :8089
如下运行成功:
然后去consul界面查看,两个实例都注册成功:
2. 服务发现均衡负载
2.1 均衡负载算法
go-micro的服务发现的算法由github.com/micro/go-micro/client/selector
下的selector
提供,目前提供了两种算法
- RoundRobin(轮询算法)
- Random(随机算法)
2.2 服务发现均衡负载的演示
使用上一节的方式,服务注册部分,同时启动了以下三个端口的productService
服务
- 8088
- 8089
- 8090
然后在服务发现部分:
- 使用
selector.Random
来随机发现服务 - 使用for循环来持续获取
- 打印出当前获取到的服务实例的端口
func main() {
// 1.连接到consul
cr := consul.NewRegistry(registry.Addrs("127.0.0.1:8500"))
// 使用for循环持续获取
for {
// 2.根据service name获取对应的微服务列表
services, err := cr.GetService("productService")
if err != nil {
log.Fatal("cannot get service list")
}
// 3.使用random随机获取其中一个实例
next := selector.Random(services)
svc, err := next()
if err != nil {
log.Fatal("cannot get service")
}
fmt.Println("[测试输出]:", svc.Address)
time.Sleep(time.Second * 1)
}
}
所以输出的实例端口可以看如下,随机获取到三个端口中的任意一个
这时候吧8090
端口的服务给关掉,再看下输出,就不会有8090
端口的实例了
最新文章
- 想学习Android开发
- JFinal 国际化
- 八、天气App案例
- java之main函数(笔记)
- nodejs 简单http 文件上传demo
- ECharts JavaScript图表库 ECharts
- HTML——JAVASCRIPT——关灯效果
- 快速构建C++项目工具Scons,结合Editplus搭建开发环境
- Spring.net 学习IOC------属性注入
- C# 中文在URL中的编码
- 【转】关于Sentry
- 使用MySQL workbench 和Excel表之间的数据互相导出
- Mac 下重新安装配置ibm Lotus 邮箱
- 在SharePoint 2013 场中移除服务器,提示 cacheHostInfo is null 错误
- git版本超前了N个版本且落后了N个版本的解决办法
- Linux内核中的机制学习总结
- [Xamarin]我的Xamarin填坑之旅(二)
- 基于Vue的弹框实例
- 自用广告过滤规则,整合xwhyc大大的,非常小才79K
- jsonp爬取页面
热门文章
- git的撤销、删除和版本回退
- (3)html-webpack-plugin的作用
- three.js 绘制3d地图
- Cyber Security - Palo Alto Basic Introduction
- Python Ethical Hacking - Malware Analysis(1)
- javascript : splice(0) 的妙用
- IOS上传图片方向问题
- .Net Core AES加解密
- nginx配置多个图片访问路径
- python map() filter() reduce()函数的用法以及实例