com.orientechnologies.orient.server.hazelcast

Class OHazelcastPlugin

java.lang.Object

com.orientechnologies.orient.server.plugin.OServerPluginAbstract

com.orientechnologies.orient.server.distributed.impl.ODistributedAbstractPlugin

com.orientechnologies.orient.server.hazelcast.OHazelcastPlugin

All Implemented Interfaces:

com.hazelcast.core.EntryListener<String,Object>, com.hazelcast.core.LifecycleListener, com.hazelcast.core.MembershipListener, com.hazelcast.map.listener.EntryAddedListener<String,Object>, com.hazelcast.map.listener.EntryEvictedListener<String,Object>, com.hazelcast.map.listener.EntryRemovedListener<String,Object>, com.hazelcast.map.listener.EntryUpdatedListener<String,Object>, com.hazelcast.map.listener.MapClearedListener, com.hazelcast.map.listener.MapEvictedListener, com.hazelcast.map.listener.MapListener, OService, OCommandOutputListener, ODatabaseLifecycleListener, ODistributedServerManager, OBeforeDatabaseOpenNetworkEventListener, OServerPlugin, EventListener

public class OHazelcastPlugin
extends ODistributedAbstractPlugin
implements com.hazelcast.core.MembershipListener, com.hazelcast.core.EntryListener<String,Object>, com.hazelcast.core.LifecycleListener, OBeforeDatabaseOpenNetworkEventListener

Hazelcast implementation for clustering.

Author:

Luca Garulli (l.garulli--at--orientdb.com)

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.server.distributed.ODistributedServerManager

ODistributedServerManager.DB_STATUS, ODistributedServerManager.NODE_STATUS

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.db.ODatabaseLifecycleListener

ODatabaseLifecycleListener.PRIORITY

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONFIG_DATABASE_PREFIX
static String	CONFIG_DBSTATUS_PREFIX
static String	CONFIG_LOCKMANAGER
static String	CONFIG_NODE_PREFIX
static String	CONFIG_REGISTEREDNODES
protected OHazelcastDistributedMap	configurationMap
protected com.hazelcast.config.Config	hazelcastConfig
protected String	hazelcastConfigFile
protected com.hazelcast.core.HazelcastInstance	hazelcastInstance
protected String	membershipListenerMapRegistration
protected String	membershipListenerRegistration

Fields inherited from class com.orientechnologies.orient.server.distributed.impl.ODistributedAbstractPlugin

activeNodes, activeNodesNamesByUuid, activeNodesUuidByName, autoRemovalOfServers, clusterAssignmentStrategy, defaultDatabaseConfigFile, DEPLOY_DB_MAX_RETRIES, haStatsTask, healthCheckerTask, installingDatabases, lastClusterChangeOn, listeners, localMessageIdCounter, messageService, NODE_NAME_ENV, nodeId, nodeName, nodeUuid, PAR_DEF_DISTRIB_DB_CONFIG, publishLocalNodeConfigurationTask, registeredNodeById, registeredNodeByName, remoteServers, REPLICATOR_USER, responseManagerFactory, serverInstance, serverStarted, startedOn, status, storages, taskFactoryManager

Fields inherited from class com.orientechnologies.orient.server.plugin.OServerPluginAbstract

enabled

Fields inherited from interface com.orientechnologies.orient.server.distributed.ODistributedServerManager

FILE_DISTRIBUTED_DB_CONFIG

Constructor Summary

Constructors

Constructor and Description
OHazelcastPlugin()

Method Summary

Modifier and Type	Method and Description
void	config(OServer iServer, OServerParameterConfiguration[] iParams) Configures the handler.
protected com.hazelcast.core.HazelcastInstance	configureHazelcast()
Throwable	convertException(Throwable original)
protected void	dumpStats()
String	electNewLockManager() Elects a new server as coordinator.
void	entryAdded(com.hazelcast.core.EntryEvent<String,Object> iEvent)
void	entryEvicted(com.hazelcast.core.EntryEvent<String,Object> iEvent)
void	entryRemoved(com.hazelcast.core.EntryEvent<String,Object> iEvent)
void	entryUpdated(com.hazelcast.core.EntryEvent<String,Object> iEvent)
Set<String>	getActiveServers()
long	getClusterTime() Returns the cluster-wide time in milliseconds.
OHazelcastDistributedMap	getConfigurationMap()
ODistributedServerManager.DB_STATUS	getDatabaseStatus(String iNode, String iDatabaseName)
ODistributedServerManager.DB_STATUS	getDatabaseStatus(String iNode, String iDatabaseName, boolean useCache)
com.hazelcast.core.HazelcastInstance	getHazelcastInstance()
ODocument	getNodeConfigurationByUuid(String iNodeId, boolean useCache)
int	getNodeIdByName(String name)
String	getNodeNameById(int id)
String	getPublicAddress()
ORemoteServerController	getRemoteServer(String rNodeName)
protected void	initSystemDatabase() Protecte system database from being replicated
protected void	installNewDatabasesFromCluster()
boolean	isNodeAvailable(String iNodeName)
boolean	isWriteQuorumPresent(String databaseName) Returns true if the quorum is present in terms of number of available nodes for full replication only.
protected void	loadLocalDatabases() Initializes all the available server's databases as distributed.
void	mapCleared(com.hazelcast.core.MapEvent event)
void	mapEvicted(com.hazelcast.core.MapEvent iEvent)
void	memberAdded(com.hazelcast.core.MembershipEvent iEvent)
void	memberAttributeChanged(com.hazelcast.core.MemberAttributeEvent memberAttributeEvent)
void	memberRemoved(com.hazelcast.core.MembershipEvent iEvent) Removes the node map entry.
void	messageAfterOp(String op, ODistributedRequestId request)
void	messageBeforeOp(String op, ODistributedRequestId request)
void	messageCurrentPayload(ODistributedRequestId requestId, Object responsePayload)
void	messagePartitionCalculate(ODistributedRequest request, Set<Integer> involvedWorkerQueues)
void	messageProcessEnd(ODistributedRequest iRequest, Object responsePayload)
void	messageProcessStart(ODistributedRequest message)
void	messageReceived(ODistributedRequest request)
void	notifyClients(String databaseName)
void	onBeforeDatabaseOpen(String url)
void	onCreate(ODatabaseInternal iDatabase)
void	onDrop(ODatabaseInternal iDatabase)
protected void	publishLocalNodeConfiguration()
protected void	registerNode(com.hazelcast.core.Member member, String joinedNodeName)
void	reloadRegisteredNodes(String registeredNodesFromClusterAsJson)
void	removeNodeFromConfiguration(String nodeLeftName, boolean removeOnlyDynamicServers)
boolean	removeNodeFromConfiguration(String nodeLeftName, String databaseName, boolean removeOnlyDynamicServers, boolean statusOffline)
void	removeServer(String nodeLeftName, boolean removeOnlyDynamicServers)
void	setDatabaseStatus(String iNode, String iDatabaseName, ODistributedServerManager.DB_STATUS iStatus)
void	setHazelcastConfig(com.hazelcast.config.Config config)
void	setNodeName(String nodeName)
void	shutdown()
void	startup()
void	stateChanged(com.hazelcast.core.LifecycleEvent event)
boolean	updateCachedDatabaseConfiguration(String databaseName, OModifiableDistributedConfiguration cfg, boolean iDeployToCluster)
protected void	waitStartupIsCompleted()

Methods inherited from class com.orientechnologies.orient.server.distributed.impl.ODistributedAbstractPlugin

assignNodeName, backupCurrentDatabase, checkIntegrityOfLastTransactions, checkNodeStatus, closeRemoteServer, dumpServersStatus, executeInDistributedDatabaseLock, executeOnLocalNode, executeOnLocalNodeFromRemote, getAvailableNodeNames, getAvailableNodes, getAvailableNodes, getClusterConfiguration, getClusterOwnedExclusivelyByCurrentNode, getConflictResolverFactory, getCoordinatorServer, getDatabaseConfiguration, getDatabaseConfiguration, getDefaultDatabaseConfigFile, getDistributedStrategy, getLastClusterChangeOn, getListeningBinaryAddress, getLocalNodeConfiguration, getLocalNodeId, getLocalNodeName, getLockManagerExecutor, getLockManagerRequester, getLockManagerServer, getManagedDatabases, getMessageService, getName, getNextMessageIdCounter, getNodeName, getNodeName, getNodeStatus, getNodesWithStatus, getNodeUuidByName, getOnlineNodes, getPriority, getServerInstance, getStats, getStorage, getStorage, getStorageIfExists, getTaskFactoryManager, getTotalNodes, installClustersOfClass, installDatabase, installDatabase, installDatabaseFromNetwork, installDatabaseOnLocalNode, isEnabled, isNodeAvailable, isNodeOnline, isNodeStatusEqualsTo, isOffline, isRelatedToLocalServer, onClose, onCreateClass, onDatabaseEvent, onDropClass, onLocalNodeConfigurationRequest, onMessage, onOpen, reassignClustersOwnership, rebalanceClusterOwnership, registerLifecycleListener, registerNewDatabaseIfNeeded, removeStorage, requestDatabaseDelta, requestDatabaseFullSync, requestFullDatabase, restartNode, sendRequest, sendRequest, sendShutdown, setDefaultDatabaseConfigFile, setDistributedStrategy, setNodeStatus, stopNode, toString, unregisterLifecycleListener, updateCachedDatabaseConfiguration, updateLastClusterChange, waitUntilNodeOnline, waitUntilNodeOnline

Methods inherited from class com.orientechnologies.orient.server.plugin.OServerPluginAbstract

getContent, onAfterClientRequest, onBeforeClientRequest, onClientConnection, onClientDisconnection, onClientError

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.server.plugin.OServerPlugin

onSocketAccepted, onSocketDestroyed

Field Detail

CONFIG_DATABASE_PREFIX

public static final String CONFIG_DATABASE_PREFIX

See Also:

Constant Field Values

CONFIG_NODE_PREFIX

public static final String CONFIG_NODE_PREFIX

See Also:

Constant Field Values

CONFIG_DBSTATUS_PREFIX

public static final String CONFIG_DBSTATUS_PREFIX

See Also:

Constant Field Values

CONFIG_LOCKMANAGER

public static final String CONFIG_LOCKMANAGER

See Also:

Constant Field Values

CONFIG_REGISTEREDNODES

public static final String CONFIG_REGISTEREDNODES

See Also:

Constant Field Values

hazelcastConfigFile

protected String hazelcastConfigFile

hazelcastConfig

protected com.hazelcast.config.Config hazelcastConfig

membershipListenerRegistration

protected String membershipListenerRegistration

membershipListenerMapRegistration

protected String membershipListenerMapRegistration

hazelcastInstance

protected volatile com.hazelcast.core.HazelcastInstance hazelcastInstance

configurationMap

protected OHazelcastDistributedMap configurationMap

Constructor Detail

OHazelcastPlugin

public OHazelcastPlugin()

Method Detail

setHazelcastConfig

public void setHazelcastConfig(com.hazelcast.config.Config config)

setNodeName

public void setNodeName(String nodeName)

config

public void config(OServer iServer,
                   OServerParameterConfiguration[] iParams)

Description copied from interface: OServerPlugin

Configures the handler. Called at startup.

Specified by:

config in interface OServerPlugin

Overrides:

config in class ODistributedAbstractPlugin

startup

public void startup()

Specified by:

startup in interface OService

Overrides:

startup in class ODistributedAbstractPlugin

initSystemDatabase

protected void initSystemDatabase()

Protecte system database from being replicated

isWriteQuorumPresent

public boolean isWriteQuorumPresent(String databaseName)

Description copied from interface: ODistributedServerManager

Returns true if the quorum is present in terms of number of available nodes for full replication only. With sharding, instead, the quorum may depend on the involved clusters.

Specified by:

isWriteQuorumPresent in interface ODistributedServerManager

Returns:

getNodeIdByName

public int getNodeIdByName(String name)

Specified by:

getNodeIdByName in interface ODistributedServerManager

Overrides:

getNodeIdByName in class ODistributedAbstractPlugin

getNodeNameById

public String getNodeNameById(int id)

Specified by:

getNodeNameById in interface ODistributedServerManager

Overrides:

getNodeNameById in class ODistributedAbstractPlugin

isNodeAvailable

public boolean isNodeAvailable(String iNodeName)

Specified by:

isNodeAvailable in interface ODistributedServerManager

Overrides:

isNodeAvailable in class ODistributedAbstractPlugin

waitStartupIsCompleted

protected void waitStartupIsCompleted()
                               throws InterruptedException

Throws:

InterruptedException

publishLocalNodeConfiguration

protected void publishLocalNodeConfiguration()

dumpStats

protected void dumpStats()

convertException

public Throwable convertException(Throwable original)

Specified by:

convertException in interface ODistributedServerManager

getClusterTime

public long getClusterTime()

Description copied from interface: ODistributedServerManager

Returns the cluster-wide time in milliseconds.

Cluster tries to keep a cluster-wide time which might be different than the member's own system time. Cluster-wide time is -almost- the same on all members of the cluster.

Specified by:

getClusterTime in interface ODistributedServerManager

shutdown

public void shutdown()

Specified by:

shutdown in interface OService

Overrides:

shutdown in class ODistributedAbstractPlugin

getRemoteServer

public ORemoteServerController getRemoteServer(String rNodeName)
                                        throws IOException

Specified by:

getRemoteServer in interface ODistributedServerManager

Throws:

IOException

getHazelcastInstance

public com.hazelcast.core.HazelcastInstance getHazelcastInstance()

configureHazelcast

protected com.hazelcast.core.HazelcastInstance configureHazelcast()
                                                           throws FileNotFoundException

Throws:

FileNotFoundException

getPublicAddress

public String getPublicAddress()

Specified by:

getPublicAddress in class ODistributedAbstractPlugin

loadLocalDatabases

protected void loadLocalDatabases()

Initializes all the available server's databases as distributed.

getConfigurationMap

public OHazelcastDistributedMap getConfigurationMap()

Specified by:

getConfigurationMap in interface ODistributedServerManager

memberAttributeChanged

public void memberAttributeChanged(com.hazelcast.core.MemberAttributeEvent memberAttributeEvent)

Specified by:

memberAttributeChanged in interface com.hazelcast.core.MembershipListener

updateCachedDatabaseConfiguration

public boolean updateCachedDatabaseConfiguration(String databaseName,
                                                 OModifiableDistributedConfiguration cfg,
                                                 boolean iDeployToCluster)

Specified by:

updateCachedDatabaseConfiguration in interface ODistributedServerManager

notifyClients

public void notifyClients(String databaseName)

Specified by:

notifyClients in interface ODistributedServerManager

Specified by:

notifyClients in class ODistributedAbstractPlugin

entryAdded

public void entryAdded(com.hazelcast.core.EntryEvent<String,Object> iEvent)

Specified by:

entryAdded in interface com.hazelcast.map.listener.EntryAddedListener<String,Object>

entryUpdated

public void entryUpdated(com.hazelcast.core.EntryEvent<String,Object> iEvent)

Specified by:

entryUpdated in interface com.hazelcast.map.listener.EntryUpdatedListener<String,Object>

entryRemoved

public void entryRemoved(com.hazelcast.core.EntryEvent<String,Object> iEvent)

Specified by:

entryRemoved in interface com.hazelcast.map.listener.EntryRemovedListener<String,Object>

entryEvicted

public void entryEvicted(com.hazelcast.core.EntryEvent<String,Object> iEvent)

Specified by:

entryEvicted in interface com.hazelcast.map.listener.EntryEvictedListener<String,Object>

mapEvicted

public void mapEvicted(com.hazelcast.core.MapEvent iEvent)

Specified by:

mapEvicted in interface com.hazelcast.map.listener.MapEvictedListener

mapCleared

public void mapCleared(com.hazelcast.core.MapEvent event)

Specified by:

mapCleared in interface com.hazelcast.map.listener.MapClearedListener

memberRemoved

public void memberRemoved(com.hazelcast.core.MembershipEvent iEvent)

Removes the node map entry.

Specified by:

memberRemoved in interface com.hazelcast.core.MembershipListener

memberAdded

public void memberAdded(com.hazelcast.core.MembershipEvent iEvent)

Specified by:

memberAdded in interface com.hazelcast.core.MembershipListener

stateChanged

public void stateChanged(com.hazelcast.core.LifecycleEvent event)

Specified by:

stateChanged in interface com.hazelcast.core.LifecycleListener

onCreate

public void onCreate(ODatabaseInternal iDatabase)

Specified by:

onCreate in interface ODatabaseLifecycleListener

onDrop

public void onDrop(ODatabaseInternal iDatabase)

Specified by:

onDrop in interface ODatabaseLifecycleListener

Overrides:

onDrop in class ODistributedAbstractPlugin

getNodeConfigurationByUuid

public ODocument getNodeConfigurationByUuid(String iNodeId,
                                            boolean useCache)

Specified by:

getNodeConfigurationByUuid in interface ODistributedServerManager

getDatabaseStatus

public ODistributedServerManager.DB_STATUS getDatabaseStatus(String iNode,
                                                             String iDatabaseName)

Specified by:

getDatabaseStatus in interface ODistributedServerManager

getDatabaseStatus

public ODistributedServerManager.DB_STATUS getDatabaseStatus(String iNode,
                                                             String iDatabaseName,
                                                             boolean useCache)

setDatabaseStatus

public void setDatabaseStatus(String iNode,
                              String iDatabaseName,
                              ODistributedServerManager.DB_STATUS iStatus)

Specified by:

setDatabaseStatus in interface ODistributedServerManager

installNewDatabasesFromCluster

protected void installNewDatabasesFromCluster()

reloadRegisteredNodes

public void reloadRegisteredNodes(String registeredNodesFromClusterAsJson)

removeNodeFromConfiguration

public void removeNodeFromConfiguration(String nodeLeftName,
                                        boolean removeOnlyDynamicServers)

removeNodeFromConfiguration

public boolean removeNodeFromConfiguration(String nodeLeftName,
                                           String databaseName,
                                           boolean removeOnlyDynamicServers,
                                           boolean statusOffline)

removeServer

public void removeServer(String nodeLeftName,
                         boolean removeOnlyDynamicServers)

Specified by:

removeServer in interface ODistributedServerManager

electNewLockManager

public String electNewLockManager()

Elects a new server as coordinator. The election browse the ordered server list.

Specified by:

electNewLockManager in interface ODistributedServerManager

getActiveServers

public Set<String> getActiveServers()

Specified by:

getActiveServers in interface ODistributedServerManager

onBeforeDatabaseOpen

public void onBeforeDatabaseOpen(String url)

Specified by:

onBeforeDatabaseOpen in interface OBeforeDatabaseOpenNetworkEventListener

registerNode

protected void registerNode(com.hazelcast.core.Member member,
                            String joinedNodeName)

messageReceived

public void messageReceived(ODistributedRequest request)

Specified by:

messageReceived in interface ODistributedServerManager

messagePartitionCalculate

public void messagePartitionCalculate(ODistributedRequest request,
                                      Set<Integer> involvedWorkerQueues)

Specified by:

messagePartitionCalculate in interface ODistributedServerManager

messageBeforeOp

public void messageBeforeOp(String op,
                            ODistributedRequestId request)

Specified by:

messageBeforeOp in interface ODistributedServerManager

messageAfterOp

public void messageAfterOp(String op,
                           ODistributedRequestId request)

Specified by:

messageAfterOp in interface ODistributedServerManager

messageCurrentPayload

public void messageCurrentPayload(ODistributedRequestId requestId,
                                  Object responsePayload)

Specified by:

messageCurrentPayload in interface ODistributedServerManager

messageProcessStart

public void messageProcessStart(ODistributedRequest message)

Specified by:

messageProcessStart in interface ODistributedServerManager

messageProcessEnd

public void messageProcessEnd(ODistributedRequest iRequest,
                              Object responsePayload)

Specified by:

messageProcessEnd in interface ODistributedServerManager