javax.management.JMX.newMXBeanProxy()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(11.4k)|赞(0)|评价(0)|浏览(144)

本文整理了Java中javax.management.JMX.newMXBeanProxy()方法的一些代码示例，展示了JMX.newMXBeanProxy()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。JMX.newMXBeanProxy()方法的具体详情如下：
包路径：javax.management.JMX
类名称：JMX
方法名：newMXBeanProxy

JMX.newMXBeanProxy介绍

暂无

代码示例

代码示例来源：origin: aragozin/jvm-tools

  1. public static ThreadMXBean connectThreadMXBean(MBeanServerConnection mserver) {
  2.     ThreadMXBean bean;
  3.     try {
  4.       bean = JMX.newMXBeanProxy(mserver, THREADING_MBEAN, ThreadMXBeanEx.class);
  5.     } catch(Exception e) {
  6.       bean = JMX.newMXBeanProxy(mserver, THREADING_MBEAN, ThreadMXBean.class);
  7.     }
  8.     return bean;
  9.   }
  10. }

代码示例来源：origin: aragozin/jvm-tools

  1. public ThreadStackSampler(MBeanServerConnection mserver) {
  2.   this.threading = JMX.newMXBeanProxy(mserver, THREADING_MBEAN, ThreadMXBean.class);
  3. }

代码示例来源：origin: apache/geode

  1. public AccessControlMXBean getAccessControlMBean() throws Exception {
  2.  return JMX.newMXBeanProxy(con, new ObjectName("GemFire:service=AccessControl,type=Distributed"),
  3.    AccessControlMXBean.class);
  4. }

代码示例来源：origin: vipshop/vjtools

  1. public synchronized ThreadMXBean getThreadMXBean() throws IOException {
  2.   if (hasPlatformMXBeans && threadMBean == null) {
  3.     threadMBean = JMX.newMXBeanProxy(server, createBeanName(ManagementFactory.THREAD_MXBEAN_NAME),
  4.         ThreadMXBean.class);
  5.   }
  6.   return threadMBean;
  7. }

代码示例来源：origin: apache/geode

  1. /**
  2.  * Retrieve a new proxy MXBean
  3.  *
  4.  * @return A new proxy MXBean of the same type with which the class was constructed
  5.  */
  6. public <T> T getProxyMXBean(Class<T> proxyClass, String beanQueryName)
  7.   throws MalformedObjectNameException, IOException {
  8.  return JMX.newMXBeanProxy(con, getObjectName(proxyClass, beanQueryName), proxyClass);
  9. }

代码示例来源：origin: aragozin/jvm-tools

  1. public static Collection<String> allCollectedPools(MBeanServerConnection conn) throws IOException {
  2.   Set<String> pools = new LinkedHashSet<String>();
  3.   
  4.   for(ObjectName gcn: conn.queryNames(COLLECTORS_PATTERN, null)) {
  5.     GarbageCollectorMXBean gc = JMX.newMXBeanProxy(conn, gcn, GarbageCollectorMXBean.class);
  6.     for(String pool: gc.getMemoryPoolNames()) {
  7.       pools.add(pool);
  8.     }
  9.   }
  10.   return pools;
  11. }

代码示例来源：origin: Red5/red5-server

  1. /**
  2.  * Returns the LoaderMBean.
  3.  * 
  4.  * @return LoaderMBean
  5.  */
  6. @SuppressWarnings("cast")
  7. public LoaderMXBean getLoader() {
  8.   MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
  9.   // proxy class
  10.   LoaderMXBean proxy = null;
  11.   ObjectName oName;
  12.   try {
  13.     oName = new ObjectName("org.red5.server:type=TomcatLoader");
  14.     if (mbs.isRegistered(oName)) {
  15.       proxy = JMX.newMXBeanProxy(mbs, oName, LoaderMXBean.class, true);
  16.       log.debug("Loader was found");
  17.     } else {
  18.       log.warn("Loader not found");
  19.     }
  20.   } catch (Exception e) {
  21.     log.error("Exception getting loader", e);
  22.   }
  23.   return proxy;
  24. }

代码示例来源：origin: aragozin/jvm-tools

  1. public MemoryPoolPoller(MBeanServerConnection mserver, MemoryPoolEventConsumer consumer) {
  2.   this.consumer = consumer;
  3.   try {
  4.     ObjectName name = new ObjectName("java.lang:type=MemoryPool,name=*");
  5.     for(ObjectName on: mserver.queryNames(name, null)) {
  6.       
  7.       MemoryPoolMXBean mpool = JMX.newMXBeanProxy(mserver, on, MemoryPoolMXBean.class);
  8.       MemPoolTracker tracker = init(mpool);
  9.       trackers.put(tracker.poolName, tracker);
  10.     }
  11.   } catch (Exception e) {
  12.     throw new RuntimeException(e);
  13.   }
  14. }

代码示例来源：origin: aragozin/jvm-tools

  1. public GcEventPoller(MBeanServerConnection mserver, GarbageCollectionEventConsumer eventSink) {
  2.   this.mserver = mserver;
  3.   this.eventSink = eventSink;
  4.   RuntimeMXBean runtime = JMX.newMXBeanProxy(mserver, RUNTIME_MXBEAN, RuntimeMXBean.class);
  5.   jvmStartTime = runtime.getStartTime();
  6.   initTrackers();
  7. }

代码示例来源：origin: aragozin/jvm-tools

  1. public static Map<PoolType, Collection<String>> classifyMemoryPools(MBeanServerConnection conn) throws IOException {
  3.   RuntimeMXBean rtmx = JMX.newMXBeanProxy(conn, RUNTIME_MXBEAN, RuntimeMXBean.class);
  4.   
  5.   boolean jrockit = rtmx.getVmName().toUpperCase().contains("JROCKIT");
  6.   Map<PoolType, Collection<String>> map = new HashMap<GcKnowledgeBase.PoolType, Collection<String>>();
  7.   for(ObjectName gcn: conn.queryNames(COLLECTORS_PATTERN, null)) {
  8.     GarbageCollectorMXBean gc = JMX.newMXBeanProxy(conn, gcn, GarbageCollectorMXBean.class);
  9.     String gcName = jrockit ? "JRockit" : gc.getName();
  10.     for(String pool: gc.getMemoryPoolNames()) {
  11.       PoolType type = classify(gcName, pool);
  12.       if (type != null) {
  13.         add(map, type, pool);
  14.       }
  15.     }
  16.   }
  17.   return map;
  18. }

代码示例来源：origin: apache/geode

  1. @Override
  2. public <T> T getMBeanProxy(final ObjectName objectName, final Class<T> mbeanInterface) {
  3.  if (DistributedSystemMXBean.class.equals(mbeanInterface)
  4.    && ManagementConstants.OBJECTNAME__DISTRIBUTEDSYSTEM_MXBEAN.equals(objectName.toString())) {
  5.   return mbeanInterface.cast(getDistributedSystemMXBean());
  6.  } else if (JMX.isMXBeanInterface(mbeanInterface)) {
  7.   return JMX.newMXBeanProxy(getMBeanServerConnection(), objectName, mbeanInterface);
  8.  } else {
  9.   return JMX.newMBeanProxy(getMBeanServerConnection(), objectName, mbeanInterface);
  10.  }
  11. }

代码示例来源：origin: Red5/red5-server

  1. /**
  2.  * Adds a connection.
  3.  * 
  4.  * @param conn
  5.  *            connection
  6.  */
  7. public void setConnection(RTMPConnection conn) {
  8.   log.trace("Adding connection: {}", conn);
  9.   int id = conn.getId();
  10.   if (id == -1) {
  11.     log.debug("Connection has unsupported id, using session id hash");
  12.     id = conn.getSessionId().hashCode();
  13.   }
  14.   log.debug("Connection id: {} session id hash: {}", conn.getId(), conn.getSessionId().hashCode());
  15.   if (debug) {
  16.     log.info("Connection count (map): {}", connMap.size());
  17.     try {
  18.       RTMPMinaTransportMXBean proxy = JMX.newMXBeanProxy(ManagementFactory.getPlatformMBeanServer(), new ObjectName("org.red5.server:type=RTMPMinaTransport"), RTMPMinaTransportMXBean.class, true);
  19.       if (proxy != null) {
  20.         log.info("{}", proxy.getStatistics());
  21.       }
  22.     } catch (Exception e) {
  23.       log.warn("Error on jmx lookup", e);
  24.     }
  25.   }
  26. }

代码示例来源：origin: aragozin/jvm-tools

  1. public GcAdapter(MBeanServerConnection mserver, ObjectName gcname, GarbageCollectionSampler sampler) throws IOException, MalformedObjectNameException {
  2.   this.sampler = sampler;
  3.   gc = JMX.newMXBeanProxy(mserver, gcname, GarbageCollectorMXBean.class);
  4.   name = gc.getName();
  5.   RuntimeMXBean runtime = JMX.newMXBeanProxy(mserver, new ObjectName(ManagementFactory.RUNTIME_MXBEAN_NAME), RuntimeMXBean.class);
  6.   processStartMs = runtime.getStartTime();
  7.   collectedPools = Arrays.asList(gc.getMemoryPoolNames());
  8.   
  9.   allCollectedPools = new ArrayList<String>(GcKnowledgeBase.allCollectedPools(mserver));
  10.   Map<GcKnowledgeBase.PoolType, Collection<String>> types = GcKnowledgeBase.classifyMemoryPools(mserver);
  11.   
  12.   edenPools = getMemPools(types, PoolType.EDEN);
  13.   survivourPools = getMemPools(types, PoolType.SURVIVOR);
  14.   oldPools = getMemPools(types, PoolType.TENURED);
  15.   permPools = getMemPools(types, PoolType.PERMANENT);
  16.   youngPools = new ArrayList<String>();
  17.   youngPools.addAll(edenPools);
  18.   youngPools.addAll(survivourPools);
  19.   
  20.   isYoung = collectedPools.containsAll(oldPools);
  21.   isConcurent = "ConcurrentMarkSweep".equals(name);
  22. }

代码示例来源：origin: apache/geode

  1. this.mbsc = connector.getMBeanServerConnection();
  2. this.connector.addConnectionNotificationListener(new JMXConnectionListener(this), null, null);
  3. this.distributedSystemMXBeanProxy = JMX.newMXBeanProxy(mbsc,
  4.   MBeanJMXAdapter.getDistributedSystemName(), DistributedSystemMXBean.class);
  5.  } else {
  6.   this.memberMXBeanProxy =
  7.     JMX.newMXBeanProxy(mbsc, managerMemberObjectName, MemberMXBean.class);
  8.   this.fileUploadMBeanProxy = JMX.newMBeanProxy(mbsc,
  9.     new ObjectName(ManagementConstants.OBJECTNAME__FILEUPLOADER_MBEAN),

代码示例来源：origin: psi-probe/psi-probe

  1. @Override
  2. public DataSourceInfo getInfo(final Object resource) throws Exception {
  3.  DataSourceInfo dataSourceInfo = null;
  4.  if (canMap(resource)) {
  5.   HikariDataSource source = (HikariDataSource) resource;
  6.   MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
  7.   ObjectName poolName =
  8.     new ObjectName("com.zaxxer.hikari:type=Pool (" + source.getPoolName() + ")");
  9.   HikariPoolMXBean poolProxy =
  10.     JMX.newMXBeanProxy(mbeanServer, poolName, HikariPoolMXBean.class);
  11.   dataSourceInfo = new DataSourceInfo();
  12.   dataSourceInfo.setBusyConnections(poolProxy.getActiveConnections());
  13.   dataSourceInfo.setEstablishedConnections(poolProxy.getTotalConnections());
  14.   dataSourceInfo.setMaxConnections(source.getMaximumPoolSize());
  15.   dataSourceInfo.setJdbcUrl(source.getJdbcUrl());
  16.   dataSourceInfo.setUsername(source.getUsername());
  17.   dataSourceInfo.setResettable(false);
  18.   dataSourceInfo.setType("hikari");
  19.  }
  20.  return dataSourceInfo;
  21. }

代码示例来源：origin: psi-probe/psi-probe

  1. @Override
  2. public DataSourceInfo getInfo(final Object resource) throws Exception {
  3.  DataSourceInfo dataSourceInfo = null;
  4.  if (canMap(resource)) {
  5.   ViburDBCPDataSource source = (ViburDBCPDataSource) resource;
  6.   MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
  7.   ObjectName poolName = new ObjectName(source.getJmxName());
  8.   ViburMonitoringMBean poolProxy =
  9.     JMX.newMXBeanProxy(mbeanServer, poolName, ViburMonitoringMBean.class);
  10.   dataSourceInfo = new DataSourceInfo();
  11.   dataSourceInfo.setBusyConnections(poolProxy.getPoolTaken());
  12.   dataSourceInfo.setEstablishedConnections(
  13.     poolProxy.getPoolRemainingCreated() + poolProxy.getPoolTaken());
  14.   dataSourceInfo.setMaxConnections(source.getPoolMaxSize());
  15.   dataSourceInfo.setJdbcUrl(source.getJdbcUrl());
  16.   dataSourceInfo.setUsername(source.getUsername());
  17.   dataSourceInfo.setResettable(false);
  18.   dataSourceInfo.setType("vibur");
  19.  }
  20.  return dataSourceInfo;
  21. }

代码示例来源：origin: org.drools/drools-compiler

  1. KieContainerMonitorMXBean c1Monitor = JMX.newMXBeanProxy(
  2.     mbserver,
  3.     DroolsManagementAgent.createObjectNameBy("myID"),

代码示例来源：origin: org.drools/drools-compiler

  1. KieContainerMonitorMXBean c1Monitor = JMX.newMXBeanProxy(
  2.     mbserver,
  3.     DroolsManagementAgent.createObjectNameBy("myID"),
  4. StatelessKieSession statelessKieSession = kc.newStatelessKieSession("org.kie.monitoring.kbase1.ksession2");
  5. KieSessionMonitoringMXBean statefulKieSessionMonitor = JMX.newMXBeanProxy(
  6.     mbserver,
  7.     DroolsManagementAgent.createObjectNameBy("myID", "org.kie.monitoring.kbase1", KieSessionType.STATEFUL, "org.kie.monitoring.kbase1.ksession1"),
  8.     KieSessionMonitoringMXBean.class);
  9. StatelessKieSessionMonitoringMXBean statelessKieSessionMonitor = JMX.newMXBeanProxy(
  10.     mbserver,
  11.     DroolsManagementAgent.createObjectNameBy("myID", "org.kie.monitoring.kbase1", KieSessionType.STATEFUL, "org.kie.monitoring.kbase1.ksession1"),
  12. KieContainerMonitorMXBean c2Monitor = JMX.newMXBeanProxy(
  13.     mbserver,
  14.     DroolsManagementAgent.createObjectNameBy("myID2"),
  15. KieSession statefulKieSession2 = kc2.newKieSession("org.kie.monitoring.kbase1.ksession1");
  16. StatelessKieSession statelessKieSession2 = kc2.newStatelessKieSession("org.kie.monitoring.kbase1.ksession2");
  17. KieSessionMonitoringMXBean statefulKieSessionMonitor2 = JMX.newMXBeanProxy(
  18.     mbserver,
  19.     DroolsManagementAgent.createObjectNameBy("myID2", "org.kie.monitoring.kbase1", KieSessionType.STATEFUL, "org.kie.monitoring.kbase1.ksession1"),
  20.     KieSessionMonitoringMXBean.class);
  21. StatelessKieSessionMonitoringMXBean statelessKieSessionMonitor2 = JMX.newMXBeanProxy(
  22.     mbserver,
  23.     DroolsManagementAgent.createObjectNameBy("myID2", "org.kie.monitoring.kbase1", KieSessionType.STATEFUL, "org.kie.monitoring.kbase1.ksession1"),

代码示例来源：origin: org.drools/drools-compiler

  1. KieContainerMonitorMXBean c1Monitor = JMX.newMXBeanProxy(
  2.     mbserver,
  3.     DroolsManagementAgent.createObjectNameBy(kc1ID),
  4. assertEquals(releaseId1.getVersion(), c1Monitor.getResolvedReleaseId().getVersion());
  5. KieContainerMonitorMXBean c2Monitor = JMX.newMXBeanProxy(
  6.     mbserver,
  7.     DroolsManagementAgent.createObjectNameBy("Matteo"),

代码示例来源：origin: org.drools/drools-compiler

  1. KieSessionMonitoringMXBean aggrMonitor = JMX.newMXBeanProxy(
  2.     mbserver,
  3.     DroolsManagementAgent.createObjectNameBy(containerId, KBASE1, KieSessionType.STATEFUL, KSESSION1),
  4. StatelessKieSessionMonitoringMXBean aggrMonitor2 = JMX.newMXBeanProxy(
  5.     mbserver,
  6.     DroolsManagementAgent.createObjectNameBy(containerId, KBASE2, KieSessionType.STATELESS, KSESSION2),

内容来源于网络，如有侵权，请联系作者删除！

JMX

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com