The manager application interacts with a connector client in order to access an agent through an established connection. Through its implementation of the RemoteMBeanServer interface, a connector client provides methods for handling the connection and for accessing the agent. This interface specifies nearly all of the same methods as the MBeanServer interface, meaning that an agent is fully manageable from a remote application.
Through the connector, the management application sends management requests to the MBeans located in a remote agent. Components of the management application access remote MBeans by calling the methods of the connector client for getting and setting attributes and invoking operations on the MBeans. The connector client then returns the result, providing a complete abstraction of the communication layer.
All connector clients implement the RemoteMBeanServer interface in order to expose the methods needed to access and manage the MBeans in a remote agent. This interface allows all management operations that would be possible directly in the agent application. In fact, the methods of the connector client for accessing MBeans remotely have exactly the same name and signature as their equivalent methods in the MBeanServer interface.
The following methods are defined identically in both the MBeanServer and the RemoteMBeanServer interfaces:
Table 8-1 The Set of Shared Methods[diams ] void | addNotificationListener(ObjectName name, NotificationListener listener, NotificationFilter filter, java.lang.Object handback) |
ObjectInstance | createMBean(*) - All four overloaded forms of this method |
[diams ] java.lang.Object | getAttribute(ObjectName name, java.lang.String attribute) |
[diams ] AttributeList | getAttributes(ObjectName name, java.lang.String[] attributes) |
java.lang.String | getDefaultDomain() |
java.lang.Integer | getMBeanCount() |
[diams ] MBeanInfo | getMBeanInfo(ObjectName name) |
ObjectInstance | getObjectInstance(ObjectName name) |
[diams ] java.lang.Object | invoke(ObjectName name, java.lang.String operationName, java.lang.Object[] params, java.lang.String[] signature) |
boolean | isInstanceOf(ObjectName name, java.lang.String className) |
boolean | isRegistered(ObjectName name) |
java.util.Set | queryMBeans(ObjectName name, QueryExp query) |
java.util.Set | queryNames(ObjectName name, QueryExp query) |
[diams ] void | removeNotificationListener(ObjectName name, NotificationListener listener) |
[diams ] void | setAttribute(ObjectName name, Attribute attribute) |
[diams ] AttributeList | setAttributes(ObjectName name, AttributeList attributes) |
[diams ] void | unregisterMBean(ObjectName name) |
[diams ] These methods are defined in the ProxyHandler interface; see the next topic: "Local and Remote Proxies".
Components of a management application which rely solely on this common subset of methods may be instantiated in either the agent or the manager application. Such components are location independent and may be reused either locally or remotely as managemement solutions evolve. This symmetry also allows the design of advanced management architectures where functionality may be deployed either in the agent or in the manager, depending on runtime conditions.
The other, unshared methods of the RemoteMBeanServer interface are used to establish and monitor the connection. In the following section, we will establish a connection and access MBeans directly through the connector client. In "The Heartbeat Mechanism", we will see how to monitor a connection and detect when it is lost.
The target of a connection is identified by a protocol-specific implementation of the ConnectorAddress interface. This object contains all the information that a connector client needs to establish a connection with the target agent. All address objects specify a host name and port number. An RMI address adds the required service name, and HTTP-based addresses have an optional authenication field (see "Password-Based Authentication"). In addition, the ConnectorType string identifies the protocol without needing to introspect the address object
In our example, the target of the connection is an active RMI connector server identified by an RmiConnectorAddress object. We use the default constructor to instantiate a default address object, but otherwise, these parameters can be specified in a constructor or through setter methods. The default values of the information contained in the RmiConnectorAddress object are the following:
The ConnectorType identifies the protocol that is used; its value is "SUN RMI" for the RmiConnectorAddress class.
The default RMI port is 1099, as given by the static variable RMI_CONNECTOR_PORT in the ServiceName class.
The Host is the name of the machine where the target agent is running; by default, its value is the localhost.
The Name attribute specifies the RMI registry service name of the adaptor server. Its default value is "name=RmiConnectorServer", which is the value of the RMI_CONNECTOR_SERVER static variable in the ServiceName class.
The RmiConnectorAddress object is used as the parameter to the connect method of the RmiConnectorClient instance. This method will try to establish the connection and will throw an exception if there is a communication or addressing error. Otherwise, when the connect method returns, the connector client will be ready to perform management operations on the designated agent.
echo("\t>> Instantiate the RMI connector client..."); connectorClient = new RmiConnectorClient(); echo("\t>> Instantiate a default RmiConnectorAddress object..."); RmiConnectorAddress address = new RmiConnectorAddress(); // display the default values echo("\t\tTYPE\t= " + address.getConnectorType()); echo("\t\tPORT\t= " + address.getPort()); echo("\t\tHOST\t= " + address.getHost()); echo("\t\tSERVER\t= " + address.getName()); echo("\t<< done <<"); echo("\t>> Connect the RMI connector client to the agent..."); try { connectorClient.connect( address ); } catch(Exception e) { echo("\t!!! RMI connector client could not connect to the agent !!!"); e.printStackTrace(); System.exit(1); } |
Once the connection to an agent is established, the management application can access that agent's MBeans through the RemoteMBeanServer interface of the connector client. Invoking these methods has exactly the same effect as invoking the equivalent methods directly on the MBean server instance.
It is possible to restrict access to certain methods of the MBean server when they are called through the connector client, but this is performed by a security mechanism in the connector server: see "Context Checking" for more details.
We use the createMBean method to instantiate and register an object from its class name. This class must already be available in the agent application's classpath, or you can use the createMBean method which takes the name of a class loader (see "M-Let Loading from a Manager (Java 2)" for more details).
private void doWithoutProxyExample(String mbeanName) { try { // build the MBean ObjectName instance // ObjectName mbeanObjectName = null; String domain = connectorClient.getDefaultDomain(); mbeanObjectName = new ObjectName( domain + ":type=" + mbeanName ); // create and register an MBean in the MBeanServer of the agent // echo("\nCurrent MBean count in the agent = "+ connectorClient.getMBeanCount()); echo("\n>>> CREATE the " + mbeanName + " MBean in the MBeanServer of the agent:"); String mbeanClassName = mbeanName; ObjectInstance mbeanObjectInstance = connectorClient.createMBean( mbeanClassName, mbeanObjectName ); echo("\tMBEAN CLASS NAME = " + mbeanObjectInstance.getClassName() ); echo("\tMBEAN OBJECT NAME = " + mbeanObjectInstance.getObjectName() ); echo("\nCurrent MBean count in the agent = "+ connectorClient.getMBeanCount() ); [...] // Retrieve MBeanInfo and access the MBean (see below) // unregister the MBean from the agent // echo("\n>>> UNREGISTERING the "+ mbeanName +" MBean"); connectorClient.unregisterMBean( mbeanObjectInstance.getObjectName() ); [...] } catch (Exception e) { e.printStackTrace(); } } |
The above sample shows the use of other calls to the remote agent, such as getDefaultDomain and getMBeanCount which have the same purpose as in an agent application.
Once you can access the object names for MBeans in the agent, you can know their management interface from their MBeanInfo object. The following code is actually called in between the MBean creation and deregistration shown in the previous code sample.
ObjectName mbeanObjectName = mbeanObjectInstance.getObjectName(); echo("\n>>> Getting the management information of the MBean"); MBeanInfo info = null; try { info = connectorClient.getMBeanInfo( mbeanObjectName ); } catch (Exception e) { echo("\t!!! Could not get MBeanInfo object for "+ mbeanObjectName ); e.printStackTrace(); return; } // display content of MBeanInfo object // echo("\nCLASSNAME: \t"+ info.getClassName()); echo("\nDESCRIPTION: \t"+ info.getDescription()); echo("\nATTRIBUTES"); MBeanAttributeInfo[] attrInfo = info.getAttributes(); if ( attrInfo.length>0 ) { for( int i=0; i<attrInfo.length; i++ ) { echo(" ** NAME: \t"+ attrInfo[i].getName()); echo(" DESCR: \t"+ attrInfo[i].getDescription()); echo(" TYPE: \t"+ attrInfo[i].getType() + "\tREAD: "+ attrInfo[i].isReadable() + "\tWRITE: "+ attrInfo[i].isWritable()); } } else echo(" ** No attributes **"); [...] |
It is then straightforward to perform management operations on MBeans through the connector client. As in an agent, we call the generic getters, setters and invoke methods with the object name of the MBean, the name of the attribute or operation, and any parameters. As in the methods of the MBean server, we need to use the Attribute and AttributeList classes to pass attributes as name-value pairs.
try { // Getting attribute values String State = (String) connectorClient.getAttribute( mbeanObjectName, "State" ); Integer NbChanges = (Integer) connectorClient.getAttribute( mbeanObjectName, "NbChanges" ); echo("\tState = \"" + State + "\""); echo("\tNbChanges = " + NbChanges); // Setting the "State" attribute Attribute stateAttr = new Attribute("State", "new state from client"); connectorClient.setAttribute(mbeanObjectName, stateAttr); // Invoking the "reset" operation Object[] params = new Object[0]; String[] signature = new String[0]; connectorClient.invoke(mbeanObjectName, "reset", params, signature); } catch (Exception e) { e.printStackTrace(); return; } |
All other MBean access methods are available in the same manner, such as bulk getters and setters, and the query methods.
In the first run of the example, the management application creates, manages and deregisters a standard MBean in the remote agent. However, standard and dynamic MBeans are designed to be managed through the same methods, both in the MBeanServer and in the RemoteMBeanServer interfaces.
As shown in Example 8-4, the subroutine of the example application takes only a single class name parameter. The first time this subroutine is called, the example passes the class name of a standard MBean, and the second time, that of a dynamic MBean. For the example to run, the two MBeans must have an identical management interface. By extension of this special case, we see that the connector client can manage dynamic MBeans through the same methods as it manages standard MBeans, without making any distinction between the two.
The examplesDir/SimpleClients directory contains all of the files for three sample managers, a base agent, and some MBeans to manage. In this topic, we run the ClientWithoutProxy application which demonstrates simple operations on MBeans through an RMI connector.
Compile all files in this directory with the javac command. For example, on the Solaris platform with the Korn shell, you would type:
$ cd examplesDir/SimpleClients/ $ javac -classpath classpath *.java |
We will not need all the files for this topic, but they will be used in the next topic, "MBean Proxy Objects". In this demonstration, we only need the BaseAgent and ClientWithoutProxy applications, as well as the standard and dynamic MBeans.
Launch the agent in another terminal window on the same host with the following command:
$ java -classpath classpath BaseAgent |
The agent creates an HTML protocol adaptor and an RMI connector server to which the client application will establish a connection, and then it waits for management operations.
Wait for the agent to be completely initialized, then launch the manager with the following command:
$ java -classpath classpath ClientWithoutProxy |
The client application creates the RMI connector client and establishes the connection to base agent.
Press <Enter> in the manager window to step through the example.
The management application instantiates both types of MBeans, looks at their metadata, and performs management operations on them. The results of each step are displayed in the terminal window.
At any time, you can view the agent through its HTML adaptor and interact with the MBeans created by the management application.
For example, immediately after the manager creates an MBean, you could modify its attributes and see this change reflected when the connector client access the new values.
Press <Enter> in both windows to stop the agent and manager applications.