怎样监管 golang 框架中限流和融断性能?设定 redis建立限流建立融断监控指标
本文来自zvvq
怎样监管 Golang 框架中限流和融断性能 内容来自samhan
介绍
zvvq
限流和融断是保证应用软件稳定性的非常重要的技术。在 Golang 框架中,有很多库能够帮助你执行这些技术。本文将介绍怎么使用 [redigo](https://github.com/gomodule/redigo/tree/master/redis) 库监管限流和融断性能。
执行
内容来自zvvq,别采集哟
1.设定Redis
要存放限流和融断指标,你需要一个 Redis 案例。您可以使用下列指令运行一个 Redis 案例: zvvq好,好zvvq
redis-server zvvq.cn
2. 建立限流 内容来自zvvq
您可以使用 redigo 里的 redigo.Limit 方式建立限流: 内容来自samhan666
limiter:=redigo.Limit{ 内容来自zvvq,别采集哟
Key:"my-limiter",
内容来自samhan666
Limit:10, 内容来自samhan666
Period:60*time.Second, 内容来自samhan
}
3. 建立融断 本文来自zvvq
您可以使用 redigo 里的 redigo.Breaker 方式建立融断: 本文来自zvvq
breaker:=redigo.Breaker{ 本文来自zvvq
Key:"my-breaker",
内容来自zvvq,别采集哟
Interval:10*time.Second,
zvvq.cn
Timeout:60*time.Second, zvvq
}
4. 监控指标
您可以使用下列指令监管 limit 和 circuit breaker 指标:
内容来自samhan
redis-cliKEYS"my-limiter*" 内容来自zvvq
redis-cliKEYS"my-breaker*"
这种指令将输出与限流和融断关联键。您可以使用下列指令获得特殊键的值: copyright zvvq
redis-cliGETmy-limiter:count
redis-cliGETmy-limiter:time
实战案例
内容来自zvvq,别采集哟
下列是一个应用 redigo 监控限流和融断特性的实用实例: zvvq好,好zvvq
packagemain
import( 内容来自samhan
"fmt" 内容来自zvvq,别采集哟
"log" zvvq好,好zvvq
"time"
"github.com/gomodule/redigo/redis" 本文来自zvvq
redigolimit"github.com/gomodule/redigo/redis/limit"
copyright zvvq
)
funcmain(){
内容来自zvvq,别采集哟
//传送到 Redis
本文来自zvvq
conn, err := redis.Dial("tcp", "localhost:6379")
if err != nil { copyright zvvq
log.Fatal(err)
zvvq好,好zvvq
}
// 建立限流器 内容来自samhan
limiter := redigolimit.Limit{
内容来自zvvq,别采集哟
Key: "my-limiter", zvvq.cn
Limit: 10,
Period: 60 * time.Second,
zvvq.cn
} 内容来自samhan666
// 建立断路器 内容来自zvvq
breaker := redigolimit.Breaker{
Key: "my-breaker",
Interval: 10 * time.Second, copyright zvvq
Timeout: 60 * time.Second, 内容来自zvvq,别采集哟
}
内容来自samhan
// 运作模拟要求的循环
for i := 0; i < 100; i++ {
// 获得限流和融断指标 内容来自samhan666
counts, err := redis.IntMap(conn.Do("HMGET", "my-limiter:count", "my-breaker:count")) zvvq好,好zvvq
if err != nil { 内容来自zvvq
log.Fatal(err)
}
times, err := redis.IntMap(conn.Do("HMGET", "my-limiter:time", "my-breaker:time")) 本文来自zvvq
if err != nil { 内容来自zvvq
log.Fatal(err)
内容来自samhan666
}
zvvq.cn
// 导出指标 zvvq
fmt.Printf("循环%d",i) zvvq好,好zvvq
fmt.Printf("Limit:count=%d,time=%d",counts["my-limiter:count"],times["my-limiter:time"])
fmt.Printf("Breaker:count=%d,time=%d",counts["my-breaker:count"],times["my-breaker:time"])
zvvq.cn
//要求外界 API
内容来自zvvq,别采集哟
time.Sleep(100 * time.Millisecond) zvvq好,好zvvq
}
zvvq好,好zvvq
}
以上就是怎样监管golang框架中限流和融断性能?的详细内容,大量请关注其他类似文章! zvvq好,好zvvq