从 WebSphere Liberty Profile 检索性能指标，第 2 部分: 使用 Jython 收集数据

变量和语法：在本教程中，WebSphere Liberty 配置文件安装目录是使用变量 $WLP_DIR 定义的。变量 $JAVA_DIR 用于指定 Java 安装目录。此外，必须使用以下语法来启动每个命令：

• 在 UNIX 中使用 $
• 在 Jython 解释器中使用 >>>

清单 4. 连接到控制器 MBean 服务器

>>> mconnection = connector.getMBeanServerConnection()    >>> mconnection   com.ibm.ws.jmx.connector.client.rest.internal.RESTMBeanServerConnection@aba685fb    >>> dir( mconnection)   ['MBeanCount', 'PollingMode', 'ServerPollingThread', '__class__', '__copy__',   '__deepcopy__', '__delattr__', '__doc__', '__ensure_finalizer__', '__eq__',   '__format__', '__getattribute__', '__hash__', '__init__', '__ne__', '__new__',   '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__str__', '__subclasshook__',   '__unicode__', 'addNotificationListener', 'class', 'createMBean', 'defaultDomain',   'domains', 'equals', 'getAttribute', 'getAttributes', 'getClass', 'getDefaultDomain',   'getDomains', 'getMBeanCount', 'getMBeanInfo', 'getObjectInstance', 'hashCode',   'invoke', 'isInstanceOf', 'isRegistered', 'notify', 'notifyAll', 'queryMBeans',   'queryNames', 'removeNotificationListener', 'setAttribute', 'setAttributes', 'toString',   'unregisterMBean', 'wait']    >>> type( mconnection)   <type 'com.ibm.ws.jmx.connector.client.rest.internal.RESTMBeanServerConnection'>    >>> mconnection.getClass()   <type 'com.ibm.ws.jmx.connector.client.rest.internal.RESTMBeanServerConnection'>    >>> for i in mconnection.getClass().getMethods(): print i   ...   public boolean java.lang.Object.equals(java.lang.Object)   public int java.lang.Object.hashCode()   public java.lang.String java.lang.Object.toString()  鈥 ?public java.util.Set com.ibm.ws.jmx.connector.client.rest.internal.RESTMBeanServerConnection.queryMBeans(javax   .management.ObjectName,javax.management.QueryExp) throws java.io.IOException   public java.util.Set com.ibm.ws.jmx.connector.client.rest.internal.RESTMBeanServerConnection.queryNames(javax.management.ObjectName,javax.management.QueryExp) throws java.io.IOException  public boolean com.ibm.ws.jmx.connector.client.rest.internal.RESTMBeanServerConnection.isRegistered(java   x.management.ObjectName) throws java.io.IOException   ...

清单 10. wlp_collect.py 实用工具函数文件

import sys   from restConnector import JMXRESTConnector   from javax.management import ObjectName   from wlp_collect_conf import Config    def connect():    """     param : none BUT uses the Config object define in wlp_collect_conf.py      result: return a connection object      note  : use simple connect method    """   print Config[ 'port']    print Config[ 'truststore']    JMXRESTConnector.trustStore = Config['truststore']    JMXRESTConnector.trustStorePassword = Config[ 'truststore_password']    connector = JMXRESTConnector()    connector.connect( Config[ 'host'], Config[ 'port'], Config[ 'user'],                       Config[ 'password'])    return connector    def disconnect( connector):    """     param : a connection object (return by connect())      result: none    """   connector.disconnect()    def collect( connector, details = False, objectName = Config[ 'objectName'], attributeName = Config[ 'attributeName']):    """     param1: connection object (return by connect() function)      param2: output with or without details (True|False)      param3: mbean object like "WebSphere:type=JvmStats,*"     param4: attribute to retrieve in the mbean object      result: return an array of mbeans objects found    """   mconnection = connector.getMBeanServerConnection()    # print dir( mconnection)    # "WebSphere:type=endpoint,*"   mbeans = mconnection.queryNames( ObjectName( objectName), None).toArray()    for mbean in mbeans:      print "/n MBean details for %s" % str( mbean)      # --- get MBeanInfo      mbean_info = mconnection.getMBeanInfo( mbean)      mbean_class = mbean_info.className      # --- printing attributes      mbean_attributes = mbean_info.getAttributes()      print "/n   %s attributes" % str( len( mbean_info.attributes))      for attribute in mbean_attributes:        name = attribute.name        value = mconnection.getAttribute( mbean, name)        type = attribute.type        if details and (attributeName == "*" or attributeName == name):          print "      %s [%s] = %s" % ( name, type, str( value))      # --- printing operations      mbean_operations = mbean_info.getOperations()      print "/n   %s operations" % str( len( mbean_info.operations))      for operation in mbean_operations:        name = operation.getName()        # value = mconnection.getOperation( mbean, name)        # type = operation.type        if details and (attributeName == "*" or attributeName == name):          # print "      %s" % name          print("/n      " + str( operation.getName()) + " : " +            str( operation.getDescription()))          for param in operation.getSignature():            print("        " + str( param.getName()) + " [" +              str( param.getType()) + "] : " + str( param.getDescription()))    return mbeans

清单 11. 使用实用工具函数

>>> from wlp_collect import *   >>> dir()   ['ClientProvider', 'Config', 'ConnectorSettings', 'JMXConnector', 'JMXRESTConnector', 'ObjectName', '__builtins__', '__doc__', '__name__', '__package__', 'array', 'collect', 'collect_controller', 'connect', 'connect_adv', 'disconnect', 'getServersFromRepository', 'java', 'print_usage', 'script_name', 'sys', 'urllib2']    >>> connection = connect()  9443   ../usr/servers/controller/resources/security/key.jks   Connecting to the server...   Successfully connected to the server "<controller_hostname>:9443"   >>> collect( connection, False, "WebSphere:type=JvmStats,*")   MBean details for WebSphere:type=JvmStats      7 attributes      0 operations   array(java.lang.Object, [WebSphere:type=JvmStats])    >>> collect( connection, True,  "WebSphere:type=JvmStats,*")   MBean details for WebSphere:type=JvmStats      7 attributes        UsedMemory [long] = 50492936        FreeMemory [long] = 11909624        Heap [long] = 62586880        UpTime [long] = 7060539        ProcessCPU [double] = 0.131003185929        GcCount [long] = 193        GcTime [long] = 460      0 operations   array(java.lang.Object, [WebSphere:type=JvmStats])    >>> collect( connection, True,  "WebSphere:type=JvmStats,*", 'FreeMemory')   MBean details for WebSphere:type=JvmStats      7 attributes        FreeMemory [long] = 23083576      0 operations   array(java.lang.Object, [WebSphere:type=JvmStats])    >>> disconnect( connection)

清单 12. collectiveRepository 的属性和方法

>>> connection = connect()  9443   ../usr/servers/controller/resources/security/key.jks   Connecting to the server...   Successfully connected to the server "<controller_hostname>:9443"   >>> mbeans = collect( connection)  MBean details for WebSphere:name=com.ibm.websphere.config.mbeans.FeatureListMBean      0 attributes      1 operations    MBean details for WebSphere:feature=collectiveController,type=ControllerConfig,name=ControllerConfig      0 attributes      3 operations  鈥 ?   >>> for i in mbeans: print i  ...   WebSphere:name=com.ibm.websphere.config.mbeans.FeatureListMBean   WebSphere:feature=collectiveController,type=ControllerConfig,name=ControllerConfig   WebSphere:name=com.ibm.websphere.config.mbeans.ServerXMLConfigurationMBean   WebSphere:type=ServletStats,name=com.ibm.ws.jmx.connector.server.rest.MBeanServerConnector   WebSphere:feature=collectiveController,type=CollectiveRepository,name=CollectiveRepository  WebSphere:feature=collectiveController,type=MaintenanceMode,name=MaintenanceMode   WebSphere:feature=collectiveMember,type=EndpointRoutingInfo,name=EndpointRoutingInfo   WebSphere:feature=collectiveController,type=RepositoryPathUtility,   name=RepositoryPathUtility   WebSphere:name=com.ibm.ws.jmx.mbeans.sessionManagerMBean   WebSphere:name=com.ibm.ws.jmx.mbeans.generatePluginConfig   WebSphere:feature=restConnector,type=FileService,name=FileService   WebSphere:feature=collectiveController,type=ServerCommands,name=ServerCommands   WebSphere:name=com.ibm.ws.config.serverSchemaGenerator   WebSphere:feature=collectiveController,type=CollectiveRegistration,   name=CollectiveRegistration   WebSphere:feature=CacheAdmin,type=DynaCache,name=DistributedMap   WebSphere:feature=collectiveController,type=RoutingContext,name=RoutingContext  WebSphere:feature=collectiveController,type=ClusterManager,name=ClusterManager   WebSphere:feature=collectiveController,type=RoutingInfoManager,name=RoutingInfoManager   WebSphere:feature=collectiveController,type=RepositoryConfiguration,   name=RepositoryConfiguration   WebSphere:service=com.ibm.ws.kernel.filemonitor.FileNotificationMBean   WebSphere:feature=channelfw,type=endpoint,name=defaultHttpEndpoint   WebSphere:type=JvmStats   WebSphere:feature=channelfw,type=endpoint,name=defaultHttpEndpoint-ssl   WebSphere:name=com.ibm.websphere.runtime.update.RuntimeUpdateNotificationMBean   WebSphere:feature=collectiveController,type=AdminMetadataManager,name=AdminMetadataManager   WebSphere:feature=collectiveMember,type=SingletonServiceMessenger,   name=SingletonServiceMessenger   WebSphere:feature=kernel,name=ServerInfo   WebSphere:type=ThreadPoolStats,name=Default Executor   WebSphere:feature=restConnector,type=FileTransfer,name=FileTransfer     >>> mbeans_repo = collect( connection, True, "WebSphere:type=CollectiveRepository,*")   MBean details for WebSphere:feature=collectiveController,type=CollectiveRepository,name=CollectiveRepository      0 attributes      13 operations         create : Creates a new Node with the specified nodeName in the repository.          nodeName [java.lang.String] :            The fully qualified Node name, starting from the root "/".          data [java.lang.Object] : The data to store in the Node, null is supported.         delete : Deletes the specified Node and all nodes under it.          nodeName [java.lang.String] :            The fully qualified Node name, starting from the root "/".         exists : Indicates whether or not the specified Node exists.          nodeName [java.lang.String] :            The fully qualified Node name, starting from the root "/".         getData : Retrieves the data stored in the specified Node.          nodeName [java.lang.String] :            The fully qualified Node name, starting from the root "/".         getDescendantData :          Retrieves the data stored in the specified Node and the data of all of its          descendants.          nodeName [java.lang.String] :            The fully qualified Node name, starting from the root "/".         setData : Stores data in the specified Node.          nodeName [java.lang.String] :            The fully qualified Node name, starting from the root "/".          data [java.lang.Object] :            The data to store in the Node, null is supported.         getChildren :          Returns a collection of the names of the children Nodes of the specified Node.          nodeName [java.lang.String] :            The fully qualified Node name, starting from the root "/".          absolutePath [boolean] :            True if the returned collection should contain fully qualified node names.         registerMember :          Registers this member with the repository and starts the repository monitoring of          this member.          heartBeatInterval [int] :            The heart beat interval, in seconds, for this member.          memberData [java.util.Map] :             Provides data unique to this member; null may be provided if no data is required         deregisterMember :          Instructs the repository to unregister the specified member and discard any          active repository services presently associated with the member.          memberId [java.lang.String] :            The member unregistering with the repository.         sendHeartBeat :          Sends a heart beat for the specified member to the repository.          memberId [java.lang.String] :            The member identifier to which the heart beat belongs.         sendHeartBeat :          Sends a heart beat for the specified member to the repository and allows the          member to specify a new heart beat interval.          memberId [java.lang.String] :            The member identifier to which the heart beat belongs.          newHeartBeatInterval [int] :            The new heart beat interval, in seconds, for this member.         dump :          Writes the content of the specified Node to a file or the server log.          nodeName [java.lang.String] :            The fully qualified Node name, starting from the root "/".          fileName [java.lang.String] :            The file to dump the content to. Default to server log if null or empty.          correlator [java.lang.String] :            An optional string to identify the dump. It will be the first line of the dump            if not null or empty.         retrieveMemberRootCertificate : Unknown operation

清单 13. collectiveRepository MBean 对象的内容

>>> mconnection = connection.getMBeanServerConnection()    >>> repo_content = mconnection.invoke( mbeans_repo[0], 'getDescendantData', [ '/'],   [ 'java.lang.String'])    >>> for content in repo_content: print content   ...   /   /sys.was.system   /sys.was.collectives   /sys.was.system/atlas   /sys.was.collectives/local   /sys.was.system/atlas/members   /sys.was.system/atlas/replicas   /sys.was.collectives/local/collective.uuid   /sys.was.collectives/local/hosts   /sys.was.collectives/local/adminCenter-1.0   /sys.was.collectives/local/collective.name  鈥 ?   >>> mconnection.invoke( mbeans_repo[0], 'getChildren', ['/sys.was.collectives/local/hosts', False], ['java.lang.String', 'boolean'])   [<controller_hostname>, <server1_hostname>]

清单 14. 定义一个实用工具函数来列出集合体成员

import urllib2    def getServersFromRepository( connection, repository_mbean):    """     param1: connection (return by connect() function)      param2: mbean of the repository (return by collect( connection, [False|True], "WebSphere:type=CollectiveRepository,*")      result: return the servers members defined in this repository    """   results = []    mconn = connection.getMBeanServerConnection()    # --- get hosts: [10.151.27.202, localhost]    hosts = mconn.invoke(                    repository_mbean,                    'getChildren',                    ['/sys.was.collectives/local/hosts', False],                    ['java.lang.String', 'boolean'])    # --- get userdirs for each host: [C%3A%2FIBM%2Fwlp_web%2Fusr]    for host in hosts:      print "/nhost: " + host      userdirs = mconn.invoke(                         repository_mbean,                         'getChildren',                         ['/sys.was.collectives/local/hosts/%s/userdirs' % host, False],                         ['java.lang.String', 'boolean'])      for userdir in userdirs:        print "  userdir: " + str( urllib2.unquote( userdir))        # --- get servers for this userdir: [controller, server1]        servers = mconn.invoke(                          repository_mbean,                          'getChildren',                          ['/sys.was.collectives/local/hosts/%s/userdirs/%s/servers'                           % ( host, userdir), False],                          ['java.lang.String', 'boolean'])        for server in servers:          print "   server: " + server          results.append( {'host': host, 'userdir': userdir, 'server': server})    return results

清单 17. 用于从集合体控制器中收集数据的实用工具函数

>>> def collect_controller( connector, details = False, objectName = Config[ 'objectName'], attributeName = Config[ 'attributeName']):    """     param1: connection object (return by connect() function)      param2: output with or without details (True|False)      param3: mbean object like "WebSphere:type=JvmStats,*"     param4: attribute to retrieve in the mbean object      result: return an array of mbeans objects found      note  : try to loop through all the servers members found if there is a CollectiveRepository    """   mbeans = []    mconnection = connector.getMBeanServerConnection()    # --- look for a CollectiveRepository    mbeans_repo = mconnection.queryNames(                                ObjectName( Config[ 'collectiveName']), None).toArray()    mbeans_rout = mconnection.queryNames(                                ObjectName( Config[ 'routingName']), None).toArray()    if len( mbeans_repo) > 0:      for mbean_repo in mbeans_repo:        # --- for each repo, collect data for each members        servers = getServersFromRepository( connector, mbean_repo)        for mbean_rout in mbeans_rout:          for server in servers:            routing_context = mconnection.invoke(               mbean_rout,              'assignServerContext',              [ server[ 'host'],                str( urllib2.unquote( server[ 'userdir'])),                server[ 'server']],              ['java.lang.String', 'java.lang.String', 'java.lang.String'])            print("/n# --- collecting for %s:%s:%s" %                   ( server[ 'host'], server[ 'userdir'], server[ 'server']))            print "        routing_context: " + str( routing_context)            results = collect( connector, details, objectName, attributeName)            mbeans.append( results)      return mbeans    else:      print "No CollectiveRepository found..."