go微服務系列(一) go micro入門

• 1. 什麼是go micro
  • 1.1 go micro做用
  • 1.2 go micro架構組成
• 2. go micro入門
• 3. 結合consul進行服務註冊/發現
  • 3.1 consul的安裝
  • 3.2 服務註冊代碼示例
  • 3.2 服務發現代碼示例

1. 什麼是go micro

1.1 go micro做用

它是一個可插入的RPC框架，用於在Go中編寫微服務。開箱即用，您將收到：

• 服務發現: 應用程序自動註冊到服務發現系統
• 負載平衡: 客戶端負載平衡，用於平衡服務實例之間的請求
• 同步通訊: 提供請求 / 響應傳輸層。
• 異步通訊: 內置發佈 / 訂閱功能。
• 消息編碼: 基於消息的內容類型頭的編碼 / 解碼。
• RPC 客戶機/服務器包: 利用上述功能並公開接口來構建微服務

1.2 go micro架構組成

Go 微體系結構能夠描述爲三層堆棧

頂層由客戶端-服務器模型和服務抽象組成。

• 服務器: 用於編寫服務的構建塊
• 客戶端: 提供了向服務請求的接口。

底層由如下類型的插件組成：

• 代理: 爲異步發佈/訂閱通訊提供消息代理的接口。
• 編解碼器: 用於編碼/解碼消息。支持的格式包括 json，bson，protobuf，msgpack 等。
• 註冊表: 提供服務發現機制(默認爲 Consul)
• 選擇器: 創建在註冊表上的負載平衡抽象。它容許使用諸如隨機，輪循，最小康等算法來 「選擇」 服務。
  傳輸 - 服務之間同步請求 / 響應通訊的接口。
• Go Micro還提供了Sidecar等功能。這使您能夠使用Go之外的語言編寫的服務

Sidecar提供服務註冊，gRPC編碼/解碼和HTTP處理程序。它支持多種語言。

2. go micro入門

最簡單的用法大概以下，結合net/http標準庫監聽路由

package main

import (
	"github.com/micro/go-micro/web"
	"net/http"
)

func main() {

	server := web.NewService(web.Address(":8081")) // 路由
	server.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		w.Write([]byte("hello go micro"))
	})
	_ = server.Run()
}

也能夠集成第三方web框架做爲路由

• 好比gin

package main

import (
	"net/http"

	"github.com/gin-gonic/gin"
	"github.com/micro/go-micro/web"
)

func main() {
    // 使用gin做爲路由
	r := gin.Default()
	r.GET("/user", func(c *gin.Context) {
		c.String(http.StatusOK, "user api")
	})

	server := web.NewService(
		web.Address(":8081"),                                // 端口
		web.Metadata(map[string]string{"protocol": "http"}), // 元信息
		web.Handler(r)) // 路由
		
	_ = server.Run()
}

3. 結合consul進行服務註冊/發現

微服務裏最重要的關鍵一步就是服務註冊

經常使用的有consul、etcd、zookeeper、eureka

咱們這裏使用consul

3.1 consul的安裝

這裏直接使用docker安裝

docker run -d --name=cs -p 8500:8500 consul agent -server -bootstrap -ui -client 0.0.0.0

而後再訪問端口8500，以下現實安裝成功

3.2 服務註冊代碼示例

github.com/micro/go-micro/registry/consul
上面這個在1.14.0版本以後刪除了，要用這個github.com/micro/go-plugins/registry/consul，或者換成etcd做爲註冊中心

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() {
    // 添加consul地址
	cr := consul.NewRegistry(
		registry.Addrs("127.0.0.1:8500"))
    
    // 使用gin做爲router
	router := gin.Default()
	router.GET("/user", func(c *gin.Context) {
		c.String(http.StatusOK, "user api")
	})
    
    // 初始化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()
}

把上述代碼運行起來，再去consul界面查看，發現productService服務添加成功

而後把代碼停掉，再去consul界面查看，productService就沒了，很是方便

3.2 服務發現代碼示例

package main

import (
	"fmt"
	"log"

	"github.com/micro/go-micro/client/selector"
	"github.com/micro/go-micro/registry"
	"github.com/micro/go-plugins/registry/consul"
)

func main() {
	// 1.鏈接到consul
	cr := consul.NewRegistry(registry.Addrs("127.0.0.1:8500"))

	// 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.Id, svc.Address, svc.Metadata)
}

而後使用goland先啓動服務註冊中的productService的微服務，再啓動服務發現中的代碼。

服務發現將會輸出以下，服務發現成功：