码迷,mamicode.com
首页 > 其他好文 > 详细

CloudStack VM运行状态的监控-Management

时间:2015-08-07 11:06:29      阅读:114      评论:0      收藏:0      [点我收藏+]

标签:cloudstack   监控   

VM和Host的运行时刻状态,应该是所有虚拟化平台管理员最热切的关注点。

本文章介绍下CloudStack中,对于VM运行状态信息的获取和扩展。

信息获取原理

Management-Server在启动的时候,会初始化1个线程,用于定期获取定期获取运行时数据。

对于3个主流Hyperviser:KVM、XenServer、VMware,分别调用Libvirt API、 XenServer RRD API和 VMware API来获取当前运行时状态。

定期获取状态之后,会上报到该线程,和之前的上报的数据进行累加,以得到统计全量。

所以,CloudStack对于VM状态的监控,是从Management-Server启动到当前时间的历史统计数据,并非瞬时值。

代码解析

StatsController.java

该类继承了ComponentLifecycle,在Management-Server 启动的时候,会加载start方法,启动后台服务。

@Override
public boolean start() {
    init(_configDao.getConfiguration());
    return true;
}
其中 init() 方法,会读取全局配置中的设置,初始化不同的监控进程

Source code	   
private void init(Map<String, String> configs) {
    _executor = Executors.newScheduledThreadPool(4, new NamedThreadFactory("StatsCollector"));
 
    ......
    hostAndVmStatsInterval = NumbersUtil.parseLong(configs.get("vm.stats.interval"), 60000L);
    ......
    if (hostAndVmStatsInterval > 0) {
        _executor.scheduleWithFixedDelay(new VmStatsCollector(), 15000L, hostAndVmStatsInterval, TimeUnit.MILLISECONDS);
    }
    ......
}

代码可以看出,从全局设置中里面获取vm.stats.interval变量,默认为60s,即1分钟。如果想修改调整时间,可以在全局配置中进行修改。

VmStatsCollector是线程类,集成ManagedContextRunnable。

VmStatsCollector列出全部可用Host,然后按Host进行遍历,查询Host上所有VM当前运行状态,与历史值进行累加,代码如下:

class VmStatsCollector extends ManagedContextRunnable {
        @Override
        protected void runInContext() {
            try {
                ......
                SearchCriteria<HostVO> sc = _hostDao.createSearchCriteria();
                ......//创建查询条件
                List<HostVO> hosts = _hostDao.search(sc, null);
 
                for (HostVO host : hosts) {
                    List<UserVmVO> vms = _userVmDao.listRunningByHostId(host.getId());
                    ......
                    try {
                        HashMap<Long, VmStatsEntry> vmStatsById = _userVmMgr.getVirtualMachineStatistics(host.getId(), host.getName(), vmIds);
                        if (vmStatsById != null) {
                            ......
                            //新VM,加入map中
                        } else {
                            //已有历史数据VM,进行更新,CPU记录最新值,Disk和Network进行累加
                                statsInMemory.setCPUUtilization(statsForCurrentIteration.getCPUUtilization());
                                    statsInMemory.setNumCPUs(statsForCurrentIteration.getNumCPUs());
                                    statsInMemory.setNetworkReadKBs(statsInMemory.getNetworkReadKBs() + statsForCurrentIteration.getNetworkReadKBs());
                                    statsInMemory.setNetworkWriteKBs(statsInMemory.getNetworkWriteKBs() + statsForCurrentIteration.getNetworkWriteKBs());
                                    statsInMemory.setDiskWriteKBs(statsInMemory.getDiskWriteKBs() + statsForCurrentIteration.getDiskWriteKBs());
                                    statsInMemory.setDiskReadIOs(statsInMemory.getDiskReadIOs() + statsForCurrentIteration.getDiskReadIOs());
                                    statsInMemory.setDiskWriteIOs(statsInMemory.getDiskWriteIOs() + statsForCurrentIteration.getDiskWriteIOs());
                                    statsInMemory.setDiskReadKBs(statsInMemory.getDiskReadKBs() + statsForCurrentIteration.getDiskReadKBs());
                                    _VmStats.put(vmId, statsInMemory);
    ......
    }

_userVmMgr.getVirtualMachineStatistics() 方法中,向Hyperviser发送Cmd,查询所需信息,代码如下:

public HashMap<Long, VmStatsEntry> getVirtualMachineStatistics(long hostId, String hostName, List<Long> vmIds) throws CloudRuntimeException {
        ......
        Answer answer = _agentMgr.easySend(hostId, new GetVmStatsCommand(vmNames, _hostDao.findById(hostId).getGuid(), hostName));
        ......
    }

GetVmStatsCommand会发送到Hyperviser相关进程,并由Hyperviser相关进程调用API或 Cloud-Agent 服务进行处理,处理结果返回到当前线程进行处理,最终由VmStatsCollector进行合并。
在ListVm过程中,如果需要得到VM运行时状态,则调用StatsController的getVmStats来获取。
在Hyperviser的相关文件中,各有接受GetVmStatsCommand并进行处理的相关逻辑,下篇帖子会继续介绍Hyperviser中相关逻辑。
CloudStack VM运行状态的监控-HypervisorGetVmStatsCommand会发送到Hyperviser相关进程,并由Hyperviser相关进程调用API或 Cloud-Agent 服务进行处理,处理结果返回到当前线程进行处理,最终由VmStatsCollector进行合并。
在ListVm过程中,如果需要得到VM运行时状态,则调用StatsController的getVmStats来获取。
在Hyperviser的相关文件中,各有接受GetVmStatsCommand并进行处理的相关逻辑,下篇帖子会继续介绍Hyperviser中相关逻辑。
CloudStack VM运行状态的监控-Hypervisor

版权声明:本文为博主原创文章,未经博主允许不得转载。

CloudStack VM运行状态的监控-Management

标签:cloudstack   监控   

原文地址:http://blog.csdn.net/u011650565/article/details/47335869

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!