HeshanSudarshana

@ResponseStatus(code = HttpStatus.TOO_MANY_REQUESTS, reason = "Too many requests")
public class ThrottlingException extends RuntimeException {}

HeshanSudarshana

//this is the defaul implementation
@Throttling
public void serviceMethod() {}

//annotation above is equivalent to this snippet
@Throttling(type = ThrottlingType.RemoteAddr, limit = 1, timeUnit = TimeUnit.SECONDS)
public void serviceMethod() {}

HeshanSudarshana

<repositories>
    <repository>
        <id>spring-boot-throttling-repo</id>
        <url>https://raw.github.com/weddini/spring-boot-throttling/mvn-repo/</url>
        <snapshots>
            <enabled>true</enabled>
            <updatePolicy>always</updatePolicy>
        </snapshots>
    </repository>
</repositories>

HeshanSudarshana

// if you are allowing 5 requests per second
final RateLimiter rateLimiter = RateLimiter.create(5.0);
void throttler() {
  rateLimiter.acquire(); // may wait
  doSomething();
}

// if you are allowing 5000 bytes per second
final RateLimiter rateLimiter = RateLimiter.create(5000.0);
void submitPacket(byte[] packet) {

HeshanSudarshana

RateLimiter rateLimiter = RateLimiter.create(10.0); // rate is "10 permits per second"

HeshanSudarshana

<!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
<dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>19.0</version>
</dependency>