javax.management.Query类的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(13.5k)|赞(0)|评价(0)|浏览(89)

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

Query介绍

暂无

代码示例

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

  1. /**
  2.  * Builds the QueryExp used to identify the target MBean.
  3.  *
  4.  * @param pidAttribute the name of the MBean attribute with the process id to compare against
  5.  * @param attributes the names of additional MBean attributes to compare with expected values
  6.  * @param values the expected values of the specified MBean attributes
  7.  *
  8.  * @return the main QueryExp for matching the target MBean
  9.  */
  10. private QueryExp buildQueryExp(final String pidAttribute, final String[] attributes,
  11.   final Object[] values) {
  12.  QueryExp optionalAttributes = buildOptionalQueryExp(attributes, values);
  13.  QueryExp constraint;
  14.  if (optionalAttributes != null) {
  15.   constraint =
  16.     Query.and(optionalAttributes, Query.eq(Query.attr(pidAttribute), Query.value(pid)));
  17.  } else {
  18.   constraint = Query.eq(Query.attr(pidAttribute), Query.value(pid));
  19.  }
  20.  return constraint;
  21. }

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

  1. public static MemberMXBean getMemberMXBean(final String serviceName, final String member)
  2.   throws IOException {
  3.  assertState(Gfsh.isCurrentInstanceConnectedAndReady(),
  4.    "Gfsh must be connected in order to get proxy to a GemFire Member MBean.");
  5.  MemberMXBean memberBean = null;
  6.  try {
  7.   String objectNamePattern = ManagementConstants.OBJECTNAME__PREFIX;
  8.   objectNamePattern += (org.apache.geode.internal.lang.StringUtils.isBlank(serviceName)
  9.     ? org.apache.geode.internal.lang.StringUtils.EMPTY
  10.     : "service=" + serviceName + org.apache.geode.internal.lang.StringUtils.COMMA_DELIMITER);
  11.   objectNamePattern += "type=Member,*";
  12.   // NOTE throws a MalformedObjectNameException, however, this should not happen since the
  13.   // ObjectName is constructed
  14.   // here in a conforming pattern
  15.   final ObjectName objectName = ObjectName.getInstance(objectNamePattern);
  16.   final QueryExp query = Query.or(Query.eq(Query.attr("Name"), Query.value(member)),
  17.     Query.eq(Query.attr("Id"), Query.value(member)));
  18.   final Set<ObjectName> memberObjectNames =
  19.     Gfsh.getCurrentInstance().getOperationInvoker().queryNames(objectName, query);
  20.   if (!memberObjectNames.isEmpty()) {
  21.    memberBean = Gfsh.getCurrentInstance().getOperationInvoker()
  22.      .getMBeanProxy(memberObjectNames.iterator().next(), MemberMXBean.class);
  23.   }
  24.  } catch (MalformedObjectNameException e) {
  25.   Gfsh.getCurrentInstance().logSevere(e.getMessage(), e);
  26.  }
  27.  return memberBean;
  28. }

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

  1. private ObjectName getObjectName(Class<?> proxyClass, String beanQueryName)
  2.   throws MalformedObjectNameException, IOException {
  3.  ObjectName name = null;
  4.  QueryExp query = null;
  5.  if (proxyClass != null) {
  6.   query = Query.isInstanceOf(Query.value(proxyClass.getName()));
  7.  }
  8.  if (beanQueryName != null) {
  9.   name = ObjectName.getInstance(beanQueryName);
  10.  }
  11.  Set<ObjectInstance> beans = con.queryMBeans(name, query);
  12.  assertEquals("failed to find only one instance of type " + proxyClass.getName() + " with name "
  13.    + beanQueryName, 1, beans.size());
  14.  return ((ObjectInstance) beans.toArray()[0]).getObjectName();
  15. }

代码示例来源：origin: vakinge/oneplatform

  1. private static  int getServerPort(){
  2.     int port = 0;
  3.     try {
  4.       MBeanServer beanServer = ManagementFactory.getPlatformMBeanServer();
  5.       Set<ObjectName> objectNames = beanServer.queryNames(new ObjectName("*:type=Connector,*"),
  6.           Query.match(Query.attr("protocol"), Query.value("HTTP/1.1")));
  8.       port = Integer.valueOf(objectNames.iterator().next().getKeyProperty("port"));
  9.     }catch (Exception e){
  10.       if(StringUtils.isNotBlank(System.getProperty("jetty.port"))){
  11.         port = Integer.parseInt(System.getProperty("jetty.port"));
  12.       }
  13.     }
  14.     return port;
  15.   }
  16. }

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

  1. @Test
  2. public void testCreateQueryParameterSource() throws MalformedObjectNameException {
  3.  final ObjectName expectedObjectName = ObjectName.getInstance("GemFire:type=Member,*");
  4.  final QueryExp expectedQueryExpression = Query.eq(Query.attr("id"), Query.value("12345"));
  5.  final QueryParameterSource query =
  6.    new QueryParameterSource(expectedObjectName, expectedQueryExpression);
  7.  assertNotNull(query);
  8.  assertSame(expectedObjectName, query.getObjectName());
  9.  assertSame(expectedQueryExpression, query.getQueryExpression());
  10. }

代码示例来源：origin: locationtech/geowave

  1. private static String getHTTPEndPoint() throws Exception {
  2.  final MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
  3.  final QueryExp subQuery1 = Query.match(Query.attr("protocol"), Query.value("HTTP/1.1"));
  4.  final QueryExp subQuery2 = Query.anySubString(Query.attr("protocol"), Query.value("Http11"));
  5.  final QueryExp query = Query.or(subQuery1, subQuery2);
  6.  final Set<ObjectName> objs = mbs.queryNames(new ObjectName("*:type=Connector,*"), query);

代码示例来源：origin: org.objectweb.jonas/jonas-ejb-2.1

  1. QueryExp match = Query.match(Query.attr("jndiName"), Query.value(jndiName));
  2. QueryExp query = Query.and(match, new DataSourcePropertiesQueryExp());
  3. Set objectNames = mbeanServer.queryNames(J2eeObjectName.getResourceAdapters(J2eeObjectName.ALL, null), query);

代码示例来源：origin: com.github.cjmx/cjmx-ext

  1. private static ValueExp asValueExp(final Object value) {
  2.   if (value instanceof Boolean)
  3.     return Query.value((Boolean)value);
  4.   else if (value instanceof Double)
  5.     return Query.value((Double)value);
  6.   else if (value instanceof Float)
  7.     return Query.value((Float)value);
  8.   else if (value instanceof Integer)
  9.     return Query.value((Integer)value);
  10.   else if (value instanceof Long)
  11.     return Query.value((Long)value);
  12.   else if (value instanceof Number)
  13.     return Query.value((Number)value);
  14.   else if (value instanceof String)
  15.     return Query.value((String)value);
  16.   else
  17.     return Query.value(value.toString());
  18. }

代码示例来源：origin: org.terracotta/terracotta-ee

  1. public static final QueryExp matchAllTerracottaMBeans(UUID id, String[] tunneledDomains) {
  2.  try {
  3.   QueryExp query = Query.or(new ObjectName(MBeanDomain.PUBLIC + ":*,node=" + id),
  4.                new ObjectName(MBeanDomain.INTERNAL + ":*,node=" + id));
  5.   if (tunneledDomains != null) {
  6.    for (String tunneledDomain : tunneledDomains) {
  7.     query = Query.or(query, new ObjectName(tunneledDomain + ":*,node=" + id));
  8.    }
  9.   }
  10.   return query;
  11.  } catch (MalformedObjectNameException e) {
  12.   throw new RuntimeException(e);
  13.  }
  14. }

代码示例来源：origin: palantir/atlasdb

  1. /**
  2.    *
  3.    * @param <T>
  4.    * @param mbeanClazz
  5.    * @return proxy interfaces to all beans registered to the server implementing the class mbeanClazz.
  6.    */
  7.   public static <T> Iterable<T> getInstanceBeanProxies(final Class<T> mbeanClazz){
  8.     return Iterables.transform(
  9.         ManagementFactory.getPlatformMBeanServer().queryNames(ObjectName.WILDCARD, Query.isInstanceOf(new StringValueExp(mbeanClazz.getName())))
  10.         , obj -> JMXUtils.newMBeanProxy(ManagementFactory.getPlatformMBeanServer(), obj, mbeanClazz));
  11.   }
  12. }

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

  1. @Override
  2. public Set<ObjectName> queryNames(ObjectName name, QueryExp query) {
  3.  if (query != null)
  4.   return mbs.queryNames(name, Query.and(query, notAccessControlMBean));
  5.  else
  6.   return mbs.queryNames(name, notAccessControlMBean);
  7. }

代码示例来源：origin: org.restcomm/restcomm-connect.commons

  1. @Override
  2.   public HttpConnectorList findConnectors() throws MalformedObjectNameException, NullPointerException, UnknownHostException, AttributeNotFoundException,
  3.       InstanceNotFoundException, MBeanException, ReflectionException {
  4.     LOG.info("Searching Tomcat HTTP connectors.");
  5.     HttpConnectorList httpConnectorList = null;
  6.     MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
  8.     Set<ObjectName> tomcatObjs = mbs.queryNames(new ObjectName("*:type=Connector,*"), Query.match(Query.attr("protocol"), Query.value("HTTP/1.1")));
  10.     ArrayList<HttpConnector> endPoints = new ArrayList<HttpConnector>();
  11.     if (tomcatObjs != null && tomcatObjs.size() > 0) {
  12.       for (ObjectName obj : tomcatObjs) {
  13.         String scheme = mbs.getAttribute(obj, "scheme").toString().replaceAll("\"", "");
  14.         String port = obj.getKeyProperty("port").replaceAll("\"", "");
  15.         String address = obj.getKeyProperty("address").replaceAll("\"", "");
  16.         if (LOG.isInfoEnabled()) {
  17.           LOG.info("Tomcat Http Connector: " + scheme + "://" + address + ":" + port);
  18.         }
  19.         HttpConnector httpConnector = new HttpConnector(scheme, address, Integer.parseInt(port), scheme.equalsIgnoreCase("https"));
  20.         endPoints.add(httpConnector);
  21.       }
  22.     }
  23.     if (endPoints.isEmpty()) {
  24.       LOG.warn("Coundn't discover any Http Interfaces");
  25.     }
  26.     httpConnectorList = new HttpConnectorList(endPoints);
  27.     return httpConnectorList;
  28.   }
  29. }

代码示例来源：origin: io.snappydata/gemfire-hydra-tests

  1. protected static String getMemberId(final String jmxManagerHost, final int jmxManagerPort, final String memberName)
  2.  throws Exception
  3. {
  4.  JMXConnector connector = null;
  5.  try {
  6.   connector = JMXConnectorFactory.connect(new JMXServiceURL(String.format(
  7.    "service:jmx:rmi://%1$s/jndi/rmi://%1$s:%2$d/jmxrmi", jmxManagerHost, jmxManagerPort)));
  8.   final MBeanServerConnection connection = connector.getMBeanServerConnection();
  9.   final ObjectName objectNamePattern = ObjectName.getInstance("GemFire:type=Member,*");
  10.   final QueryExp query = Query.eq(Query.attr("Name"), Query.value(memberName));
  11.   final Set<ObjectName> objectNames = connection.queryNames(objectNamePattern, query);
  12.   assertNotNull(objectNames);
  13.   assertEquals(1, objectNames.size());
  14.   //final ObjectName objectName = ObjectName.getInstance("GemFire:type=Member,Name=" + memberName);
  15.   final ObjectName objectName = objectNames.iterator().next();
  16.   //System.err.printf("ObjectName for Member with Name (%1$s) is %2$s%n", memberName, objectName);
  17.   return ObjectUtils.toString(connection.getAttribute(objectName, "Id"));
  18.  }
  19.  finally {
  20.   IOUtils.close(connector);
  21.  }
  22. }

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

  1. Query.match(Query.attr("SensorName"), Query.value("*" + _clusterNamePrefix + "*"));
  2. final Set<ObjectInstance> mbeans = new HashSet<>(ManagementFactory.getPlatformMBeanServer()
  3.   .queryMBeans(new ObjectName("ClusterStatus:*"), exp1));
  4. final QueryExp exp2 = Query.and(
  5.   Query.not(Query.match(Query.attr("SensorName"), Query.value("MessageQueueStatus.*"))),
  6.   exp1);

代码示例来源：origin: stackoverflow.com

  1. Class[] objs = Arrays.stream(joinPoint.getArgs()).map(item -> item.getClass()).toArray(Class[]::new);
  2. System.out.println("[AspectJ] args interfaces :"+objs);
  4. Class clazz = Class.forName(joinPoint.getSignature().getDeclaringTypeName());
  5. System.out.println("[AspectJ] signature class :"+clazz);
  7. Method method = clazz.getDeclaredMethod(joinPoint.getSignature().getName(), objs) ;
  8. System.out.println("[AspectJ] signature method :"+method);
  10. Query m = method.getDeclaredAnnotation(Query.class) ;
  11. System.out.println("[AspectJ] signature annotation value:"+ (m!=null?m.value():m) );

代码示例来源：origin: org.terracotta/terracotta-l1

  1. public static final QueryExp matchAllTerracottaMBeans(UUID id, String[] tunneledDomains) {
  2.  try {
  3.   QueryExp query = Query.or(new ObjectName(MBeanDomain.PUBLIC + ":*,node=" + id),
  4.                new ObjectName(MBeanDomain.INTERNAL + ":*,node=" + id));
  5.   if (tunneledDomains != null) {
  6.    for (String tunneledDomain : tunneledDomains) {
  7.     query = Query.or(query, new ObjectName(tunneledDomain + ":*,node=" + id));
  8.    }
  9.   }
  10.   return query;
  11.  } catch (MalformedObjectNameException e) {
  12.   throw new RuntimeException(e);
  13.  }
  14. }

代码示例来源：origin: com.palantir.atlasdb/atlasdb-commons

  1. /**
  2.    *
  3.    * @param <T>
  4.    * @param mbeanClazz
  5.    * @return proxy interfaces to all beans registered to the server implementing the class mbeanClazz.
  6.    */
  7.   public static <T> Iterable<T> getInstanceBeanProxies(final Class<T> mbeanClazz){
  8.     return Iterables.transform(
  9.         ManagementFactory.getPlatformMBeanServer().queryNames(ObjectName.WILDCARD, Query.isInstanceOf(new StringValueExp(mbeanClazz.getName())))
  10.         , obj -> JMXUtils.newMBeanProxy(ManagementFactory.getPlatformMBeanServer(), obj, mbeanClazz));
  11.   }
  12. }

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

  1. @Override
  2. public Set<ObjectInstance> queryMBeans(ObjectName name, QueryExp query) {
  3.  // We need to filter out the AccessControlMXBean so that the clients wouldn't see it
  4.  if (query != null)
  5.   return mbs.queryMBeans(name, Query.and(query, notAccessControlMBean));
  6.  else
  7.   return mbs.queryMBeans(name, notAccessControlMBean);
  8. }

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

  1. if (values[i] instanceof Boolean) {
  2.  if (queryExp == null) {
  3.   queryExp = Query.eq(Query.attr(attributes[i]), Query.value((Boolean) values[i]));
  4.  } else {
  5.   queryExp = Query.and(queryExp,
  6.     Query.eq(Query.attr(attributes[i]), Query.value((Boolean) values[i])));
  7.   queryExp = Query.eq(Query.attr(attributes[i]), Query.value((Number) values[i]));
  8.  } else {
  9.   queryExp = Query.and(queryExp,
  10.     Query.eq(Query.attr(attributes[i]), Query.value((Number) values[i])));
  11.   queryExp = Query.eq(Query.attr(attributes[i]), Query.value((String) values[i]));
  12.  } else {
  13.   queryExp = Query.and(queryExp,
  14.     Query.eq(Query.attr(attributes[i]), Query.value((String) values[i])));

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

  1. @Test
  2. public void testSerialization()
  3.   throws ClassNotFoundException, IOException, MalformedObjectNameException {
  4.  final ObjectName expectedObjectName = ObjectName.getInstance("GemFire:type=Member,*");
  5.  final QueryExp expectedQueryExpression =
  6.    Query.or(Query.eq(Query.attr("name"), Query.value("myName")),
  7.      Query.eq(Query.attr("id"), Query.value("myId")));
  8.  final QueryParameterSource expectedQuery =
  9.    new QueryParameterSource(expectedObjectName, expectedQueryExpression);
  10.  assertNotNull(expectedQuery);
  11.  assertSame(expectedObjectName, expectedQuery.getObjectName());
  12.  assertSame(expectedQueryExpression, expectedQuery.getQueryExpression());
  13.  final byte[] queryBytes = IOUtils.serializeObject(expectedQuery);
  14.  assertNotNull(queryBytes);
  15.  assertTrue(queryBytes.length != 0);
  16.  final Object queryObj = IOUtils.deserializeObject(queryBytes);
  17.  assertTrue(queryObj instanceof QueryParameterSource);
  18.  final QueryParameterSource actualQuery = (QueryParameterSource) queryObj;
  19.  assertNotSame(expectedQuery, actualQuery);
  20.  assertNotNull(actualQuery.getObjectName());
  21.  assertEquals(expectedQuery.getObjectName().toString(), actualQuery.getObjectName().toString());
  22.  assertNotNull(actualQuery.getQueryExpression());
  23.  assertEquals(expectedQuery.getQueryExpression().toString(),
  24.    actualQuery.getQueryExpression().toString());
  25. }

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

query

相关文章

    查看更多

    热门标签

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

    最新文章

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