- java.lang.Object
-
- javax.management.NotificationBroadcasterSupport
-
- javax.management.remote.JMXConnectorServer
-
- javax.management.remote.rmi.RMIConnectorServer
-
- All Implemented Interfaces:
MBeanRegistration
,NotificationBroadcaster
,NotificationEmitter
,JMXAddressable
,JMXConnectorServerMBean
public class RMIConnectorServer extends JMXConnectorServer
A JMX API connector server that creates RMI-based connections from remote clients. Usually, such connector servers are made using
JMXConnectorServerFactory
. However, specialized applications can use this class directly, for example with anRMIServerImpl
object.- Since:
- 1.5
-
-
Field Summary
Fields Modifier and Type Field Description static String
CREDENTIAL_TYPES
Name of the attribute that specifies a list of class names acceptable as parameters to theRMIServer.newClient()
remote method call.static String
JNDI_REBIND_ATTRIBUTE
Name of the attribute that specifies whether theRMIServer
stub that represents an RMI connector server should override an existing stub at the same address.static String
RMI_CLIENT_SOCKET_FACTORY_ATTRIBUTE
Name of the attribute that specifies theRMIClientSocketFactory
for the RMI objects created in conjunction with this connector.static String
RMI_SERVER_SOCKET_FACTORY_ATTRIBUTE
Name of the attribute that specifies theRMIServerSocketFactory
for the RMI objects created in conjunction with this connector.-
Fields inherited from class javax.management.remote.JMXConnectorServer
AUTHENTICATOR
-
-
Constructor Summary
Constructors Constructor Description RMIConnectorServer(JMXServiceURL url, Map<String,?> environment)
Makes anRMIConnectorServer
.RMIConnectorServer(JMXServiceURL url, Map<String,?> environment, MBeanServer mbeanServer)
Makes anRMIConnectorServer
for the given MBean server.RMIConnectorServer(JMXServiceURL url, Map<String,?> environment, RMIServerImpl rmiServerImpl, MBeanServer mbeanServer)
Makes anRMIConnectorServer
for the given MBean server.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
connectionClosed(String connectionId, String message, Object userData)
Called by a subclass when a client connection is closed normally.protected void
connectionFailed(String connectionId, String message, Object userData)
Called by a subclass when a client connection fails.protected void
connectionOpened(String connectionId, String message, Object userData)
Called by a subclass when a new client connection is opened.JMXServiceURL
getAddress()
The address of this connector server.Map<String,?>
getAttributes()
The attributes for this connector server.boolean
isActive()
Determines whether the connector server is active.void
setMBeanServerForwarder(MBeanServerForwarder mbsf)
Inserts an object that intercepts requests for the MBean server that arrive through this connector server.void
start()
Activates the connector server, that is starts listening for client connections.void
stop()
Deactivates the connector server, that is, stops listening for client connections.JMXConnector
toJMXConnector(Map<String,?> env)
Returns a client stub for this connector server.-
Methods inherited from class javax.management.remote.JMXConnectorServer
getConnectionIds, getMBeanServer, getNotificationInfo, postDeregister, postRegister, preDeregister, preRegister
-
Methods inherited from class javax.management.NotificationBroadcasterSupport
addNotificationListener, handleNotification, removeNotificationListener, removeNotificationListener, sendNotification
-
-
-
-
Field Detail
-
JNDI_REBIND_ATTRIBUTE
public static final String JNDI_REBIND_ATTRIBUTE
Name of the attribute that specifies whether the
RMIServer
stub that represents an RMI connector server should override an existing stub at the same address. The value associated with this attribute, if any, should be a string that is equal, ignoring case, to"true"
or"false"
. The default value is false.- See Also:
- Constant Field Values
-
RMI_CLIENT_SOCKET_FACTORY_ATTRIBUTE
public static final String RMI_CLIENT_SOCKET_FACTORY_ATTRIBUTE
Name of the attribute that specifies the
RMIClientSocketFactory
for the RMI objects created in conjunction with this connector. The value associated with this attribute must be of typeRMIClientSocketFactory
and can only be specified in theMap
argument supplied when creating a connector server.- See Also:
- Constant Field Values
-
RMI_SERVER_SOCKET_FACTORY_ATTRIBUTE
public static final String RMI_SERVER_SOCKET_FACTORY_ATTRIBUTE
Name of the attribute that specifies the
RMIServerSocketFactory
for the RMI objects created in conjunction with this connector. The value associated with this attribute must be of typeRMIServerSocketFactory
and can only be specified in theMap
argument supplied when creating a connector server.- See Also:
- Constant Field Values
-
CREDENTIAL_TYPES
public static final String CREDENTIAL_TYPES
Name of the attribute that specifies a list of class names acceptable as parameters to theRMIServer.newClient()
remote method call.This list of classes should correspond to the transitive closure of the credentials class (or classes) used by the installed JMXAuthenticator associated with the RMIServer implementation.
If the attribute is not set, or is null, then any class is deemed acceptable.
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
RMIConnectorServer
public RMIConnectorServer(JMXServiceURL url, Map<String,?> environment) throws IOException
Makes an
RMIConnectorServer
. This is equivalent to callingRMIConnectorServer(directoryURL,environment,null,null)
- Parameters:
url
- the URL defining how to create the connector server. Cannot be null.environment
- attributes governing the creation and storing of the RMI object. Can be null, which is equivalent to an empty Map.- Throws:
IllegalArgumentException
- ifurl
is null.MalformedURLException
- ifurl
does not conform to the syntax for an RMI connector, or if its protocol is not recognized by this implementation. Only "rmi" is valid when this constructor is used.IOException
- if the connector server cannot be created for some reason or if it is inevitable that itsstart
method will fail.
-
RMIConnectorServer
public RMIConnectorServer(JMXServiceURL url, Map<String,?> environment, MBeanServer mbeanServer) throws IOException
Makes an
RMIConnectorServer
for the given MBean server. This is equivalent to callingRMIConnectorServer(directoryURL,environment,null,mbeanServer)
- Parameters:
url
- the URL defining how to create the connector server. Cannot be null.environment
- attributes governing the creation and storing of the RMI object. Can be null, which is equivalent to an empty Map.mbeanServer
- the MBean server to which the new connector server is attached, or null if it will be attached by being registered as an MBean in the MBean server.- Throws:
IllegalArgumentException
- ifurl
is null.MalformedURLException
- ifurl
does not conform to the syntax for an RMI connector, or if its protocol is not recognized by this implementation. Only "rmi" is valid when this constructor is used.IOException
- if the connector server cannot be created for some reason or if it is inevitable that itsstart
method will fail.
-
RMIConnectorServer
public RMIConnectorServer(JMXServiceURL url, Map<String,?> environment, RMIServerImpl rmiServerImpl, MBeanServer mbeanServer) throws IOException
Makes an
RMIConnectorServer
for the given MBean server.- Parameters:
url
- the URL defining how to create the connector server. Cannot be null.environment
- attributes governing the creation and storing of the RMI object. Can be null, which is equivalent to an empty Map.rmiServerImpl
- An implementation of the RMIServer interface, consistent with the protocol type specified in url. If this parameter is non null, the protocol type specified by url is not constrained, and is assumed to be valid. Otherwise, only "rmi" will be recognized.mbeanServer
- the MBean server to which the new connector server is attached, or null if it will be attached by being registered as an MBean in the MBean server.- Throws:
IllegalArgumentException
- ifurl
is null.MalformedURLException
- ifurl
does not conform to the syntax for an RMI connector, or if its protocol is not recognized by this implementation. Only "rmi" is recognized when rmiServerImpl is null.IOException
- if the connector server cannot be created for some reason or if it is inevitable that itsstart
method will fail.- See Also:
start()
-
-
Method Detail
-
toJMXConnector
public JMXConnector toJMXConnector(Map<String,?> env) throws IOException
Returns a client stub for this connector server. A client stub is a serializable object whose
connect
method can be used to make one new connection to this connector server.- Specified by:
toJMXConnector
in interfaceJMXConnectorServerMBean
- Overrides:
toJMXConnector
in classJMXConnectorServer
- Parameters:
env
- client connection parameters of the same sort that could be provided toJMXConnector.connect(Map)
. Can be null, which is equivalent to an empty map.- Returns:
- a client stub that can be used to make a new connection to this connector server.
- Throws:
UnsupportedOperationException
- if this connector server does not support the generation of client stubs.IllegalStateException
- if the JMXConnectorServer is not started (seeisActive()
).IOException
- if a communications problem means that a stub cannot be created.
-
start
public void start() throws IOException
Activates the connector server, that is starts listening for client connections. Calling this method when the connector server is already active has no effect. Calling this method when the connector server has been stopped will generate an
IOException
.The behavior of this method when called for the first time depends on the parameters that were supplied at construction, as described below.
First, an object of a subclass of
RMIServerImpl
is required, to export the connector server through RMI:- If an
RMIServerImpl
was supplied to the constructor, it is used. - Otherwise, if the
JMXServiceURL
was null, or its protocol part wasrmi
, an object of typeRMIJRMPServerImpl
is created. - Otherwise, the implementation can create an
implementation-specific
RMIServerImpl
or it can throwMalformedURLException
.
If the given address includes a JNDI directory URL as specified in the package documentation for
javax.management.remote.rmi
, then thisRMIConnectorServer
will bootstrap by binding theRMIServerImpl
to the given address.If the URL path part of the
JMXServiceURL
was empty or a single slash (/
), then the RMI object will not be bound to a directory. Instead, a reference to it will be encoded in the URL path of the RMIConnectorServer address (returned bygetAddress()
). The encodings forrmi
are described in the package documentation forjavax.management.remote.rmi
.The behavior when the URL path is neither empty nor a JNDI directory URL, or when the protocol is not
rmi
, is implementation defined, and may include throwingMalformedURLException
when the connector server is created or when it is started.- Throws:
IllegalStateException
- if the connector server has not been attached to an MBean server.IOException
- if the connector server cannot be started.
- If an
-
stop
public void stop() throws IOException
Deactivates the connector server, that is, stops listening for client connections. Calling this method will also close all client connections that were made by this server. After this method returns, whether normally or with an exception, the connector server will not create any new client connections.
Once a connector server has been stopped, it cannot be started again.
Calling this method when the connector server has already been stopped has no effect. Calling this method when the connector server has not yet been started will disable the connector server object permanently.
If closing a client connection produces an exception, that exception is not thrown from this method. A
JMXConnectionNotification
is emitted from this MBean with the connection ID of the connection that could not be closed.Closing a connector server is a potentially slow operation. For example, if a client machine with an open connection has crashed, the close operation might have to wait for a network protocol timeout. Callers that do not want to block in a close operation should do it in a separate thread.
This method calls the method
close
on the connector server'sRMIServerImpl
object.If the
RMIServerImpl
was bound to a JNDI directory by thestart
method, it is unbound from the directory by this method.- Throws:
IOException
- if the server cannot be closed cleanly, or if theRMIServerImpl
cannot be unbound from the directory. When this exception is thrown, the server has already attempted to close all client connections, if appropriate; to callRMIServerImpl.close()
; and to unbind theRMIServerImpl
from its directory, if appropriate. All client connections are closed except possibly those that generated exceptions when the server attempted to close them.
-
isActive
public boolean isActive()
Description copied from interface:JMXConnectorServerMBean
Determines whether the connector server is active. A connector server starts being active when its
start
method returns successfully and remains active until either itsstop
method is called or the connector server fails.- Returns:
- true if the connector server is active.
-
getAddress
public JMXServiceURL getAddress()
Description copied from interface:JMXConnectorServerMBean
The address of this connector server.
The address returned may not be the exact original
JMXServiceURL
that was supplied when creating the connector server, since the original address may not always be complete. For example the port number may be dynamically allocated when starting the connector server. Instead the address returned is the actualJMXServiceURL
of theJMXConnectorServer
. This is the address that clients supply toJMXConnectorFactory.connect(JMXServiceURL)
.Note that the address returned may be
null
if theJMXConnectorServer
is not yetactive
.- Returns:
- the address of this connector server, or null if it does not have one.
-
getAttributes
public Map<String,?> getAttributes()
Description copied from interface:JMXConnectorServerMBean
The attributes for this connector server.
- Returns:
- a read-only map containing the attributes for this connector server. Attributes whose values are not serializable are omitted from this map. If there are no serializable attributes, the returned map is empty.
-
setMBeanServerForwarder
public void setMBeanServerForwarder(MBeanServerForwarder mbsf)
Description copied from interface:JMXConnectorServerMBean
Inserts an object that intercepts requests for the MBean server that arrive through this connector server. This object will be supplied as the
MBeanServer
for any new connection created by this connector server. Existing connections are unaffected.This method can be called more than once with different
MBeanServerForwarder
objects. The result is a chain of forwarders. The last forwarder added is the first in the chain. In more detail:If this connector server is already associated with an
MBeanServer
object, then that object is given tombsf.setMBeanServer
. If doing so produces an exception, this method throws the same exception without any other effect.If this connector is not already associated with an
MBeanServer
object, or if thembsf.setMBeanServer
call just mentioned succeeds, thenmbsf
becomes this connector server'sMBeanServer
.
- Specified by:
setMBeanServerForwarder
in interfaceJMXConnectorServerMBean
- Overrides:
setMBeanServerForwarder
in classJMXConnectorServer
- Parameters:
mbsf
- the newMBeanServerForwarder
.
-
connectionOpened
protected void connectionOpened(String connectionId, String message, Object userData)
Description copied from class:JMXConnectorServer
Called by a subclass when a new client connection is opened. Adds
connectionId
to the list returned byJMXConnectorServer.getConnectionIds()
, then emits aJMXConnectionNotification
with typeJMXConnectionNotification.OPENED
.- Overrides:
connectionOpened
in classJMXConnectorServer
- Parameters:
connectionId
- the ID of the new connection. This must be different from the ID of any connection previously opened by this connector server.message
- the message for the emittedJMXConnectionNotification
. Can be null. SeeNotification.getMessage()
.userData
- theuserData
for the emittedJMXConnectionNotification
. Can be null. SeeNotification.getUserData()
.
-
connectionClosed
protected void connectionClosed(String connectionId, String message, Object userData)
Description copied from class:JMXConnectorServer
Called by a subclass when a client connection is closed normally. Removes
connectionId
from the list returned byJMXConnectorServer.getConnectionIds()
, then emits aJMXConnectionNotification
with typeJMXConnectionNotification.CLOSED
.- Overrides:
connectionClosed
in classJMXConnectorServer
- Parameters:
connectionId
- the ID of the closed connection.message
- the message for the emittedJMXConnectionNotification
. Can be null. SeeNotification.getMessage()
.userData
- theuserData
for the emittedJMXConnectionNotification
. Can be null. SeeNotification.getUserData()
.
-
connectionFailed
protected void connectionFailed(String connectionId, String message, Object userData)
Description copied from class:JMXConnectorServer
Called by a subclass when a client connection fails. Removes
connectionId
from the list returned byJMXConnectorServer.getConnectionIds()
, then emits aJMXConnectionNotification
with typeJMXConnectionNotification.FAILED
.- Overrides:
connectionFailed
in classJMXConnectorServer
- Parameters:
connectionId
- the ID of the failed connection.message
- the message for the emittedJMXConnectionNotification
. Can be null. SeeNotification.getMessage()
.userData
- theuserData
for the emittedJMXConnectionNotification
. Can be null. SeeNotification.getUserData()
.
-
-