Go by Example: Rate Limiting

So’rovlarni cheklash resurslardan foydalanishni nazorat qilish va xizmat sifatini saqlash uchun muhim mexanizmdir. Go goroutinalar, kanallar va tickerlar yordamida so’rovlarni cheklashni nafis tarzda qo’llab-quvvatlaydi.

 
package main
 
import (
    "fmt"
    "time"
)
 
func main() {

Avval so’rovlarni cheklashning asosiy holatini ko’rib chiqamiz. Faraz qilaylik, kelayotgan so’rovlarni qayta ishlashni cheklamoqchimiz. Bu so’rovlarni xuddi shu nomdagi kanal orqali xizmat ko’rsatamiz.

 
    requests := make(chan int, 5)
    for i := 1; i <= 5; i++ {
        requests <- i
    }
    close(requests)

Bu limiter kanali har 200 millisekundda bitta qiymat qabul qiladi. Bu bizning so’rovlarni cheklash sxemamizdagi regulyatordir.

 
    limiter := time.Tick(200 * time.Millisecond)

Har bir so’rovga xizmat ko’rsatishdan oldin limiter kanalidan qabul qilishni kutib bloklanish orqali, biz o’zimizni har 200 millisekundda 1 so’rov bilan cheklaymiz.

 
    for req := range requests {
        <-limiter
        fmt.Println("request", req, time.Now())
    }

Umumiy cheklovni saqlagan holda, so’rovlarni cheklash sxemamizda qisqa muddatli so’rovlar to’lqinlariga ruxsat berishni xohlashimiz mumkin. Buni limiter kanalimizni buferlash orqali amalga oshira olamiz. Bu burstyLimiter kanali 3 tagacha hodisaning to’lqiniga ruxsat beradi.

 
    burstyLimiter := make(chan time.Time, 3)

Ruxsat etilgan to’lqinni ifodalash uchun kanalni to’ldiramiz.

 
    for range 3 {
        burstyLimiter <- time.Now()
    }

Har 200 millisekundda burstyLimiterga, uning 3 lik chegarasigacha, yangi qiymat qo’shishga harakat qilamiz.

 
    go func() {
        for t := range time.Tick(200 * time.Millisecond) {
            burstyLimiter <- t
        }
    }()

Endi yana 5 ta kelayotgan so’rovni simulyatsiya qilamiz. Ulardan dastlabki 3 tasi burstyLimiterning to’lqin imkoniyatidan foyda ko’radi.

 
    burstyRequests := make(chan int, 5)
    for i := 1; i <= 5; i++ {
        burstyRequests <- i
    }
    close(burstyRequests)
    for req := range burstyRequests {
        <-burstyLimiter
        fmt.Println("request", req, time.Now())
    }
}

Dasturimizni ishga tushirsak, so’rovlarning birinchi to’plami xohlaganimizdek har ~200 millisekundda bir marta qayta ishlanayotganini ko’ramiz.

 
$ go run rate-limiting.go
request 1 2012-10-19 00:38:18.687438 +0000 UTC
request 2 2012-10-19 00:38:18.887471 +0000 UTC
request 3 2012-10-19 00:38:19.087238 +0000 UTC
request 4 2012-10-19 00:38:19.287338 +0000 UTC
request 5 2012-10-19 00:38:19.487331 +0000 UTC

So’rovlarning ikkinchi to’plami uchun to’lqinli cheklash tufayli dastlabki 3 tasini darhol xizmat ko’rsatamiz, so’ngra qolgan 2 tasini har biri ~200ms kechikish bilan xizmat ko’rsatamiz.

 
request 1 2012-10-19 00:38:20.487578 +0000 UTC
request 2 2012-10-19 00:38:20.487645 +0000 UTC
request 3 2012-10-19 00:38:20.487676 +0000 UTC
request 4 2012-10-19 00:38:20.687483 +0000 UTC
request 5 2012-10-19 00:38:20.887542 +0000 UTC

Keyingi misol: .

mualliflar: Mark McGranaghan va Eli Bendersky | tarjima: @elchintoyirov | manba | litsenziya