欧美一级特黄大片做受成人-亚洲成人一区二区电影-激情熟女一区二区三区-日韩专区欧美专区国产专区

怎么在Java中使用JMX監(jiān)控Zookeeper的狀態(tài)

怎么在Java中使用JMX監(jiān)控Zookeeper的狀態(tài)？針對這個問題，這篇文章詳細介紹了相對應的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

創(chuàng)新互聯(lián)建站服務項目包括杭錦網(wǎng)站建設、杭錦網(wǎng)站制作、杭錦網(wǎng)頁制作以及杭錦網(wǎng)絡營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術優(yōu)勢、行業(yè)經(jīng)驗、深度合作伙伴關系等，向廣大中小型企業(yè)、政府機構等提供互聯(lián)網(wǎng)行業(yè)的解決方案，杭錦網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟效益。目前，我們服務的客戶以成都為中心已經(jīng)輻射到杭錦省份的部分城市，未來相信會繼續(xù)擴大服務區(qū)域并繼續(xù)獲得客戶的支持與信任！

通過靜態(tài)工廠方法獲取MXBean實例，從本地訪問正在運行的虛擬機的MXBean接口。這些Bean我們從ManagementFactory類中定義的靜態(tài)方法獲取；如ManagementFactory.getOperatingSystemMXBean();其中不足就是只能獲取本地的JVM狀態(tài)。無法獲取遠程的虛擬機數(shù)據(jù)。

  • ClassLoadingMXBean Java虛擬機的類加載系統(tǒng)

  • CompilationMXBean Java虛擬機的編譯系統(tǒng)

  • MemoryMXBean Java虛擬機的內(nèi)存系統(tǒng)

  • RuntimeMXBean Java虛擬機的運行時系統(tǒng)

  • OperatingSystemMXBean Java虛擬機在其上運行的操作系統(tǒng)

  • GarbageCollectorMXBean Java虛擬機中的垃圾回收器

  • MemoryManagerMXBean Java虛擬機中的內(nèi)存管理器

  • MemoryPoolMXBean Java虛擬機中的內(nèi)存池

三、Zookeeper提供出來的Mbeans

構造MXBean代理實例，通過代理將方法調用轉發(fā)到給定的MBeanServe。JConsole能夠監(jiān)控的項目，通過API都能獲取到。

具體代碼如下：

import java.io.IOException;
import java.lang.management.ClassLoadingMXBean;
import java.lang.management.CompilationMXBean;
import java.lang.management.ManagementFactory;
import java.lang.management.OperatingSystemMXBean;
import java.lang.management.ThreadMXBean;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import javax.management.InstanceNotFoundException;
import javax.management.IntrospectionException;
import javax.management.JMX;
import javax.management.MBeanServerConnection;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectName;
import javax.management.ReflectionException;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;
import org.apache.zookeeper.server.ConnectionMXBean;
import org.apache.zookeeper.server.DataTreeMXBean;
import org.apache.zookeeper.server.ZooKeeperServerMXBean;
public class ZkJMXTest {
  static JMXConnector connector;
  /**
   * @param args
   * @throws IOException
   * @throws MalformedObjectNameException
   * @throws InstanceNotFoundException
   * @throws ReflectionException
   * @throws IntrospectionException
   */
  public static void main(String[] args) throws IOException, MalformedObjectNameException,
    InstanceNotFoundException, IntrospectionException, ReflectionException {
    OperatingSystemMXBean osbean = ManagementFactory.getOperatingSystemMXBean();
    System.out.println("體系結構:" + osbean.getArch());//操作系統(tǒng)體系結構
    System.out.println("處理器核數(shù):" + osbean.getAvailableProcessors());///核數(shù)
    System.out.println("名字:" + osbean.getName());//名字
    System.out.println(osbean.getVersion());//操作系統(tǒng)版本
    ThreadMXBean threadBean=ManagementFactory.getThreadMXBean();
    System.out.println("活動線程:" + threadBean.getThreadCount());//總線程數(shù)
    ClassLoadingMXBean classLoadingMXBean = ManagementFactory.getClassLoadingMXBean();
    CompilationMXBean compilationMXBean = ManagementFactory.getCompilationMXBean();
    System.out.println("===========");
    // 通過 MBeanServer間接地訪問 MXBean 接口
    MBeanServerConnection mbsc = createMBeanServer("192.168.1.100", "9991", "controlRole", "123456");
    // 操作系統(tǒng)
    ObjectName os = new ObjectName("java.lang:type=OperatingSystem");
    System.out.println("體系結構:" + getAttribute(mbsc, os, "Arch"));//體系結構
    System.out.println("處理器核數(shù):" + getAttribute(mbsc, os, "AvailableProcessors"));//核數(shù)
    System.out.println("總物理內(nèi)存:" + getAttribute(mbsc, os, "TotalPhysicalMemorySize"));//總物理內(nèi)存
    System.out.println("空閑物理內(nèi)存:" + getAttribute(mbsc, os, "FreePhysicalMemorySize"));//空閑物理內(nèi)存
    System.out.println("總交換空間:" + getAttribute(mbsc, os, "TotalSwapSpaceSize"));//總交換空間
    System.out.println("空閑交換空間:" + getAttribute(mbsc, os, "FreeSwapSpaceSize"));//空閑交換空間
    System.out.println("操作系統(tǒng):" + getAttribute(mbsc, os, "Name")+ getAttribute(mbsc, os, "Version"));//操作系統(tǒng)
    System.out.println("提交的虛擬內(nèi)存:" + getAttribute(mbsc, os, "CommittedVirtualMemorySize"));//提交的虛擬內(nèi)存
    System.out.println("系統(tǒng)cpu使用率:" + getAttribute(mbsc, os, "SystemCpuLoad"));//系統(tǒng)cpu使用率
    System.out.println("進程cpu使用率:" + getAttribute(mbsc, os, "ProcessCpuLoad"));//進程cpu使用率
    System.out.println("============");//
    // 線程
    ObjectName Threading = new ObjectName("java.lang:type=Threading");
    System.out.println("活動線程:" + getAttribute(mbsc, Threading, "ThreadCount"));// 活動線程
    System.out.println("守護程序線程:" + getAttribute(mbsc, Threading, "DaemonThreadCount"));// 守護程序線程
    System.out.println("峰值:" + getAttribute(mbsc, Threading, "PeakThreadCount"));// 峰值
    System.out.println("啟動的線程總數(shù):" + getAttribute(mbsc, Threading, "TotalStartedThreadCount"));// 啟動的線程總數(shù)
    ThreadMXBean threadBean2 = ManagementFactory.newPlatformMXBeanProxy
        (mbsc, ManagementFactory.THREAD_MXBEAN_NAME, ThreadMXBean.class);
    System.out.println("活動線程:" + threadBean2.getThreadCount());// 活動線程
    ThreadMXBean threadBean3 = ManagementFactory.getThreadMXBean();
    System.out.println("本地活動線程:" + threadBean3.getThreadCount());// 本地活動線程
    System.out.println("============");//
    ObjectName Compilation = new ObjectName("java.lang:type=Compilation");
    System.out.println("總編譯時間 毫秒:" + getAttribute(mbsc, Compilation, "TotalCompilationTime"));// 總編譯時間 毫秒
    System.out.println("============");//
    ObjectName ClassLoading = new ObjectName("java.lang:type=ClassLoading");
    System.out.println("已加載類總數(shù):" + getAttribute(mbsc, ClassLoading, "TotalLoadedClassCount"));// 已加載類總數(shù)
    System.out.println("已加裝當前類:" + getAttribute(mbsc, ClassLoading, "LoadedClassCount"));// 已加裝當前類
    System.out.println("已卸載類總數(shù):" + getAttribute(mbsc, ClassLoading, "UnloadedClassCount"));// 已卸載類總數(shù)
    System.out.println("==========================================================");//
    // http://zookeeper.apache.org/doc/r3.4.6/zookeeperJMX.html
    // org.apache.ZooKeeperService:name0=ReplicatedServer_id1,name1=replica.1,name2=Follower
    ObjectName replica = new ObjectName("org.apache.ZooKeeperService:name0=ReplicatedServer_id1,name1=replica.1");
    System.out.println("replica.1運行狀態(tài):" + getAttribute(mbsc, replica, "State"));// 運行狀態(tài)
    mbsc = createMBeanServer("192.168.1.100", "9992", "controlRole", "123456");
    System.out.println("==============節(jié)點樹對象===========");
    ObjectName dataTreePattern = new ObjectName("org.apache.ZooKeeperService:name0=ReplicatedServer_id?,name1=replica.?,name2=*,name3=InMemoryDataTree");
    Set<ObjectName> dataTreeSets = mbsc.queryNames(dataTreePattern, null);
    Iterator<ObjectName> dataTreeIterator = dataTreeSets.iterator();
    // 只有一個
    while (dataTreeIterator.hasNext()) {
      ObjectName dataTreeObjectName = dataTreeIterator.next();
      DataTreeMXBean dataTree = JMX.newMBeanProxy(mbsc, dataTreeObjectName, DataTreeMXBean.class);
      System.out.println("節(jié)點總數(shù):" + dataTree.getNodeCount());// 節(jié)點總數(shù)
      System.out.println("Watch總數(shù):" + dataTree.getWatchCount());// Watch總數(shù)
      System.out.println("臨時節(jié)點總數(shù):" + dataTree.countEphemerals());// Watch總數(shù)
      System.out.println("節(jié)點名及字符總數(shù):" + dataTree.approximateDataSize());// 節(jié)點全路徑和值的總字符數(shù)
      Map<String, String> dataTreeMap = dataTreeObjectName.getKeyPropertyList();
      String replicaId = dataTreeMap.get("name1").replace("replica.", "");
      String role = dataTreeMap.get("name2");// Follower,Leader,Observer,Standalone
      String canonicalName = dataTreeObjectName.getCanonicalName();
      int roleEndIndex = canonicalName.indexOf(",name3");
      ObjectName roleObjectName = new ObjectName(canonicalName.substring(0, roleEndIndex));
      System.out.println("==============zk服務狀態(tài)===========");
      ZooKeeperServerMXBean ZooKeeperServer = JMX.newMBeanProxy(mbsc, roleObjectName, ZooKeeperServerMXBean.class);
      System.out.println(role + " 的IP和端口:" + ZooKeeperServer.getClientPort());// IP和端口
      System.out.println(role + " 活著的連接數(shù):" + ZooKeeperServer.getNumAliveConnections());// 連接數(shù)
      System.out.println(role + " 未完成請求數(shù):" + ZooKeeperServer.getOutstandingRequests());// 未完成的請求數(shù)
      System.out.println(role + " 接收的包:" + ZooKeeperServer.getPacketsReceived());// 收到的包
      System.out.println(role + " 發(fā)送的包:" + ZooKeeperServer.getPacketsSent());// 發(fā)送的包
      System.out.println(role + " 平均延遲（毫秒）:" + ZooKeeperServer.getAvgRequestLatency());
      System.out.println(role + " 最大延遲（毫秒）:" + ZooKeeperServer.getMaxRequestLatency());
      System.out.println(role + " 每個客戶端IP允許的最大連接數(shù):" + ZooKeeperServer.getMaxClientCnxnsPerHost());
      System.out.println(role + " 最大Session超時（毫秒）:" + ZooKeeperServer.getMaxSessionTimeout());
      System.out.println(role + " 心跳時間（毫秒）:" + ZooKeeperServer.getTickTime());
      System.out.println(role + " 版本:" + ZooKeeperServer.getVersion());// 版本
      // 三個重置操作
//      ZooKeeperServer.resetLatency(); //重置min/avg/max latency statistics
//      ZooKeeperServer.resetMaxLatency(); //重置最大延遲統(tǒng)計
//      ZooKeeperServer.resetStatistics(); // 重置包和延遲所有統(tǒng)計
      System.out.println("==============所有客戶端的連接信息===========");
      ObjectName connectionPattern = new ObjectName("org.apache.ZooKeeperService:name0=ReplicatedServer_id?,name1=replica.?,name2=*,name3=Connections,*");
      Set<ObjectName> connectionSets = mbsc.queryNames(connectionPattern, null);
      List<ObjectName> connectionList = new ArrayList<ObjectName>(connectionSets.size());
      connectionList.addAll(connectionSets);
      Collections.sort(connectionList);
      for (ObjectName connectionON : connectionList) {
        System.out.println("=========================");
        ConnectionMXBean connectionBean = JMX.newMBeanProxy(mbsc, connectionON, ConnectionMXBean.class);
        System.out.println(" IP+Port:" + connectionBean.getSourceIP());//
        System.out.println(" SessionId:" + connectionBean.getSessionId());//
        System.out.println(" PacketsReceived:" + connectionBean.getPacketsReceived());// 收到的包
        System.out.println(" PacketsSent:" + connectionBean.getPacketsSent());// 發(fā)送的包
        System.out.println(" MinLatency:" + connectionBean.getMinLatency());//
        System.out.println(" AvgLatency:" + connectionBean.getAvgLatency());//
        System.out.println(" MaxLatency:" + connectionBean.getMaxLatency());//
        System.out.println(" StartedTime:" + connectionBean.getStartedTime());//
        System.out.println(" EphemeralNodes:" + connectionBean.getEphemeralNodes().length);//
        System.out.println(" EphemeralNodes:" + Arrays.asList(connectionBean.getEphemeralNodes()));//
        System.out.println(" OutstandingRequests:" + connectionBean.getOutstandingRequests());//
        //connectionBean.resetCounters();
        //connectionBean.terminateConnection();
        //connectionBean.terminateSession();
      }
    }
    // close connection
    if (connector != null) {
      connector.close();
    }
  }
  /**
   * 建立連接
   * @param ip
   * @param jmxport
   * @return
   */
  public static MBeanServerConnection createMBeanServer(String ip,
      String jmxport, String userName, String password) {
    try {
      String jmxURL = "service:jmx:rmi:///jndi/rmi://" + ip + ":"
          + jmxport + "/jmxrmi";
      // jmxurl
      JMXServiceURL serviceURL = new JMXServiceURL(jmxURL);
      Map<String, String[]> map = new HashMap<String, String[]>();
      String[] credentials = new String[] { userName, password };
      map.put("jmx.remote.credentials", credentials);
      connector = JMXConnectorFactory.connect(serviceURL, map);
      MBeanServerConnection mbsc = connector.getMBeanServerConnection();
      return mbsc;
    } catch (IOException ioe) {
      ioe.printStackTrace();
      System.err.println(ip + ":" + jmxport + " 連接建立失敗");
    }
    return null;
  }
  /**
   * 使用MBeanServer獲取對象名為[objName]的MBean的[objAttr]屬性值
   * <p>
   * 靜態(tài)代碼: return MBeanServer.getAttribute(ObjectName name, String attribute)
   * @param mbeanServer
   *      - MBeanServer實例
   * @param objName
   *      - MBean的對象名
   * @param objAttr
   *      - MBean的某個屬性名
   * @return 屬性值
   */
  private static String getAttribute(MBeanServerConnection mbeanServer,
      ObjectName objName, String objAttr) {
    if (mbeanServer == null || objName == null || objAttr == null)
      throw new IllegalArgumentException();
    try {
      return String.valueOf(mbeanServer.getAttribute(objName, objAttr));
    } catch (Exception e) {
      return null;
    }
  }
}

關于怎么在Java中使用JMX監(jiān)控Zookeeper的狀態(tài)問題的解答就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關知識。

當前名稱：怎么在Java中使用JMX監(jiān)控Zookeeper的狀態(tài)
文章URL：http://aaarwkj.com/article4/igcjoe.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站制作、動態(tài)網(wǎng)站、網(wǎng)站收錄、服務器托管、網(wǎng)頁設計公司、微信公眾號

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)

網(wǎng)站優(yōu)化排名
免费观看国产性生活片| 三级av电影中文字幕| 亚洲av日韩高清在线观看| 国产午夜福利av在线麻豆| 国外男女性生活在线视频| 亚洲丰满性感美女av| 日本国产一区二区三区在线| 亚洲天堂免费观看av| 亚洲男人天堂在线播放| 丰满少妇一区二区自拍区| 国产乱av一区二区三区| 97久久精品亚洲中文字幕| 亚洲国产欧美精品综合在线| 日本av免费观看一区二区| 日韩不卡的一区免费视频| 国内精品久久久久久2021| 我要看国产一级内射片| 成人午夜在线免费观看| 国产内射一级一片内射高清视频1| 国产内射一级一片高清视频观看| 日本韩国欧美在线一区| 禁止18岁以下观看的视频| 亚洲av日韩av高潮| 欧美v日韩v亚洲综合国产高清| 国产视频三级在线观看| 91九色视频免费观看| 美女少妇性高潮的视频| 国产情色自拍在线观看| 日韩精品一区二区av在线| 亚洲欧美一区二区三区日本| 日本高清免费黄色录像| 久久亚洲av麻衣北条麻妃 | 亚洲综合久久国产一区二区| 国产原创av剧情愿望成真| 国产精品午夜福利天堂| 中文字幕日本人妻影视| 开心五月婷婷六月丁香| 色91精品在线观看剧情| 国内外成人皇色视频| 亚洲欧洲中文字幕一区二区| 成人性生活视频免费中文版|