欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

go-kit組件使用hystrix中間件的操作

 更新時(shí)間:2021年04月27日 08:53:32   作者:鹿灝楷silves  
這篇文章主要介紹了go-kit組件使用hystrix中間件的操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

使用go-kit中間件時(shí),一般在endpoint中進(jìn)行中間件的開(kāi)發(fā)。

在endpoint層插入hystrix中間件的插入。

endpoint.go

func MakeEndpoint (svc services.StringService) endpoint.Endpoint {
 return func(ctx context.Context, request interface{}) (response interface{}, err error) {
  req := request.(*StringService.Request)
  rep , err  := svc.Diff(ctx , req)
  return rep , err
 }
}

go-kit使我們更注重對(duì)服務(wù)邏輯的開(kāi)發(fā),對(duì)中間過(guò)程的省略會(huì)減少很多的錯(cuò)誤發(fā)生。

main.go

package main

import (
 "balencegrpc/services"
 "balencegrpc/router"
 "balencegrpc/proto"
 "balencegrpc/discover"
 "balencegrpc/endpoints"
 "github.com/go-kit/kit/circuitbreaker"
 "google.golang.org/grpc"
 "google.golang.org/grpc/health/grpc_health_v1"
 "log"
 "net"
)

func main() {
 //svc := new()
  svc := services.ServiceI{}
 endpoint := circuitbreaker.Hystrix("testname")(endpoints.MakeEndpoint(svc))
 lis , err := net.Listen("tcp" , ":8081")
 if err != nil {
  log.Println(err)
  return
 }
 router := router.NewRouter(svc , endpoint)
 grpcserver := grpc.NewServer()
 c := discover.Service{}
 grpc_health_v1.RegisterHealthServer(grpcserver , &c)
 StringService.RegisterStringServiceServer(grpcserver , router)
 rs := discover.NewService()
 rs.Register("127.0.0.1" , 8081)
 grpcserver.Serve(lis)
}

我們?cè)趍ain.go中進(jìn)行添加hystrix對(duì)endpoint進(jìn)行封裝,,使用hystrix進(jìn)行服務(wù)熔斷的處理。其實(shí)使用go-kit封裝的。也可以自行封裝一個(gè)中間件,在創(chuàng)建endpoint時(shí)進(jìn)行封裝

補(bǔ)充:go-kit微服務(wù)熔斷機(jī)制的實(shí)現(xiàn)

在微服務(wù)架構(gòu)中,每一個(gè)微服務(wù)都是一個(gè)獨(dú)立的業(yè)務(wù)功能單元,而一個(gè)應(yīng)用一般由多個(gè)微服務(wù)組成,微服務(wù)之間的交互是通過(guò)RPC(遠(yuǎn)程過(guò)程調(diào)用)完成。

比如,我們的應(yīng)用是微服務(wù)A調(diào)用微服務(wù)B和微服務(wù)C來(lái)完成的,而微服務(wù)B又需要調(diào)用微服務(wù)D,微服務(wù)D又需要調(diào)用微服務(wù)E。如果在調(diào)用的鏈路上對(duì)微服務(wù)E的調(diào)用,響應(yīng)時(shí)間過(guò)長(zhǎng)或者服務(wù)不可用,那么對(duì)微服務(wù)D的調(diào)用就會(huì)占用越來(lái)越多的系統(tǒng)資源,進(jìn)而引起微服務(wù)D的系統(tǒng)崩潰,微服務(wù)D的不可用,又會(huì)連鎖反應(yīng)的引起微服務(wù)B崩潰,進(jìn)而微服務(wù)A崩潰,最終導(dǎo)致整個(gè)應(yīng)用不可用。這也就是所謂的“雪崩效應(yīng)”。

介紹

go-kit 提供了三種熔斷

1、 gobreaker

2、 handy

3、 hystrix-go

hystrix用的比較多,我們來(lái)介紹下go-kit中hystrix的使用方法

go-kit的hystrix

Middleware的實(shí)現(xiàn)

1、 Hystrix返回Middleware 此中間件會(huì)在原來(lái)的endPoint包一層Hystrix的endPoint

2、 hystrix通過(guò)傳入的commanName獲取對(duì)應(yīng)的Hystrix的設(shè)置,并設(shè)置run失敗時(shí)運(yùn)行的fallback函數(shù)為nil

3、 我們也可以自己實(shí)現(xiàn)middleware包裝endPoint

func Hystrix(commandName string) endpoint.Middleware {  
   return func(next endpoint.Endpoint) endpoint.Endpoint {  
      return func(ctx context.Context, request interface{}) (response interface{}, err error) {  
         var resp interface{}  
         if err := hystrix.Do(commandName, func() (err error) {  
            resp, err = next(ctx, request)  
            return err  
         }, nil); err != nil {  
            return nil, err  
         }  
         return resp, nil  
      }  
   }  
}

客戶端hystrix配置

1、Timeout 【請(qǐng)求超時(shí)的時(shí)間】

2、ErrorPercentThreshold【允許出現(xiàn)的錯(cuò)誤比例】

3、SleepWindow【熔斷開(kāi)啟多久嘗試發(fā)起一次請(qǐng)求】

4、MaxConcurrentRequests【允許的最大并發(fā)請(qǐng)求數(shù)】

5、RequestVolumeThreshold 【波動(dòng)期內(nèi)的最小請(qǐng)求數(shù),默認(rèn)波動(dòng)期10S】

commandName := "my-endpoint"  
hystrix.ConfigureCommand(commandName, hystrix.CommandConfig{  
  Timeout: 1000 * 30,  
  ErrorPercentThreshold: 1,  
  SleepWindow: 10000,  
  MaxConcurrentRequests: 1000,  
  RequestVolumeThreshold: 5,  
})

增加熔斷中間件的包裝

breakerMw := circuitbreaker.Hystrix(commandName)
//增加熔斷中間件  
reqEndPoint = breakerMw(reqEndPoint)

實(shí)例

1、protobuf文件及生成對(duì)應(yīng)的go文件

 
syntax = "proto3"; 
// 請(qǐng)求書(shū)詳情的參數(shù)結(jié)構(gòu)  book_id 32位整形
message BookInfoParams {
    int32 book_id = 1;
} 
 
// 書(shū)詳情信息的結(jié)構(gòu)   book_name字符串類型
message BookInfo {
    int32 book_id = 1;
    string  book_name = 2;
}
 
// 請(qǐng)求書(shū)列表的參數(shù)結(jié)構(gòu)  page、limit   32位整形
message BookListParams {
    int32 page = 1;
    int32 limit = 2;
} 
 
// 書(shū)列表的結(jié)構(gòu)    BookInfo結(jié)構(gòu)數(shù)組
message BookList {
    repeated BookInfo book_list = 1;
}
// 定義 獲取書(shū)詳情  和 書(shū)列表服務(wù)   入?yún)⒊鰠⒎謩e為上面所定義的結(jié)構(gòu)
service BookService {
    rpc GetBookInfo (BookInfoParams) returns (BookInfo) {}
    rpc GetBookList (BookListParams) returns (BookList) {}
}

生成對(duì)應(yīng)的go語(yǔ)言代碼文件:protoc --go_out=plugins=grpc:. book.proto (其中:protobuf文件名為:book.proto)

注:由于演示熔斷機(jī)制,也就是Server出現(xiàn)問(wèn)題的時(shí)候進(jìn)行熔斷,因此本文Server端代碼可以不用。

2、Client端代碼

package main 
import (
	"MyKit"
	"context"
	"fmt"
	"github.com/afex/hystrix-go/hystrix"
	"github.com/go-kit/kit/circuitbreaker"
	"github.com/go-kit/kit/endpoint"
	"github.com/go-kit/kit/log"
	"github.com/go-kit/kit/sd"
	"github.com/go-kit/kit/sd/etcdv3"
	"github.com/go-kit/kit/sd/lb"
	"google.golang.org/grpc"
	"io"
	"time"
)
 
func main() { 
	var (
		//注冊(cè)中心地址
		etcdServer = "127.0.0.1:2379"
		//監(jiān)聽(tīng)的服務(wù)前綴
		prefix = "/services/book/"
		ctx    = context.Background()
	)
	//對(duì)hystrix進(jìn)行配置
	commandName:="my_endpoint"
	hystrix.ConfigureCommand(commandName,hystrix.CommandConfig{
		Timeout:1000*3, //超時(shí)
		MaxConcurrentRequests:100, //最大并發(fā)的請(qǐng)求數(shù)
		RequestVolumeThreshold:5,//請(qǐng)求量閾值
		SleepWindow:10000, //熔斷開(kāi)啟多久嘗試發(fā)起一次請(qǐng)求
		ErrorPercentThreshold:1, //誤差閾值百分比
	})
	breakerMw:=circuitbreaker.Hystrix(commandName) //定義熔斷器中間件
	options := etcdv3.ClientOptions{
		DialTimeout:   time.Second * 3,
		DialKeepAlive: time.Second * 3,
	}
	//連接注冊(cè)中心
	client, err := etcdv3.NewClient(ctx, []string{etcdServer}, options)
	if err != nil {
		panic(err)
	}
	logger := log.NewNopLogger()
	//創(chuàng)建實(shí)例管理器, 此管理器會(huì)Watch監(jiān)聽(tīng)etc中prefix的目錄變化更新緩存的服務(wù)實(shí)例數(shù)據(jù)
	instancer, err := etcdv3.NewInstancer(client, prefix, logger)
	if err != nil {
		panic(err)
	}
	//創(chuàng)建端點(diǎn)管理器, 此管理器根據(jù)Factory和監(jiān)聽(tīng)的到實(shí)例創(chuàng)建endPoint并訂閱instancer的變化動(dòng)態(tài)更新Factory創(chuàng)建的endPoint
	endpointer := sd.NewEndpointer(instancer, reqFactory, logger) //reqFactory自定義的函數(shù),主要用于端點(diǎn)層(endpoint)接受并顯示數(shù)據(jù)
	//創(chuàng)建負(fù)載均衡器
	balancer := lb.NewRoundRobin(endpointer)
 
	/**
	我們可以通過(guò)負(fù)載均衡器直接獲取請(qǐng)求的endPoint,發(fā)起請(qǐng)求
	reqEndPoint,_ := balancer.Endpoint()
	*/
 
	/**
	也可以通過(guò)retry定義嘗試次數(shù)進(jìn)行請(qǐng)求
	*/
	reqEndPoint := lb.Retry(3, 100*time.Second, balancer) //請(qǐng)求次數(shù)為3,時(shí)間為10S(時(shí)間需要多于服務(wù)器限流時(shí)間3s)
 
	//增加熔斷中間件
	reqEndPoint=breakerMw(reqEndPoint)
 
	//現(xiàn)在我們可以通過(guò) endPoint 發(fā)起請(qǐng)求了
	req := struct{}{}
	for i:=0;i<20;i++ {  //發(fā)生20次請(qǐng)求
		ctx=context.Background()
		if _, err = reqEndPoint(ctx, req); err != nil {
			//panic(err)
			fmt.Println("當(dāng)前時(shí)間: ", time.Now().Format("2006-01-02 15:04:05.99"),"\t第",i+1,"次")
			fmt.Println(err)
			time.Sleep(1*time.Second)
		}
	}
}
 
//通過(guò)傳入的 實(shí)例地址  創(chuàng)建對(duì)應(yīng)的請(qǐng)求endPoint
func reqFactory(instanceAddr string) (endpoint.Endpoint, io.Closer, error) {
	return func(ctx context.Context, request interface{}) (interface{}, error) {
		conn, err := grpc.Dial(instanceAddr, grpc.WithInsecure())
		if err != nil {
			fmt.Println(err)
			panic("connect error")
		}
		defer conn.Close()
		bookClient := book.NewBookServiceClient(conn)
		bi, _ := bookClient.GetBookInfo(context.Background(), &book.BookInfoParams{BookId: 1})
		fmt.Println("獲取書(shū)籍詳情")
		fmt.Println("bookId: 1", " => ", "bookName:", bi.BookName)
		fmt.Println("請(qǐng)求服務(wù)成功: ", instanceAddr,"當(dāng)前時(shí)間為:",time.Now().Format("2006-01-02 15:04:05.99"))
		/*bl, _ := bookClient.GetBookList(context.Background(), &book.BookListParams{Page: 1, Limit: 10})
		fmt.Println("獲取書(shū)籍列表")
		for _, b := range bl.BookList {
			fmt.Println("bookId:", b.BookId, " => ", "bookName:", b.BookName)
		}*/
		return nil, nil
	}, nil, nil
}

3、運(yùn)行及分析

直接運(yùn)行Client端(不用啟動(dòng)etcd、Server),效果如下:

通過(guò)上面的輸出記錄可以驗(yàn)證我們的配置:

1、 前5條波動(dòng)期內(nèi)的錯(cuò)誤,沒(méi)有觸發(fā)circuit開(kāi)啟(RequestVolumeThreshold:5,//請(qǐng)求量閾值)

2、 circuit開(kāi)啟后請(qǐng)求熔斷生效(輸出內(nèi)容:hystrix: circuit open)

3、 circuit開(kāi)啟10S后,SleepWindow測(cè)試發(fā)起請(qǐng)求設(shè)置生效(第16次輸出的內(nèi)容;設(shè)置:SleepWindow:10000, //熔斷開(kāi)啟多久嘗試發(fā)起一次請(qǐng)求)

以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教。

相關(guān)文章

  • 更高效的GoLevelDB:shardingdb實(shí)現(xiàn)分片和并發(fā)讀寫(xiě)操作

    更高效的GoLevelDB:shardingdb實(shí)現(xiàn)分片和并發(fā)讀寫(xiě)操作

    這篇文章主要介紹了更高效的GoLevelDB:shardingdb實(shí)現(xiàn)分片和并發(fā)讀寫(xiě)操作的相關(guān)資料,需要的朋友可以參考下
    2023-09-09
  • Go語(yǔ)言實(shí)現(xiàn)的樹(shù)形結(jié)構(gòu)數(shù)據(jù)比較算法實(shí)例

    Go語(yǔ)言實(shí)現(xiàn)的樹(shù)形結(jié)構(gòu)數(shù)據(jù)比較算法實(shí)例

    這篇文章主要介紹了Go語(yǔ)言實(shí)現(xiàn)的樹(shù)形結(jié)構(gòu)數(shù)據(jù)比較算法,實(shí)例分析了樹(shù)形結(jié)構(gòu)數(shù)據(jù)比較算法的實(shí)現(xiàn)技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下
    2015-02-02
  • Windows下使用go語(yǔ)言寫(xiě)程序安裝配置實(shí)例

    Windows下使用go語(yǔ)言寫(xiě)程序安裝配置實(shí)例

    這篇文章主要介紹了Windows下使用go語(yǔ)言寫(xiě)程序安裝配置實(shí)例,本文講解了安裝go語(yǔ)言、寫(xiě)go代碼、生成可執(zhí)行文件、批量生成可執(zhí)行文件等內(nèi)容,需要的朋友可以參考下
    2015-03-03
  • Go排序算法通用qsort函數(shù)使用示例

    Go排序算法通用qsort函數(shù)使用示例

    這篇文章主要為大家介紹了Go排序算法通用qsort函數(shù)使用示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-11-11
  • golang實(shí)現(xiàn)webgis后端開(kāi)發(fā)的步驟詳解

    golang實(shí)現(xiàn)webgis后端開(kāi)發(fā)的步驟詳解

    這篇文章主要介紹如何用golang結(jié)合postgis數(shù)據(jù)庫(kù),使用gin、grom框架實(shí)現(xiàn)后端的MVC的接口搭建,文中有詳細(xì)的流程步驟及代碼示例,需要的朋友可以參考下
    2023-06-06
  • 解決golang http.FileServer 遇到的坑

    解決golang http.FileServer 遇到的坑

    這篇文章主要介紹了解決golang http.FileServer 遇到的坑,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
    2020-12-12
  • GO實(shí)現(xiàn)協(xié)程池管理的方法

    GO實(shí)現(xiàn)協(xié)程池管理的方法

    這篇文章給大家介紹GO實(shí)現(xiàn)協(xié)程池管理的方法,分別使用channel實(shí)現(xiàn)協(xié)程池和消費(fèi)者模式實(shí)現(xiàn)協(xié)程池,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),需要的朋友參考下吧
    2021-07-07
  • 使用Golang搭建web服務(wù)的實(shí)現(xiàn)步驟

    使用Golang搭建web服務(wù)的實(shí)現(xiàn)步驟

    本文主要介紹了使用Golang搭建web服務(wù)的實(shí)現(xiàn)步驟,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2022-04-04
  • Go經(jīng)典面試題匯總(填空+判斷)

    Go經(jīng)典面試題匯總(填空+判斷)

    這篇文章主要介紹了Go經(jīng)典面試題匯總(填空+判斷),本文章內(nèi)容詳細(xì),具有很好的參考價(jià)值,希望對(duì)大家有所幫助,需要的朋友可以參考下
    2023-01-01
  • Go指針的具體使用

    Go指針的具體使用

    本文主要介紹了Go指針的具體使用,包括使用指針、空指針、指針數(shù)組、指向指針的指針等,具有一定的參考價(jià)值,感興趣的可以了解一下
    2023-11-11

最新評(píng)論