詳解go-micro微服務(wù)consul配置及注冊中心
更新時間：2023年01月10日 11:19:18 作者：夏沫的夢
這篇文章主要為大家介紹了go-micro微服務(wù)consul配置及注冊中心示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
一 Consul介紹
Consul是HashiCorp公司推出的開源工具，用于實現(xiàn)分布式系統(tǒng)的服務(wù)發(fā)現(xiàn)與配置。 Consul是分布式的、高可用的、可橫向擴展的。
1. 注冊中心Consul基本介紹
- Consul是一種服務(wù)網(wǎng)格解決方案
- 提供具有服務(wù)發(fā)現(xiàn),配置和分段功能的全功能控制平面
- Consul 附帶-個簡單的內(nèi)置代理,可以開箱即用
2.注冊中心Consul關(guān)鍵功能
服務(wù)發(fā)現(xiàn):
- 客戶端可以注冊服務(wù)，程序可以輕松找到它們所依賴的服務(wù)
運行狀況檢查:
- Consul客戶端可以提供任意數(shù)量的運行狀況檢查
KV 存儲:
- 應(yīng)用程序可以將Consul的層級鍵/值存儲用于任何目的，包括動態(tài)配置，功能標(biāo)記，協(xié)調(diào)，領(lǐng)導(dǎo)者選舉等
安全服務(wù)通信:
- Consul 可以為服務(wù)生成和分發(fā)TLS證書，建立相互的TLS連接
多數(shù)據(jù)中心:
- Consul 支持多個數(shù)據(jù)中心
3.注冊中心Consul兩個重要協(xié)議
- Gossip Protocol (八卦協(xié)議)
- Raft Protocol ( 選舉協(xié)議)
對于想要學(xué)習(xí)Consul原理的，可以自行百度詳細(xì)了解這兩個協(xié)議。
二 Consul安裝
1.使用docker拉取鏡像
- 打開終端，輸入以下命令：
docekr pull consul
等待一段時間后拉取成功
- 啟動命令：
docker run -d -p 8500:8500 consul
consul會被運行在本機的8500端口上
- 檢查是否運行
docker ps
- 可視化界面
打開瀏覽器，輸入http://127.0.0.1:8500
三 Config配置
- 在config目錄下新建一個config.yaml
可以把配置相關(guān)信息先放在config.yaml里，之后放在consul中。
- 編寫代碼：
name: "Account" title: "賬號功能" mode: "dev" port: 9580 version: "v0.0.1" log: level: "debug" filename: "Account.log" max_size: 200 max_age: 30 max_backips: 7 mysql: host: "127.0.0.1" port: 3306 user: "root" password: "xxx" dbname: "micro" max_open_conns: 200 max_idle_conns: "50" redis: host: "127.0.0.1" port: 6379 password: "xxx" db: 4 pool_size: 100 email: user: "xxx@qq.com" pass: "xxx" host: "smtp.qq.com" port: 465 rename: "Account" # 配置、注冊中心 consul: host: "localhost" port: 8500 prefix: "/micro/config" consulRegistry: "127.0.0.1:8500" # 鏈路追蹤 jaeger: serviceName: "go.micro.service.account" addr: "localhost:6831" # 監(jiān)控服務(wù) prometheus: host: "0.0.0.0" port: 9089 # 限流 ratelimit: QPS: 1000 # 微服務(wù) micro: name: "go.micro.service.account" version: "latest" address: ":9580"
- 注意，以下字段自行修改：
- mysql.password
- redis.password
- email.user
- email.pass
四 Consul代碼編寫
- 在micro目錄下新建一個consul.go文件
1.設(shè)置consul配置中心
// GetConsulConfig 設(shè)置配置中心
func GetConsulConfig(host string, port int64, prefix string) (config.Config, error) {
consulSource := consul.NewSource(
//設(shè)置配置中心的地址
consul.WithAddress(host+":"+strconv.FormatInt(port, 10)),
//設(shè)置前綴，不設(shè)置默認(rèn)前綴 /micro/config
consul.WithPrefix(prefix),
//是否移除前綴，這里是設(shè)置為true，表示可以不帶前綴直接獲取對應(yīng)配置
consul.StripPrefix(true),
)
//配置初始化
newConfig, err := config.NewConfig()
if err != nil {
return newConfig, err
}
//加載配置
err = newConfig.Load(consulSource)
return newConfig, err
}
2.獲取consul配置中心的數(shù)據(jù)
- 編寫結(jié)構(gòu)體（嵌套結(jié)構(gòu)）
type Account struct {
Name string `json:"name"`
Title string `json:"title"`
Mode string `json:"mode"`
Port int64 `json:"port"`
Version string `json:"version"`
}
type Mysql struct {
Host string `json:"host"`
User string `json:"user"`
Pwd string `json:"pwd"`
Database string `json:"database"`
Port int64 `json:"port"`
}
type Log struct {
Level string `json:"level"`
Filename string `json:"filename"`
MaxSize int64 `json:"max_size"`
MaxAge int64 `json:"max_age"`
MaxBackips int64 `json:"max_backips"`
}
type Redis struct {
Host string `json:"host"`
Port int64 `json:"port"`
Password string `json:"password"`
Db int64 `json:"db"`
PoolSize int64 `json:"pool_size"`
}
type Email struct {
User string `json:"user"`
Pass string `json:"pass"`
Host string `json:"host"`
Port int64 `json:"port"`
Rename string `json:"rename"`
}
type Consul struct {
Host string `json:"host"`
Port int64 `json:"port"`
Prefix string `json:"prefix"`
ConsulRegistry string `json:"consulRegistry"`
}
type Jaeger struct {
ServiceName string `json:"serviceName"`
Addr string `json:"addr"`
}
type Prometheus struct {
Host string `json:"host"`
Port int64 `json:"port"`
}
type Ratelimit struct {
QPS int64 `json:"QPS"`
}
type Micro struct {
Name string `json:"name"`
Version string `json:"version"`
Address string `json:"address"`
}
type ConsulConfig struct {
Account Account `json:"account"`
Mysql Mysql `json:"mysql"`
Log Log `json:"log"`
Redis Redis `json:"redis"`
Email Email `json:"email"`
Consul Consul `json:"consul"`
Jaeger Jaeger `json:"jaeger"`
Prometheus Prometheus `json:"prometheus"`
Ratelimit Ratelimit `json:"ratelimit"`
Micro Micro `json:"micro"`
}
- 獲取consul數(shù)據(jù)
var(
ConsulInfo *ConsulConfig
)
// GetAccountFromConsul 獲取 consul 的配置
func GetAccountFromConsul(config config.Config, path ...string) error {
consulData := &ConsulConfig{}
config.Get(path...).Scan(consulData)
ConsulInfo = consulData
return nil
}
3.consul可視化界面數(shù)據(jù)編寫
點擊Key/Value，再點擊Create
- 輸入項目名稱： micro/config/account
選擇JSON
- 輸入以下代碼：
{
"account":{
"name": "Account",
"title": "賬號功能",
"mode": "dev",
"port": 9580,
"version": "v0.0.1"
},
"log":{
"level": "debug",
"filename": "Account.log",
"max_size": 200,
"max_age": 30,
"max_backips": 7
},
"mysql":{
"host":"127.0.0.1",
"user":"root",
"pwd":"xxx",
"database":"micro",
"port":3306
},
"redis":{
"host": "127.0.0.1",
"port": 6379,
"password": "123456",
"db": 4,
"pool_size": 100
},
"consul":{
"host": "localhost",
"port": 8500,
"prefix": "/micro/config",
"consulRegistry": "127.0.0.1:8500"
},
"email":{
"user": "xxx@qq.com",
"pass": "xxx",
"host": "smtp.qq.com",
"port": 465,
"rename": "Account"
},
"jaeger":{
"serviceName": "go.micro.service.account",
"addr": "localhost:6831"
},
"prometheus":{
"host": "0.0.0.0",
"port": 9089
},
"ratelimit":{
"QPS": 1000
},
"micro":{
"name": "go.micro.service.account",
"version": "latest",
"address": ":9580"
}
}
- 注意JSON格式，點擊Save
4. main.go代碼編寫
// 1.配置中心
consulConfig, err := micro.GetConsulConfig("localhost", 8500, "/micro/config")
if err != nil {
fmt.Printf("Init consulConfig failed, err: %v\n", err)
}
// 2.注冊中心
consulRegistry := consul.NewRegistry(func(options *registry.Options) {
options.Addrs = []string{
"127.0.0.1:8500",
}
})
if err := micro.GetAccountFromConsul(consulConfig, "account"); err != nil {
fmt.Printf("Init consul failed, err: %v\n", err)
}
fmt.Println(micro.ConsulInfo)
- 這時候，micro中的ConsulInfo可以用來使用consul中的數(shù)據(jù)了，使用 . 取數(shù)據(jù)
五 最后
- 至此，go-micro微服務(wù)consul配置、注冊中心開發(fā)工作就正式完成。
- 接下來就開始Mysql的代碼編寫了，希望大家關(guān)注博主和關(guān)注專欄，第一時間獲取最新內(nèi)容，每篇博客都干貨滿滿。
以上就是詳解go-micro微服務(wù)consul配置及注冊中心的詳細(xì)內(nèi)容，更多關(guān)于go micro consul配置注冊的資料請關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
這篇文章主要介紹了Go語言中Select語句用法,實例分析了select語句的原理與使用技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-02-02
在Go語言中，切片作為一種引用類型數(shù)據(jù)，相對數(shù)組而言是一種動態(tài)長度的數(shù)據(jù)類型，使用的場景也是非常多，所以本文主要來和大家聊聊切片的底層原理，需要的可以參考一下2023-06-06
golang控制結(jié)構(gòu)select機制及使用示例詳解
這篇文章主要介紹了golang控制結(jié)構(gòu)select機制及使用示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-10-10
我們在使用Gin框架進行Web開發(fā)的時候,基本上都會遇到登錄攔截的場景,在Gin當(dāng)中,?中間件和業(yè)務(wù)處理函數(shù)都是一樣的類型,都是一種函數(shù),本文給大家介紹了Gin的中間件執(zhí)行流程與用法,需要的朋友可以參考下2024-04-04
golang中內(nèi)存泄露的發(fā)現(xiàn)與排查一直是來是go開發(fā)者頭疼的一件事,下面這篇文章主要給大家介紹了關(guān)于Golang內(nèi)存泄漏場景以及解決的相關(guān)資料,文中通過實例代碼介紹的非常詳細(xì),需要的朋友可以參考下2023-01-01
這篇文章主要介紹了Go語言的代碼碼組織結(jié)構(gòu)詳細(xì)介紹,即Go語言源碼的文件結(jié)構(gòu),本文講解了包、main和main.main、os包等內(nèi)容,需要的朋友可以參考下2014-10-10
CSP communicating sequential processes并發(fā)模型
這篇文章主要為大家介紹了CSP communicating sequential processes并發(fā)模型，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-05-05
這篇文章主要介紹了Golang匯編之控制流，程序執(zhí)行的流程主要有順序、分支和循環(huán)幾種執(zhí)行流程，本節(jié)主要討論如何將Go語言的控制流比較直觀地轉(zhuǎn)譯為匯編程序，或者說如何以匯編思維來編寫Go語言代碼，感興趣的同學(xué)可以參考下文2023-05-05
這篇文章主要介紹了Golang中的time.Duration類型用法說明，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-12-12
golang int 轉(zhuǎn)float 強轉(zhuǎn)和高精度轉(zhuǎn)操作
這篇文章主要介紹了golang int 轉(zhuǎn)float 強轉(zhuǎn)和高精度轉(zhuǎn)操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-12-12