go-kit组件使用hystrix中间件

拼搏现实的明天。 2022-11-16 15:18 189阅读 0赞

使用go-kit中间件时，一般在endpoint中进行中间件的开发。  
在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使我们更注重对服务逻辑的开发，对中间过程的省略会减少很多的错误发生。  
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)
    }

我们在main.go中进行添加hystrix对endpoint进行封装，，使用hystrix进行服务熔断的处理。其实使用go-kit封装的。也可以自行封装一个中间件，在创建endpoint时进行封装

发表评论取消回复

表情：

评论列表（有 0 条评论，189人围观）

还没有评论，来说两句吧...

相关阅读

相关 springCloud组件之Hystrix

springCloud组件之Hystrix 背景 SpringBoot使用Hystrix Feign使用Hystrix 背景最近

男娘i/ 2024年04月01日 08:51/ 0 赞/ 107 阅读

相关 (四)SpringCloud组件：Hystrix

一、概念 1、雪崩效应服务链中的某一个服务不可用，导致一些列的服务不可用，最终导致服务逻辑崩溃。造成原因：服务提供者不可用、重试加大流量、服务调用者不可用。

淩亂°似流年/ 2024年03月27日 11:13/ 0 赞/ 114 阅读

相关消息中间件介绍&为什么要使用消息中间件&什么时候使用消息中间件

我们用java来举例子，打个比方我们客户端发送一个下单请求给订单系统（order）订单系统发送了一个请求给我们的库存系统告诉他需要更改库存了，我已经下单了，这里

￡神魔★判官ぃ/ 2023年03月02日 05:30/ 0 赞/ 38 阅读

相关 springcloud 组件之 Hystrix 实战使用（四）

今天和大家分享 Hystrix 组件的使用，其功能主要包含：服务雪崩、服务隔离策略、服务降级、数据监控、熔断等作用。下面我们以此介绍其使用方法。一、服务雪崩：服务雪崩是

╰+攻爆jí腚メ/ 2022年11月28日 13:58/ 0 赞/ 270 阅读

相关 go-kit组件使用hystrix中间件

使用go-kit中间件时，一般在endpoint中进行中间件的开发。在endpoint层插入hystrix中间件的插入。 endpoint.go func

拼搏现实的明天。/ 2022年11月16日 15:18/ 0 赞/ 190 阅读

相关 Hystrix组件

Spring Cloud Hystrix 1、Hystrix简介 2、Hystrix基本功能 2.1 隔离 2.2 限流

雨点打透心脏的1/2处/ 2022年09月08日 15:52/ 0 赞/ 235 阅读

相关中间件-消息中间件

jms是java ee 的消息规范，其实现是hornetq和activemq等，小型系统直接使用jms是可以的但是大型系统不太适用。消息中间件主要保证消息的顺序保证，扩展性

旧城等待，/ 2022年08月10日 05:59/ 0 赞/ 402 阅读

相关中间件

1. AOP面向切面编程 2. 可切入函数 3. 切入函数如果没有返回值，就是获取请求相关的信息，没有对原来的逻辑进行更改

红太狼/ 2022年06月02日 21:58/ 0 赞/ 369 阅读

相关 SpringCloud入坑记-Hystrix组件

![在这里插入图片描述][20190623224648710.png] 简介（是什么） ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5n

我就是我/ 2022年01月05日 13:11/ 0 赞/ 351 阅读

相关 Auth,Forms组件,中间件

1.前后台分离数据交换跨域:主机,端口,协议不同文件上传下载　　file=$('.file')\[0\].files\[i\] form\_data = new F

迈不过友情╰/ 2021年12月20日 08:17/ 0 赞/ 303 阅读