org.apache.hadoop.hbase

Class JMXListener

java.lang.Object

org.apache.hadoop.hbase.JMXListener

All Implemented Interfaces:

Coprocessor, MasterCoprocessor, RegionServerCoprocessor

@InterfaceAudience.Private
public class JMXListener
extends Object
implements MasterCoprocessor, RegionServerCoprocessor

Pluggable JMX Agent for HBase(to fix the 2 random TCP ports issue of the out-of-the-box JMX Agent): 1)connector port can share with the registry port if SSL is OFF 2)support password authentication 3)support subset of SSL (with default configuration)

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

Coprocessor.State

Field Summary

Fields

Modifier and Type	Field and Description
static int	defMasterRMIRegistryPort
static int	defRegionserverRMIRegistryPort
private static JMXConnectorServer	JMX_CS workaround for HBASE-11146 master and regionserver are in 1 JVM in standalone mode only 1 JMX instance is allowed, otherwise there is port conflict even if we only load regionserver coprocessor on master
private static org.slf4j.Logger	LOG
static String	RMI_CONNECTOR_PORT_CONF_KEY
static String	RMI_REGISTRY_PORT_CONF_KEY
private Registry	rmiRegistry

Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
JMXListener()

Method Summary

Modifier and Type	Method and Description
static JMXServiceURL	buildJMXServiceURL(int rmiRegistryPort, int rmiConnectorPort)
void	start(CoprocessorEnvironment env) Called by the CoprocessorEnvironment during it's own startup to initialize the coprocessor.
void	startConnectorServer(int rmiRegistryPort, int rmiConnectorPort)
void	stop(CoprocessorEnvironment env) Called by the CoprocessorEnvironment during it's own shutdown to stop the coprocessor.
void	stopConnectorServer()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.MasterCoprocessor

getMasterObserver

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor

getRegionServerObserver

Methods inherited from interface org.apache.hadoop.hbase.Coprocessor

getServices

Field Detail

LOG

private static final org.slf4j.Logger LOG

RMI_REGISTRY_PORT_CONF_KEY

public static final String RMI_REGISTRY_PORT_CONF_KEY

See Also:

Constant Field Values

RMI_CONNECTOR_PORT_CONF_KEY

public static final String RMI_CONNECTOR_PORT_CONF_KEY

See Also:

Constant Field Values

defMasterRMIRegistryPort

public static final int defMasterRMIRegistryPort

See Also:

Constant Field Values

defRegionserverRMIRegistryPort

public static final int defRegionserverRMIRegistryPort

See Also:

Constant Field Values

JMX_CS

private static JMXConnectorServer JMX_CS

workaround for HBASE-11146 master and regionserver are in 1 JVM in standalone mode only 1 JMX instance is allowed, otherwise there is port conflict even if we only load regionserver coprocessor on master

rmiRegistry

private Registry rmiRegistry

Constructor Detail

JMXListener

public JMXListener()

Method Detail

buildJMXServiceURL

public static JMXServiceURL buildJMXServiceURL(int rmiRegistryPort,
                                               int rmiConnectorPort)
                                        throws IOException

Throws:

IOException

startConnectorServer

public void startConnectorServer(int rmiRegistryPort,
                                 int rmiConnectorPort)
                          throws IOException

Throws:

IOException

stopConnectorServer

public void stopConnectorServer()
                         throws IOException

Throws:

IOException

start

public void start(CoprocessorEnvironment env)
           throws IOException

Description copied from interface: Coprocessor

Called by the CoprocessorEnvironment during it's own startup to initialize the coprocessor.

Specified by:

start in interface Coprocessor

Throws:

IOException

stop

public void stop(CoprocessorEnvironment env)
          throws IOException

Description copied from interface: Coprocessor

Called by the CoprocessorEnvironment during it's own shutdown to stop the coprocessor.

Specified by:

stop in interface Coprocessor

Throws:

IOException