Bucket4j Java: Rate Limiting की पूरी गाइड

आधुनिक सॉफ्टवेयर डेवलपमेंट में, खासकर हाई-लोड वेब सर्विसेज और API बनाते समय, आने वाले रिक्वेस्ट की दर को नियंत्रित करना बेहद ज़रूरी है। अगर ऐसा न किया जाए, तो एक बेईमान यूज़र या सिस्टम में कोई बग बाकी सभी क्लाइंट्स के लिए सेवा बंद (DoS) कर सकता है। यहीं पर Rate Limiting की अवधारणा काम आती है, और Bucket4j लाइब्रेरी Java प्लेटफॉर्म पर इसे लागू करने के लिए सबसे शक्तिशाली और लचीले टूल्स में से एक है।

Bucket4j, Token Bucket एल्गोरिदम पर आधारित एक थ्रेड-सेफ Java लाइब्रेरी है। यह डेवलपर्स को आसानी से और कुशलता से ऑपरेशंस की फ्रीक्वेंसी सीमित करने देती है: जैसे API पर HTTP रिक्वेस्ट की संख्या, डेटाबेस कॉल्स, मैसेज भेजना आदि। साधारण काउंटरों के विपरीत, Token Bucket एल्गोरिदम लोड को स्मूथ करता है, ट्रैफिक में थोड़े समय के उछाल की अनुमति देता है, लेकिन लंबी अवधि में औसत गति का सख्ती से पालन करता है। यह इसे अधिकांश वास्तविक परिदृश्यों के लिए आदर्श बनाता है।

Bucket4j का उपयोग क्यों करें? पहला, यह आपके बैकएंड को ओवरलोड और हमलावरों से बचाता है। दूसरा, यह मल्टी-लेवल प्राइसिंग प्लान (प्रीमियम यूज़र्स को प्रति सेकंड अधिक रिक्वेस्ट) लागू करना संभव बनाता है। तीसरा, यह लाइब्रेरी बारीक ट्यूनिंग के लिए एक समृद्ध API प्रदान करती है, जिसमें टोकन रिफिल की विभिन्न रणनीतियाँ, Redis या Hazelcast के माध्यम से डिस्ट्रीब्यूटेड सिस्टम के साथ काम करना, और Spring Boot जैसे लोकप्रिय फ्रेमवर्क के साथ इंटीग्रेशन शामिल है। Bucket4j सिर्फ एक "स्टब" नहीं, बल्कि एक पूर्ण प्रोडक्शन-ग्रेड टूल है।

इंस्टॉलेशन

Bucket4j, Maven Central रिपॉजिटरी के माध्यम से वितरित किया जाता है। अपने प्रोजेक्ट में लाइब्रेरी जोड़ने के लिए, आपको pom.xml (Maven के लिए) या build.gradle (Gradle के लिए) फ़ाइल में डिपेंडेंसी जोड़नी होगी।

Maven (pom.xml):

<dependency>
    <groupId>com.github.vladimir-bukhtoyarov</groupId>
    <artifactId>bucket4j-core</artifactId>
    <version>8.7.0</version>
</dependency>

Gradle (build.gradle):

implementation 'com.github.vladimir-bukhtoyarov:bucket4j-core:8.7.0'

महत्वपूर्ण: वर्जन 8.x के लिए Java 11 या उससे ऊपर की आवश्यकता है। अगर आप Java 8 का उपयोग कर रहे हैं, तो आपको वर्जन 7.x की ज़रूरत होगी। डिस्ट्रीब्यूटेड कैश (Redis, Hazelcast) के साथ काम करने के लिए, संबंधित मॉड्यूल जैसे bucket4j-redis जोड़ना होगा।

त्वरित शुरुआत: न्यूनतम कार्यशील उदाहरण

चलिए एक सरल लिमिटर बनाते हैं जो प्रति सेकंड अधिकतम 10 ऑपरेशंस की अनुमति देता है।

import io.github.bucket4j.Bandwidth;
import io.github.bucket4j.Bucket;
import io.github.bucket4j.Refill;

import java.time.Duration;

public class QuickStartExample {

    public static void main(String[] args) {
        // 1. कॉन्फ़िगरेशन: 10 टोकन, हर सेकंड 10 टोकन रिफिल
        Bandwidth limit = Bandwidth.classic(10, Refill.greedy(10, Duration.ofSeconds(1)));

        // 2. बकेट बनाना
        Bucket bucket = Bucket.builder()
                .addLimit(limit)
                .build();

        // 3. रिक्वेस्ट का सिमुलेशन
        for (int i = 1; i <= 15; i++) {
            boolean consumed = bucket.tryConsume(1);
            if (consumed) {
                System.out.println("रिक्वेस्ट " + i + ": सफल (टोकन मिल गया)");
            } else {
                System.out.println("रिक्वेस्ट " + i + ": अस्वीकृत (लिमिट पार हो गई)");
            }
        }
    }
}

यह कोड 10 टोकन का एक बकेट बनाता है। हर सेकंड इसमें 10 नए टोकन जोड़े जाते हैं (greedy refill — टोकन लगातार जोड़े जाते हैं, इंटरवल के अंत में एक साथ नहीं)। पहले 10 रिक्वेस्ट तुरंत सफल होंगी।