services.moleculer.service

Class DefaultServiceRegistry

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.service.ServiceRegistry

services.moleculer.service.DefaultServiceRegistry

All Implemented Interfaces:

MetricConstants, MoleculerLifecycle

public class DefaultServiceRegistry
extends ServiceRegistry
implements MetricConstants

Default implementation of the Service Registry.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	asyncLocalInvocation Invoke all local services via Thread pool (true) or directly (false)
protected FastBuildTree	cachedDescriptor
protected java.util.concurrent.atomic.AtomicReference<java.util.concurrent.ScheduledFuture<?>>	callTimeoutTimer Cancelable timer for handling timeouts of action calls
protected boolean	checkVersion Check protocol version
protected MetricCounter	counterOrphanResponseTotal
protected Eventbus	eventbus
protected java.util.concurrent.ExecutorService	executor
protected MetricGauge	gaugeRequestsActive
protected MetricGauge	gaugeStreamsReceiveActive
protected Metrics	metrics
protected java.util.LinkedHashSet<Middleware>	middlewares
protected java.util.HashSet<java.lang.String>	names
protected java.lang.String	nodeID
protected java.util.concurrent.atomic.AtomicLong	prevTimeoutAt Next scheduled time to check timeouts
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,PendingPromise>	promises
protected java.lang.String	protocolVersion ServiceBroker's protocol version
protected java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock	readLock
protected java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock	requestStreamReadLock
protected java.util.HashMap<java.lang.String,IncomingStream>	requestStreams
protected java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock	requestStreamWriteLock
protected java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock	responseStreamReadLock
protected java.util.HashMap<java.lang.String,IncomingStream>	responseStreams
protected java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock	responseStreamWriteLock
protected java.util.concurrent.ScheduledExecutorService	scheduler
protected ServiceInvoker	serviceInvoker
protected java.util.LinkedList<ServiceListener>	serviceListeners Promises of the "waitingForServices" calls
protected java.util.LinkedHashMap<java.lang.String,Service>	services
protected java.util.concurrent.ScheduledFuture<?>	servicesOnlineTimer Cancelable timer for handling "wait for service" calls
protected java.util.HashMap<java.lang.String,Strategy<ActionEndpoint>>	strategies
protected StrategyFactory	strategyFactory
protected long	streamTimeout Stream inactivity/read timeout in MILLISECONDS (0 = no timeout).
protected java.util.concurrent.atomic.AtomicLong	timestamp Timestamp of the service descriptor of this Moleculer Node (~= "generated at" timestamp)
protected Transporter	transporter
protected UidGenerator	uidGenerator
protected boolean	writeErrorsToLog Write exceptions into the log file
protected java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock	writeLock
protected boolean	writeRegistrations Write Service and Action registrations into the log file

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Fields inherited from interface services.moleculer.metrics.MetricConstants

MOLECULER_CACHER_CLEAN_TIME, MOLECULER_CACHER_CLEAN_TIME_DESC, MOLECULER_CACHER_CLEAN_TOTAL, MOLECULER_CACHER_CLEAN_TOTAL_DESC, MOLECULER_CACHER_DEL_TIME, MOLECULER_CACHER_DEL_TIME_DESC, MOLECULER_CACHER_DEL_TOTAL, MOLECULER_CACHER_DEL_TOTAL_DESC, MOLECULER_CACHER_EXPIRED_TOTAL, MOLECULER_CACHER_EXPIRED_TOTAL_DESC, MOLECULER_CACHER_FOUND_TOTAL, MOLECULER_CACHER_FOUND_TOTAL_DESC, MOLECULER_CACHER_GET_TIME, MOLECULER_CACHER_GET_TIME_DESC, MOLECULER_CACHER_GET_TOTAL, MOLECULER_CACHER_GET_TOTAL_DESC, MOLECULER_CACHER_SET_TIME, MOLECULER_CACHER_SET_TIME_DESC, MOLECULER_CACHER_SET_TOTAL, MOLECULER_CACHER_SET_TOTAL_DESC, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL_DESC, MOLECULER_EVENT_BROADCAST_TOTAL, MOLECULER_EVENT_BROADCAST_TOTAL_DESC, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL_DESC, MOLECULER_EVENT_EMIT_TOTAL, MOLECULER_EVENT_EMIT_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_ACTIVE, MOLECULER_EVENT_RECEIVED_ACTIVE_DESC, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_TIME, MOLECULER_EVENT_RECEIVED_TIME_DESC, MOLECULER_EVENT_RECEIVED_TOTAL, MOLECULER_EVENT_RECEIVED_TOTAL_DESC, MOLECULER_EXECUTOR, MOLECULER_REQUEST_ACTIVE, MOLECULER_REQUEST_ACTIVE_DESC, MOLECULER_REQUEST_ERROR_TOTAL, MOLECULER_REQUEST_ERROR_TOTAL_DESC, MOLECULER_REQUEST_LEVELS, MOLECULER_REQUEST_LEVELS_DESC, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL_DESC, MOLECULER_REQUEST_TIME, MOLECULER_REQUEST_TIME_DESC, MOLECULER_REQUEST_TIMEOUT_TOTAL, MOLECULER_REQUEST_TIMEOUT_TOTAL_DESC, MOLECULER_REQUEST_TOTAL, MOLECULER_REQUEST_TOTAL_DESC, MOLECULER_SCHEDULER, MOLECULER_TRANSIT_CONNECTED, MOLECULER_TRANSIT_CONNECTED_DESC, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL_DESC, MOLECULER_TRANSIT_REQUESTS_ACTIVE, MOLECULER_TRANSIT_REQUESTS_ACTIVE_DESC, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL_DESC

Constructor Summary

Constructors

Constructor and Description
DefaultServiceRegistry()
DefaultServiceRegistry(boolean asyncLocalInvocation)

Method Summary

Modifier and Type	Method and Description
io.datatree.Promise	addActions(java.lang.String serviceName, Service service)
void	addActions(java.lang.String nodeID, io.datatree.Tree config)
protected void	addOnlineActions(java.lang.String serviceName, Service service)
protected void	broadcastServicesChanged(boolean local)
protected void	checkServicesOnline()
protected void	checkTimeouts()
protected void	clearDescriptorCache()
protected int	countOnlineServices(java.util.Collection<java.lang.String> requiredServices)
protected io.datatree.Tree	currentDescriptor()
protected void	deregister(java.lang.String id)
Action	getAction(java.lang.String name, java.lang.String nodeID)
io.datatree.Tree	getDescriptor()
Service	getService(java.lang.String name)
long	getStreamTimeout()
long	getTimestamp()
boolean	isAsyncLocalInvocation()
boolean	isCheckVersion()
protected boolean	isServicesOnline(java.util.Collection<java.lang.String> requiredServices)
boolean	isWriteErrorsToLog()
boolean	isWriteRegistrations()
protected void	logUnableToInvokeAction(java.lang.String action, java.lang.Throwable cause)
io.datatree.Promise	ping(long timeoutMillis, java.lang.String nodeID)
void	receivePong(io.datatree.Tree message)
void	receiveRequest(io.datatree.Tree message)
void	receiveResponse(io.datatree.Tree message)
protected void	register(java.lang.String id, io.datatree.Promise promise, long timeoutAt, java.lang.String nodeID, java.lang.String action, io.datatree.Tree req)
void	removeActions(java.lang.String nodeID)
protected void	reschedule(long minTimeoutAt) Recalculates the next timeout checking time.
void	setAsyncLocalInvocation(boolean asyncLocalInvocation)
void	setCheckVersion(boolean checkVersion)
void	setStreamTimeout(long streamTimeout)
void	setWriteErrorsToLog(boolean writeErrorsToLog)
void	setWriteRegistrations(boolean writeRegistrations)
void	started(ServiceBroker broker) Initializes ServiceRegistry instance.
protected void	stopAllLocalServices()
void	stopped()
void	use(java.util.Collection<Middleware> middlewares)
io.datatree.Promise	waitForServices(long timeoutMillis, java.util.Collection<java.lang.String> services)

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

middlewares

protected final java.util.LinkedHashSet<Middleware> middlewares

services

protected final java.util.LinkedHashMap<java.lang.String,Service> services

strategies

protected final java.util.HashMap<java.lang.String,Strategy<ActionEndpoint>> strategies

names

protected final java.util.HashSet<java.lang.String> names

promises

protected final java.util.concurrent.ConcurrentHashMap<java.lang.String,PendingPromise> promises

requestStreams

protected final java.util.HashMap<java.lang.String,IncomingStream> requestStreams

responseStreams

protected final java.util.HashMap<java.lang.String,IncomingStream> responseStreams

readLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock readLock

writeLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock writeLock

requestStreamReadLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock requestStreamReadLock

requestStreamWriteLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock requestStreamWriteLock

responseStreamReadLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock responseStreamReadLock

responseStreamWriteLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock responseStreamWriteLock

asyncLocalInvocation

protected boolean asyncLocalInvocation

Invoke all local services via Thread pool (true) or directly (false)

checkVersion

protected boolean checkVersion

Check protocol version

protocolVersion

protected java.lang.String protocolVersion

ServiceBroker's protocol version

writeErrorsToLog

protected boolean writeErrorsToLog

Write exceptions into the log file

writeRegistrations

protected boolean writeRegistrations

Write Service and Action registrations into the log file

streamTimeout

protected long streamTimeout

Stream inactivity/read timeout in MILLISECONDS (0 = no timeout). It may be useful if you want to remove the wrong packages from the memory.

nodeID

protected java.lang.String nodeID

executor

protected java.util.concurrent.ExecutorService executor

scheduler

protected java.util.concurrent.ScheduledExecutorService scheduler

strategyFactory

protected StrategyFactory strategyFactory

transporter

protected Transporter transporter

eventbus

protected Eventbus eventbus

uidGenerator

protected UidGenerator uidGenerator

serviceInvoker

protected ServiceInvoker serviceInvoker

metrics

protected Metrics metrics

callTimeoutTimer

protected final java.util.concurrent.atomic.AtomicReference<java.util.concurrent.ScheduledFuture<?>> callTimeoutTimer

Cancelable timer for handling timeouts of action calls

prevTimeoutAt

protected final java.util.concurrent.atomic.AtomicLong prevTimeoutAt

Next scheduled time to check timeouts

servicesOnlineTimer

protected java.util.concurrent.ScheduledFuture<?> servicesOnlineTimer

Cancelable timer for handling "wait for service" calls

serviceListeners

protected final java.util.LinkedList<ServiceListener> serviceListeners

Promises of the "waitingForServices" calls

timestamp

protected java.util.concurrent.atomic.AtomicLong timestamp

Timestamp of the service descriptor of this Moleculer Node (~= "generated at" timestamp)

cachedDescriptor

protected volatile FastBuildTree cachedDescriptor

gaugeRequestsActive

protected MetricGauge gaugeRequestsActive

gaugeStreamsReceiveActive

protected MetricGauge gaugeStreamsReceiveActive

counterOrphanResponseTotal

protected MetricCounter counterOrphanResponseTotal

Constructor Detail

DefaultServiceRegistry

public DefaultServiceRegistry()

DefaultServiceRegistry

public DefaultServiceRegistry(boolean asyncLocalInvocation)

Method Detail

started

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

Initializes ServiceRegistry instance.

Specified by:

started in interface MoleculerLifecycle

Overrides:

started in class MoleculerComponent

Parameters:

broker - parent ServiceBroker

Throws:

java.lang.Exception

stopped

public void stopped()

Specified by:

stopped in interface MoleculerLifecycle

Overrides:

stopped in class MoleculerComponent

checkTimeouts

protected void checkTimeouts()

reschedule

protected void reschedule(long minTimeoutAt)

Recalculates the next timeout checking time.

Parameters:

minTimeoutAt - next / closest timestamp

register

protected void register(java.lang.String id,
                        io.datatree.Promise promise,
                        long timeoutAt,
                        java.lang.String nodeID,
                        java.lang.String action,
                        io.datatree.Tree req)

deregister

protected void deregister(java.lang.String id)

receiveRequest

public void receiveRequest(io.datatree.Tree message)

Specified by:

receiveRequest in class ServiceRegistry

logUnableToInvokeAction

protected void logUnableToInvokeAction(java.lang.String action,
                                       java.lang.Throwable cause)

receivePong

public void receivePong(io.datatree.Tree message)

Specified by:

receivePong in class ServiceRegistry

receiveResponse

public void receiveResponse(io.datatree.Tree message)

Specified by:

receiveResponse in class ServiceRegistry

use

public void use(java.util.Collection<Middleware> middlewares)

Specified by:

use in class ServiceRegistry

addActions

public io.datatree.Promise addActions(java.lang.String serviceName,
                                      Service service)

Specified by:

addActions in class ServiceRegistry

addOnlineActions

protected void addOnlineActions(java.lang.String serviceName,
                                Service service)

broadcastServicesChanged

protected void broadcastServicesChanged(boolean local)

addActions

public void addActions(java.lang.String nodeID,
                       io.datatree.Tree config)

Specified by:

addActions in class ServiceRegistry

removeActions

public void removeActions(java.lang.String nodeID)

Specified by:

removeActions in class ServiceRegistry

stopAllLocalServices

protected void stopAllLocalServices()

getService

public Service getService(java.lang.String name)

Specified by:

getService in class ServiceRegistry

getAction

public Action getAction(java.lang.String name,
                        java.lang.String nodeID)

Specified by:

getAction in class ServiceRegistry

waitForServices

public io.datatree.Promise waitForServices(long timeoutMillis,
                                           java.util.Collection<java.lang.String> services)

Specified by:

waitForServices in class ServiceRegistry

checkServicesOnline

protected void checkServicesOnline()

isServicesOnline

protected boolean isServicesOnline(java.util.Collection<java.lang.String> requiredServices)

countOnlineServices

protected int countOnlineServices(java.util.Collection<java.lang.String> requiredServices)

ping

public io.datatree.Promise ping(long timeoutMillis,
                                java.lang.String nodeID)

Specified by:

ping in class ServiceRegistry

getTimestamp

public long getTimestamp()

Specified by:

getTimestamp in class ServiceRegistry

getDescriptor

public io.datatree.Tree getDescriptor()

Specified by:

getDescriptor in class ServiceRegistry

clearDescriptorCache

protected void clearDescriptorCache()

currentDescriptor

protected io.datatree.Tree currentDescriptor()

isCheckVersion

public boolean isCheckVersion()

setCheckVersion

public void setCheckVersion(boolean checkVersion)

isAsyncLocalInvocation

public boolean isAsyncLocalInvocation()

setAsyncLocalInvocation

public void setAsyncLocalInvocation(boolean asyncLocalInvocation)

isWriteErrorsToLog

public boolean isWriteErrorsToLog()

setWriteErrorsToLog

public void setWriteErrorsToLog(boolean writeErrorsToLog)

getStreamTimeout

public long getStreamTimeout()

setStreamTimeout

public void setStreamTimeout(long streamTimeout)

isWriteRegistrations

public boolean isWriteRegistrations()

setWriteRegistrations

public void setWriteRegistrations(boolean writeRegistrations)