services.moleculer.web.middleware

Class RateLimiter

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.service.Service

services.moleculer.web.middleware.HttpMiddleware

services.moleculer.web.middleware.RateLimiter

All Implemented Interfaces:

services.moleculer.service.MoleculerLifecycle, HttpConstants

public class RateLimiter
extends HttpMiddleware
implements HttpConstants

Rate Limiter limits concurrent constant requests to the HTTP calls in the application. Sample:

 route.use(new RateLimiter(100, true));
 

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	applyForAll Apply the performance cutoff for each service (= true), otherwise (= false) it will only limit the load with the Actions marked with the 'RateLimit' annotation.
protected boolean	headers Add headers to all HTTP response (eg.
protected long	limit Default rate limit
protected RatingStoreFactory	storeFactory Hits per IP-addresses store
protected java.util.concurrent.TimeUnit	unit Unit of the time window/frame
protected long	window Time "window" (time frame) length
static java.lang.String	X_HEADER_LIMIT
static java.lang.String	X_HEADER_REMAINING
static java.lang.String	X_HEADER_RESET

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Fields inherited from interface services.moleculer.web.common.HttpConstants

ACCEPT, ACCEPT_ENCODING, AUTHORIZATION, CACHE_CONTROL, CHUNKED, CLOSE, CONNECT, CONNECTION, CONTENT_ENCODING, CONTENT_LENGTH, CONTENT_TYPE, CONTENT_TYPE_HTML, CONTENT_TYPE_JSON, COOKIE, DEFLATE, DELETE, ETAG, GET, GZIP, HEAD, IF_NONE_MATCH, KEEP_ALIVE, LOCATION, META_CONTENT_TYPE, META_HEADERS, META_LOCALE, META_LOCATION, META_SESSION, META_STATUS, META_TEMPLATE, NO_CACHE, OPTIONS, PATCH, POST, PROPERTY_COOKIES, PROPERTY_SESSION_ID, PROPERTY_USER, PUT, SET_COOKIE, TRACE, TRANSFER_ENCODING, WWW_AUTHENTICATE, X_FORWARDED_FOR

Constructor Summary

Constructors

Constructor and Description
RateLimiter() Creates a RateLimiter with default settings (50 requests / second for all URLs).
RateLimiter(boolean applyForAll) Creates a RateLimiter.
RateLimiter(int rateLimit, boolean applyForAll)
RateLimiter(int rateLimit, int window, java.util.concurrent.TimeUnit unit, boolean applyForAll)

Method Summary

Modifier and Type	Method and Description
long	getRateLimit()
RatingStoreFactory	getStoreFactory()
java.util.concurrent.TimeUnit	getUnit()
long	getWindow()
RequestProcessor	install(RequestProcessor next, io.datatree.Tree config)
boolean	isApplyForAll()
boolean	isHeaders()
void	setApplyForAll(boolean applyForAll)
void	setHeaders(boolean headers)
void	setRateLimit(long rateLimit)
void	setStoreFactory(RatingStoreFactory storeFactory)
void	setUnit(java.util.concurrent.TimeUnit unit)
void	setWindow(long window)
void	started(services.moleculer.ServiceBroker broker)
void	stopped()

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

X_HEADER_LIMIT

public static final java.lang.String X_HEADER_LIMIT

See Also:

Constant Field Values

X_HEADER_REMAINING

public static final java.lang.String X_HEADER_REMAINING

See Also:

Constant Field Values

X_HEADER_RESET

public static final java.lang.String X_HEADER_RESET

See Also:

Constant Field Values

applyForAll

protected boolean applyForAll

Apply the performance cutoff for each service (= true), otherwise (= false) it will only limit the load with the Actions marked with the 'RateLimit' annotation.

limit

protected long limit

Default rate limit

window

protected long window

Time "window" (time frame) length

headers

protected boolean headers

Add headers to all HTTP response (eg. "X-Rate-Limit-Remaining", etc.)

unit

protected java.util.concurrent.TimeUnit unit

Unit of the time window/frame

storeFactory

protected RatingStoreFactory storeFactory

Hits per IP-addresses store

Constructor Detail

RateLimiter

public RateLimiter()

Creates a RateLimiter with default settings (50 requests / second for all URLs).

RateLimiter

public RateLimiter(boolean applyForAll)

Creates a RateLimiter. It is adjustable to consider the 'RateLimit' annotation.

Parameters:

applyForAll - apply the performance cutoff for each service (= true), otherwise (= false) it will only limit the load with the Actions marked with the 'RateLimit' annotation.

RateLimiter

public RateLimiter(int rateLimit,
                   boolean applyForAll)

RateLimiter

public RateLimiter(int rateLimit,
                   int window,
                   java.util.concurrent.TimeUnit unit,
                   boolean applyForAll)

Method Detail

started

public void started(services.moleculer.ServiceBroker broker)
             throws java.lang.Exception

Specified by:

started in interface services.moleculer.service.MoleculerLifecycle

Overrides:

started in class services.moleculer.service.MoleculerComponent

Throws:

java.lang.Exception

install

public RequestProcessor install(RequestProcessor next,
                                io.datatree.Tree config)

Specified by:

install in class HttpMiddleware

stopped

public void stopped()

Specified by:

stopped in interface services.moleculer.service.MoleculerLifecycle

Overrides:

stopped in class services.moleculer.service.MoleculerComponent

isApplyForAll

public boolean isApplyForAll()

setApplyForAll

public void setApplyForAll(boolean applyForAll)

getRateLimit

public long getRateLimit()

setRateLimit

public void setRateLimit(long rateLimit)

getWindow

public long getWindow()

setWindow

public void setWindow(long window)

getUnit

public java.util.concurrent.TimeUnit getUnit()

setUnit

public void setUnit(java.util.concurrent.TimeUnit unit)

getStoreFactory

public RatingStoreFactory getStoreFactory()

setStoreFactory

public void setStoreFactory(RatingStoreFactory storeFactory)

isHeaders

public boolean isHeaders()

setHeaders

public void setHeaders(boolean headers)