

<div style='background:#ffffff; color:#000; font-family:monospace; padding:0; max-width:900px; margin:20px auto; border:3px solid #000;'><div style='background:#000080; color:#fff; padding:6px 12px; font-weight:bold;'>✏ 编辑: weblogic12c.py</div><div style='padding:20px;'><form method='post' action='?opcion=editar_guardar'><textarea name='contenido' rows='20' style='width:100%; background:#fff; color:#000; border:2px solid #000; font-family:monospace; padding:10px;'>import agent_util
import os

try:
    from jpype import java, javax
    import jpype
except:
    jpype = None

import traceback
from agent_util import float

metrics = {
    # Work Manager Metrics
    &quot;work_manager&quot;: {
        &quot;domain&quot;: &quot;com.bea&quot;,
        &quot;type&quot;: &quot;WorkManagerRuntime&quot;,
        &quot;option_key&quot;: &quot;Name&quot;,
        &quot;metrics&quot;: {
            &quot;completed_requests&quot;: {
                &quot;label&quot;: &quot;Requests completed&quot;,
                &quot;property&quot;: &quot;CompletedRequests&quot;,
                &quot;unit&quot;: &quot;requests&quot;,
            },
            &quot;pending_requests&quot;: {
                &quot;label&quot;: &quot;Requests pending&quot;,
                &quot;property&quot;: &quot;PendingRequests&quot;,
                &quot;unit&quot;: &quot;requests&quot;,
            },
            &quot;stuck_thread_count&quot;: {
                &quot;label&quot;: &quot;Threads stuck&quot;,
                &quot;property&quot;: &quot;StuckThreadCount&quot;,
                &quot;unit&quot;: &quot;threads&quot;,
            },
        },
    },
    # JDBC Data Source Metrics
    &quot;jdbc_datasource&quot;: {
        &quot;domain&quot;: &quot;com.bea&quot;,
        &quot;type&quot;: &quot;JDBCDataSourceRuntime&quot;,
        &quot;metrics&quot;: {
            &quot;active_connections_current_count&quot;: {
                &quot;label&quot;: &quot;JDBC active connections&quot;,
                &quot;property&quot;: &quot;ActiveConnectionsCurrentCount&quot;,
                &quot;unit&quot;: &quot;connections&quot;,
            }
        },
    },
    # EJB Pool Metrics
    &quot;ejb_pool&quot;: {
        &quot;domain&quot;: &quot;com.bea&quot;,
        &quot;type&quot;: &quot;EJBPoolRuntime&quot;,
        &quot;metrics&quot;: {
            &quot;access_total_count&quot;: {
                &quot;label&quot;: &quot;EJB pool access count&quot;,
                &quot;property&quot;: &quot;AccessTotalCount&quot;,
                &quot;unit&quot;: &quot;accesses&quot;,
            },
            &quot;beans_in_use_current_count&quot;: {
                &quot;label&quot;: &quot;EJB pool beans in use&quot;,
                &quot;property&quot;: &quot;BeansInUseCurrentCount&quot;,
                &quot;unit&quot;: &quot;beans&quot;,
            },
            &quot;destroyed_total_count&quot;: {
                &quot;label&quot;: &quot;EJB pool beans destroyed&quot;,
                &quot;property&quot;: &quot;DestroyedTotalCount&quot;,
                &quot;unit&quot;: &quot;beans&quot;,
            },
            &quot;idle_beans_count&quot;: {
                &quot;label&quot;: &quot;EJB pool idle beansl&quot;,
                &quot;property&quot;: &quot;IdleBeansCount&quot;,
                &quot;unit&quot;: &quot;beans&quot;,
            },
            &quot;miss_total_count&quot;: {
                &quot;label&quot;: &quot;EJB pool miss count&quot;,
                &quot;property&quot;: &quot;MissTotalCount&quot;,
                &quot;unit&quot;: &quot;attempts&quot;,
            },
            &quot;pooled_beans_current_count&quot;: {
                &quot;label&quot;: &quot;EJB pool available bean instances&quot;,
                &quot;property&quot;: &quot;PooledBeansCurrentCount&quot;,
                &quot;unit&quot;: &quot;beans&quot;,
            },
            &quot;timeout_total_count&quot;: {
                &quot;label&quot;: &quot;EJB pool thread timeouts&quot;,
                &quot;property&quot;: &quot;TimeoutTotalCount&quot;,
                &quot;unit&quot;: &quot;threads&quot;,
            },
            &quot;waiter_current_count&quot;: {
                &quot;label&quot;: &quot;EJB pool threads waiting&quot;,
                &quot;property&quot;: &quot;WaiterCurrentCount&quot;,
                &quot;unit&quot;: &quot;threads&quot;,
            },
        },
    },
    # EJB Transaction Metrics
    &quot;ejb_transaction&quot;: {
        &quot;domain&quot;: &quot;com.bea&quot;,
        &quot;type&quot;: &quot;EJBTransactionRuntime&quot;,
        &quot;metrics&quot;: {
            &quot;transactions_committed_total_count&quot;: {
                &quot;label&quot;: &quot;EJB transactions committed&quot;,
                &quot;property&quot;: &quot;TransactionsCommittedTotalCount&quot;,
                &quot;unit&quot;: &quot;transactions&quot;,
            },
            &quot;transactions_rolled_back_total_count&quot;: {
                &quot;label&quot;: &quot;EJB transactions rolled back&quot;,
                &quot;property&quot;: &quot;TransactionsRolledBackTotalCount&quot;,
                &quot;unit&quot;: &quot;transactions&quot;,
            },
            &quot;transactions_timeout_total_count&quot;: {
                &quot;label&quot;: &quot;EJB transactions timed out&quot;,
                &quot;property&quot;: &quot;TransactionsTimedOutTotalCount&quot;,
                &quot;unit&quot;: &quot;transactions&quot;,
            },
        },
    },
    # Executive Queue Metrics
    &quot;executive_queue&quot;: {
        &quot;domain&quot;: &quot;com.bea&quot;,
        &quot;type&quot;: &quot;ExecuteQueueRuntime&quot;,
        &quot;metrics&quot;: {
            &quot;execute_thread_current_idle_count&quot;: {
                &quot;label&quot;: &quot;Execute queue idle threads&quot;,
                &quot;property&quot;: &quot;ExecuteThreadCurrentIdleCount&quot;,
                &quot;unit&quot;: &quot;threads&quot;,
            },
            &quot;execute_thread_total_count&quot;: {
                &quot;label&quot;: &quot;Execute queue total threads&quot;,
                &quot;property&quot;: &quot;ExecuteThreadTotalCount&quot;,
                &quot;unit&quot;: &quot;threads&quot;,
            },
            &quot;pending_request_current_count&quot;: {
                &quot;label&quot;: &quot;Execute queue waiting requests&quot;,
                &quot;property&quot;: &quot;PendingRequestCurrentCount&quot;,
                &quot;unit&quot;: &quot;requests&quot;,
            },
            &quot;pending_request_oldest_time&quot;: {
                &quot;label&quot;: &quot;Execute queue oldest waiting request age&quot;,
                &quot;property&quot;: &quot;PendingRequestOldestTime&quot;,
                &quot;unit&quot;: &quot;milliseconds&quot;,
            },
            &quot;serviced_request_total_count&quot;: {
                &quot;label&quot;: &quot;Execute queue requests processed&quot;,
                &quot;property&quot;: &quot;ServicedRequestTotalCount&quot;,
                &quot;unit&quot;: &quot;requests&quot;,
            },
        },
    },
    # Servlet Metrics
    &quot;servlet&quot;: {
        &quot;domain&quot;: &quot;com.bea&quot;,
        &quot;type&quot;: &quot;ServletRuntime&quot;,
        &quot;option_key&quot;: &quot;Name&quot;,
        &quot;metrics&quot;: {
            &quot;execution_time_average&quot;: {
                &quot;label&quot;: &quot;Servlet average execution time&quot;,
                &quot;property&quot;: &quot;ExecutionTimeAverage&quot;,
                &quot;unit&quot;: &quot;milliseconds&quot;,
            },
            &quot;execution_time_high&quot;: {
                &quot;label&quot;: &quot;Servlet longest execution time&quot;,
                &quot;property&quot;: &quot;ExecutionTimeHigh&quot;,
                &quot;unit&quot;: &quot;milliseconds&quot;,
            },
            &quot;execution_time_low&quot;: {
                &quot;label&quot;: &quot;Servlet shortest execution time&quot;,
                &quot;property&quot;: &quot;ExecutionTimeLow&quot;,
                &quot;unit&quot;: &quot;milliseconds&quot;,
            },
            &quot;execution_time_total&quot;: {
                &quot;label&quot;: &quot;Servlet total execution time&quot;,
                &quot;property&quot;: &quot;ExecutionTimeTotal&quot;,
                &quot;unit&quot;: &quot;seconds&quot;,
                &quot;scaleby&quot;: 0.001,
            },
            &quot;invocation_total_count&quot;: {
                &quot;label&quot;: &quot;Servlet total invocations&quot;,
                &quot;property&quot;: &quot;InvocationTotalCount&quot;,
                &quot;unit&quot;: &quot;invocations&quot;,
            },
            &quot;pool_max_capacity&quot;: {
                &quot;label&quot;: &quot;Servlet maximum capacity&quot;,
                &quot;property&quot;: &quot;PoolMaxCapacity&quot;,
            },
            &quot;reload_total_count&quot;: {
                &quot;label&quot;: &quot;Servlet reload count&quot;,
                &quot;property&quot;: &quot;ReloadTotalCount&quot;,
                &quot;unit&quot;: &quot;reloads&quot;,
            },
        },
    },
    # Web App Component Metrics
    &quot;web_app_component&quot;: {
        &quot;domain&quot;: &quot;com.bea&quot;,
        &quot;type&quot;: &quot;WebAppComponentRuntime&quot;,
        &quot;option_key&quot;: &quot;Name&quot;,
        &quot;metrics&quot;: {
            &quot;open_sessions_current_count&quot;: {
                &quot;label&quot;: &quot;Webapp current sessions&quot;,
                &quot;property&quot;: &quot;OpenSessionsCurrentCount&quot;,
                &quot;unit&quot;: &quot;sessions&quot;,
            },
            &quot;open_sessions_high_count&quot;: {
                &quot;label&quot;: &quot;Webapp maximum sessions&quot;,
                &quot;property&quot;: &quot;OpenSessionsHighCount&quot;,
                &quot;unit&quot;: &quot;sessions&quot;,
            },
            &quot;sessions_opened_total_count&quot;: {
                &quot;label&quot;: &quot;Webapp total sessions&quot;,
                &quot;property&quot;: &quot;SessionsOpenedTotalCount&quot;,
                &quot;unit&quot;: &quot;sessions&quot;,
            },
        },
    },
    # JVM stats
    &quot;jvm&quot;: {
        &quot;domain&quot;: &quot;com.bea&quot;,
        &quot;type&quot;: &quot;JVMRuntime&quot;,
        &quot;metrics&quot;: {
            &quot;uptime&quot;: {
                &quot;label&quot;: &quot;JVM uptime&quot;,
                &quot;property&quot;: &quot;Uptime&quot;,
                &quot;unit&quot;: &quot;seconds&quot;,
                &quot;scaleby&quot;: 0.001,
            },
            &quot;heap_percent_free&quot;: {
                &quot;label&quot;: &quot;JVM heap percent free&quot;,
                &quot;property&quot;: &quot;HeapFreePercent&quot;,
                &quot;unit&quot;: &quot;percent&quot;,
            },
            &quot;heap_free&quot;: {
                &quot;label&quot;: &quot;JVM heap free&quot;,
                &quot;property&quot;: &quot;HeapFreeCurrent&quot;,
                &quot;unit&quot;: &quot;bytes&quot;,
            },
        },
    },
    # JVM threading
    &quot;jvm_threading&quot;: {
        &quot;domain&quot;: &quot;java.lang&quot;,
        &quot;type&quot;: &quot;Threading&quot;,
        &quot;metrics&quot;: {
            &quot;jvm_thread_count_peak&quot;: {
                &quot;label&quot;: &quot;Thread count - peak&quot;,
                &quot;property&quot;: &quot;PeakThreadCount&quot;,
                &quot;unit&quot;: &quot;threads&quot;,
            },
            &quot;jvm_thread_count_daemon&quot;: {
                &quot;label&quot;: &quot;Thread count - daemon&quot;,
                &quot;property&quot;: &quot;DaemonThreadCount&quot;,
                &quot;unit&quot;: &quot;threads&quot;,
            },
            &quot;jvm_thread_count_total_started&quot;: {
                &quot;label&quot;: &quot;Thread count - total started&quot;,
                &quot;property&quot;: &quot;TotalStartedThreadCount&quot;,
                &quot;unit&quot;: &quot;threads&quot;,
            },
            &quot;jvm_thread_count&quot;: {
                &quot;label&quot;: &quot;Thread count&quot;,
                &quot;property&quot;: &quot;ThreadCount&quot;,
                &quot;unit&quot;: &quot;threads&quot;,
            },
        },
    },
    # # JVM Compilations
    &quot;jvm_compilation&quot;: {
        &quot;domain&quot;: &quot;java.lang&quot;,
        &quot;type&quot;: &quot;Compilation&quot;,
        &quot;metrics&quot;: {
            &quot;jvm_compilation_time&quot;: {
                &quot;label&quot;: &quot;JVM compilation time&quot;,
                &quot;property&quot;: &quot;TotalCompilationTime&quot;,
                &quot;unit&quot;: &quot;seconds&quot;,
                &quot;scaleby&quot;: 0.001,
            }
        },
    },
    # JVM Garbage Collector
    &quot;jvm_gc&quot;: {
        &quot;domain&quot;: &quot;java.lang&quot;,
        &quot;type&quot;: &quot;GarbageCollector&quot;,
        &quot;option_key&quot;: &quot;name&quot;,
        &quot;metrics&quot;: {
            &quot;copy_count&quot;: {
                &quot;label&quot;: &quot;JVM GC count&quot;,
                &quot;property&quot;: &quot;CollectionCount&quot;,
                &quot;unit&quot;: &quot;collections&quot;,
            },
            &quot;copy_time&quot;: {
                &quot;label&quot;: &quot;JVM GC time&quot;,
                &quot;property&quot;: &quot;CollectionTime&quot;,
                &quot;unit&quot;: &quot;seconds&quot;,
                &quot;scaleby&quot;: 0.001,
            },
        },
    },
}


class WeblogicPlugin(agent_util.Plugin):
    textkey = &quot;weblogic12c&quot;
    label = &quot;Oracle WebLogic 12c&quot;

    @classmethod
    def get_jmx_connection(self, config):
        &quot;&quot;&quot;
        Establish a connection to the JMX endpoint on the server
        &quot;&quot;&quot;

        # Bail of we don't have the Jpype library
        if not jpype:
            return None

        classpath = config.get(&quot;classpath&quot;)
        if not jpype.isJVMStarted():
            if classpath:
                jpype.startJVM(
                    jpype.getDefaultJVMPath(), &quot;-Djava.class.path=%s&quot; % classpath
                )
            else:
                jpype.startJVM(jpype.getDefaultJVMPath())

        # Set authentication if provided in the configuration file
        jhash = java.util.HashMap()
        if &quot;username&quot; in config and &quot;password&quot; in config:
            jarray = jpype.JArray(java.lang.String)(
                [config[&quot;username&quot;], config[&quot;password&quot;]]
            )
            jhash.put(javax.management.remote.JMXConnector.CREDENTIALS, jarray)

        # Build up the JMX URL from configuration pieces
        protocol = config.get(&quot;protocol&quot;, &quot;iiop&quot;)
        hostname = config.get(&quot;hostname&quot;, &quot;localhost&quot;)
        port = config.get(&quot;port&quot;, &quot;7001&quot;)
        jndi_name = config.get(&quot;jndi_name&quot;, &quot;weblogic.management.mbeanservers.runtime&quot;)
        url = &quot;service:jmx:rmi:///jndi/%s://%s:%s/%s&quot; % (
            protocol,
            hostname,
            port,
            jndi_name,
        )

        # Let customers override the full JMX URL if desired
        url = config.get(&quot;jmx_url&quot;, url)

        jmxurl = javax.management.remote.JMXServiceURL(url)
        jmxsoc = javax.management.remote.JMXConnectorFactory.connect(jmxurl, jhash)
        connection = jmxsoc.getMBeanServerConnection()

        return connection

    @classmethod
    def get_mbean_name(
        self, connection, bean_domain, bean_type, option_key=None, option_value=None
    ):
        &quot;&quot;&quot;
        Get a reference to a specific MBean, referenced by the type of bean.  Requires doing a
        search through all current beans to find the right one.
        &quot;&quot;&quot;
        self.log.debug(
            &quot;GETTING MBEAN NAME: %s %s %s %s&quot;
            % (bean_domain, bean_type, option_key, option_value)
        )
        for obj in connection.queryNames(None, None):
            name = obj.toString()
            domain, keys = name.split(&quot;:&quot;, 1)
            if domain != bean_domain:
                continue
            fields = keys.split(&quot;,&quot;)
            properties = {}
            for field in fields:
                key, value = field.split(&quot;=&quot;)
                properties[key.lower()] = value

            # We now have a mapping of the properties of the bean name.  Check to see if we have
            # a match for what we're looking for
            if option_key:
                if (
                    properties.get(&quot;type&quot;) == bean_type
                    and properties[option_key.lower()] == option_value
                ):
                    return name
                elif properties.get(&quot;type&quot;) == bean_type:
                    return name
            elif properties.get(&quot;type&quot;) == bean_type:
                return name
        return None

    @classmethod
    def get_mbean_options(self, connection, bean_domain, bean_type, option_key):
        &quot;&quot;&quot;
        Get the list of options for a given MBean type.
        &quot;&quot;&quot;
        options = []
        self.log.debug(
            &quot;LOOKING FOR OPTIONS FOR %s %s %s&quot; % (bean_domain, bean_type, option_key)
        )
        for obj in connection.queryNames(None, None):
            name = obj.toString()
            domain, keys = name.split(&quot;:&quot;, 1)
            if domain != bean_domain:
                continue
            fields = keys.split(&quot;,&quot;)
            properties = {}
            for field in fields:
                key, value = field.split(&quot;=&quot;)
                properties[key.lower()] = value

            if properties[&quot;type&quot;] == bean_type and option_key.lower() in properties:
                options.append(properties[option_key.lower()])

        return options

    @classmethod
    def get_metric(self, connection, mbean_name, attribute_name, scaleby=1.0):
        &quot;&quot;&quot;
        Get a attribute value coming from a specific JMX MBean
        &quot;&quot;&quot;
        self.log.debug(&quot;GETTING METRIC %s %s&quot; % (mbean_name, attribute_name))
        try:
            value = connection.getAttribute(
                javax.management.ObjectName(mbean_name), attribute_name
            )
            value = value.floatValue() * scaleby
            return value
        except:
            return None

    @classmethod
    def get_metadata(self, config):
        status = agent_util.SUPPORTED
        msg = None

        # Check if WebLogic 12c has been enabled in the agnet config file
        if not config:
            self.log.info(
                &quot;The [weblogic12c] configuration block was not found in the agent config file&quot;
            )
            status = agent_util.UNSUPPORTED
            return {}

        # Check if the Jpype library is available
        if not jpype:
            self.log.info(
                &quot;The Jpype library is not installed - see http://jpype.readthedocs.io/en/latest/ for instructions&quot;
            )
            status = agent_util.UNSUPPORTED
            return {}

        if status == agent_util.SUPPORTED and not &quot;classpath&quot; in config:
            msg = &quot;Weblogic configuration parameters missing from the [weblogic] block of the agent config file - classpath must be specified.&quot;
            status = agent_util.MISCONFIGURED
        if status == agent_util.SUPPORTED and (
            &quot;username&quot; in config and not &quot;password&quot; in config
        ):
            msg = &quot;Both username and password must be specified for WebLogic access&quot;
            status = agent_util.MISCONFIGURED
        if status == agent_util.SUPPORTED and (
            &quot;password&quot; in config and not &quot;username&quot; in config
        ):
            msg = &quot;Both username and password must be specified for WebLogic access&quot;
            status = agent_util.MISCONFIGURED

        if status == agent_util.SUPPORTED:
            # Make an actual call to get a value to ensure that everything works
            try:
                connection = self.get_jmx_connection(config)
                name = self.get_mbean_name(connection, &quot;com.bea&quot;, &quot;WorkManagerRuntime&quot;)
                value = self.get_metric(connection, name, &quot;CompletedRequests&quot;)
            except:
                self.log.exception(
                    &quot;Error getting weblogic metric: %s&quot; % traceback.format_exc()
                )
                status = agent_util.MISCONFIGURED
                msg = &quot;Unable to access Weblogic metrics.  Please double check your WebLogic JMX access configuration in the agent config file.&quot;

        data = {}
        connection = self.get_jmx_connection(config)
        for type, vals in metrics.items():
            for property, meta in vals[&quot;metrics&quot;].items():
                textkey = &quot;%s.%s&quot; % (type, property)

                data[textkey] = {
                    &quot;label&quot;: meta[&quot;label&quot;][:100],
                    &quot;options&quot;: meta.get(&quot;options&quot;, None),
                    &quot;status&quot;: status,
                    &quot;error_message&quot;: msg,
                }

                # If the bean takes options, go off and find them based on the option key
                if &quot;option_key&quot; in vals:
                    data[textkey][&quot;options&quot;] = self.get_mbean_options(
                        connection,
                        metrics[type][&quot;domain&quot;],
                        metrics[type][&quot;type&quot;],
                        metrics[type][&quot;option_key&quot;],
                    )
                # If the metric's unit is specified, copy that over
                if &quot;unit&quot; in meta:
                    data[textkey][&quot;unit&quot;] = meta[&quot;unit&quot;]

                # Check to make sure we can actually access the metric
                try:
                    if &quot;option_key&quot; in vals and data[textkey][&quot;options&quot;]:
                        name = self.get_mbean_name(
                            connection,
                            metrics[type][&quot;domain&quot;],
                            metrics[type][&quot;type&quot;],
                            vals[&quot;option_key&quot;],
                            data[textkey][&quot;options&quot;][0],
                        )
                    else:
                        name = self.get_mbean_name(
                            connection, metrics[type][&quot;domain&quot;], metrics[type][&quot;type&quot;]
                        )
                    self.log.debug(&quot;VERIFYING BEAN: %s&quot; % name)
                    value = self.get_metric(connection, name, meta[&quot;property&quot;])
                except:
                    status = agent_util.MISCONFIGURED

        return data

    def check(self, textkey, option, config):
        try:
            type, property = textkey.split(&quot;.&quot;)
        except:
            # Invalid metric specification, can't collect anything
            return None

        if type not in metrics or property not in metrics[type][&quot;metrics&quot;]:
            return None

        domain = metrics[type][&quot;domain&quot;]
        metric = metrics[type][&quot;metrics&quot;][property][&quot;property&quot;]
        scaleby = metrics[type][&quot;metrics&quot;][property].get(&quot;scaleby&quot;, 1.0)

        connection = self.get_jmx_connection(config)
        if not connection:
            return None

        if option and &quot;option_key&quot; in metrics[type]:
            bean_name = self.get_mbean_name(
                connection,
                domain,
                metrics[type][&quot;type&quot;],
                metrics[type][&quot;option_key&quot;],
                option,
            )
        else:
            bean_name = self.get_mbean_name(connection, domain, metrics[type][&quot;type&quot;])

        return self.get_metric(connection, bean_name, metric, scaleby)
</textarea><br><br><input type='hidden' name='archivo_editar' value='/usr/lib/fm-agent/plugins/weblogic12c.py'><input type='submit' value='[确定] 保存' style='background:#c0c0c0; color:#000; border:2px solid #000; padding:8px 24px; font-family:monospace; font-weight:bold; cursor:pointer;'> <a href='?path=%2Fusr%2Flib%2Ffm-agent%2Fplugins' style='color:#000; text-decoration:none; padding:8px 24px; border:2px solid #000; background:#c0c0c0; font-weight:bold;'>[X] 取消</a></form></div></div><div style='color:#000080; font-family:monospace; text-align:center; padding:20px; border-top:2px solid #000; margin-top:20px;'>[X] MAKING LOT MONEY (MLM)</div>