文档章节

在java里头读取/proc/net/dev

go4it
 go4it
发布于 2017/01/30 16:22
字数 387
阅读 27
收藏 2

##直接读取/proc/net/dev

public class NetStatReader implements MetricsReader {

    private static File netstat = new File("/proc/net/dev");
    private static final Pattern dline =
            //rx                                                   //tx
            //                  device_name        -bytes  packets errs  drops fifo   frame  com   mult   -bytes  packets errs  drops fifo   frame  com   mult
            Pattern.compile("^ *([A-Za-z]+[0-9]*):\\D*(\\d+)\\D+(\\d+)\\D+(\\d+)\\D+(\\d+)\\D+\\d+\\D+\\d+\\D+\\d+\\D+\\d+\\D+(\\d+)\\D+(\\d+)\\D+(\\d+)\\D+(\\d+)\\D+\\d+\\D+\\d+\\D+\\d+\\D+\\d+.*");
    private static final Logger LOG = Logger.getLogger(NetStatReader.class.getName());
    @Inject
    private Configuration conf;
    private String device_regexp = "eth0";

    /**
     * It creates a wrapper to obtain statistics about a network interface by
     * reading information from <i>/proc/net/dev</i>
     *
     * @param interfaceRegexp a string with a regexp to match with the device to
     * control <i>(e.g. "sd[ab]")</i>
     *
     *
     */
    public NetStatReader(String interfaceRegexp) {
        LOG.log(Level.INFO, "Sampling interfaces {0}", interfaceRegexp);
        this.device_regexp = interfaceRegexp;

        checkArgument(netstat.exists(), "/proc/diskstats does not exists");
        checkArgument(netstat.canRead(), "/proc/diskstats can not be read");



    }

    /**
     * *
     *
     * @param interfaceRegexp
     * @param processPid to bind the statistics to only one process
     * @deprecated it seems to give the same results when looking for a process
     * instead of the whole system
     */
    @Deprecated
    public NetStatReader(String interfaceRegexp, Integer processPid) {
        LOG.log(Level.INFO, "Sampling interfaces {0} for process {1}",
                new Object[]{interfaceRegexp, processPid});
        this.device_regexp = interfaceRegexp;
        netstat = new File("proc/" + processPid + "/net/dev");
        checkArgument(netstat.exists(), "/proc/diskstats does not exists");
        checkArgument(netstat.canRead(), "/proc/diskstats can not be read");



    }

    public NetStatReader() {
//        checkArgument(diskstats.exists(), "/proc/diskstats does not exists");
//        checkArgument(diskstats.canRead(), "/proc/diskstats can not be read");
    }

    @Override
    public List<Metric> call() throws Exception {

        Builder<Metric> b = ImmutableList.builder();
        LineReader lr = new LineReader(new FileReader(netstat));
        String l;
        while ((l = lr.readLine()) != null) {
            Matcher m = dline.matcher(l);
            if (!m.matches()) {
                continue;
            }
            String iface = m.group(1);
            if (iface.matches(device_regexp)) {
                b.addAll(Metric.Metric(iface)
                        .addMetric("rx.bytes", Long.parseLong(m.group(2)))
                        .addMetric("rx.packets", Long.parseLong(m.group(3)))
                        .addMetric("rx.errs", Long.parseLong(m.group(4)))
                        .addMetric("rx.drop", Long.parseLong(m.group(5)))
                        .addMetric("tx.bytes", Long.parseLong(m.group(6)))
                        .addMetric("tx.packets", Long.parseLong(m.group(7)))
                        .addMetric("tx.errs", Long.parseLong(m.group(8)))
                        .addMetric("tx.drop", Long.parseLong(m.group(9))).getList());

            }
        }
        return b.build();

    }

    @Override
    public void configure() {
        if (conf.containsKey("netstat-reader.interfaceregexp")) {
            this.device_regexp = conf.getString("netstat-reader.interfaceregexp");
            checkArgument(netstat.exists(), "/proc/diskstats does not exists");
            checkArgument(netstat.canRead(), "/proc/diskstats can not be read");
        }
    }
     @Override
    public void setConf(Configuration c) {
        conf = c;
    }

    @Override
    public Configuration getConf() {
        return conf;
    }
}

##doc

© 著作权归作者所有

go4it
粉丝 85
博文 1014
码字总数 974403
作品 0
深圳
私信 提问
linux mount使用和rpm包安装-jdk为例

如果是物理真机(非虚拟机),放入光盘后系统会自动加载,可以通过命令“mount”查看系统挂载情况,然后继续用命令“mount"去实现其它的挂载任务(即 新增挂载); 如果是虚拟机,需要情况也差...

青涩的梦
2018/06/26
0
0
聊聊jvm的StringTable及SymbolTable

序 本文主要研究一下jvm的StringTable及SymbolTable StringTable及SymbolTable JDK的变动 在java7的时候将字符串常量池移到java heap,字符串常量池被限制在整个应用的堆内存中,在运行时调用...

go4it
04/08
0
0
RHEL7下Tomcat启动慢的原因及解决方案

分析结果 主要原因是生成随机数的时候卡住了,导致tomcat启动不了。 是否有足够的熵来用于产生随机数,可以通过如下命令来查看 [root@tomcat tools]# cat /proc/sys/kernel/random/entropy_a...

有功夫
2018/05/30
0
0
彻底找到 Tomcat 启动速度慢的元凶

问题现象 美女同事找我解决一个问题,说Tomcat启动很慢。开始我以为是程序写的问题,所以把webapps下所有程序都删除掉。(只保留Tomcat自带)灵异的事情发生了,Tomcat停止在—— 我查看了一...

MaxWell__
2018/04/26
0
0
Docker容器实现原理及容器隔离性踩坑介绍

容器底层实现 我们都知道,虚拟机与容器的底层实现原理是不同的,正如下图对比: 虚拟机实现资源隔离的方法是利用一个独立的Guest OS,并利用Hypervisor虚拟化CPU、内存、IO设备等实现的。例...

Docker
2018/09/08
0
0

没有更多内容

加载失败,请刷新页面

加载更多

NIO基于长度域的报文在Netty下的解码

1, 先复习一下粘包/拆包 1.1, 粘包/拆包的含义 TCP是个“流”协议, 并不了解上层业务数据的具体含义, 它会根据TCP缓冲区的实际情况进行包的划分,所以在业务上认为,一个完整的包可能会被TCP...

老菜鸟0217
今天
8
0
从零开始搭建spring-cloud(2) ----ribbon

在微服务架构中,业务都会被拆分成一个独立的服务,服务与服务的通讯是基于http restful的。Spring cloud有两种服务调用方式,一种是ribbon+restTemplate,另一种是feign。 其实我们已经在上...

Vincent-Duan
今天
19
0
get和post的区别?

doGet:路径传参。效率高,安全性差(get的传送数据量有限制,不能大于2Kb) doPOST:实体传参。效率低,安全性好 建议: 1、get方式的安全性较Post方式要差些,包含机密信息的话,建议用Pos...

花无谢
昨天
4
0
当谈论迭代器时,我谈些什么?

当谈论迭代器时,我谈些什么? 花下猫语:之前说过,我对于编程语言跟其它学科的融合非常感兴趣,但我还说漏了一点,就是我对于 Python 跟其它编程语言的对比学习,也很感兴趣。所以,我一直...

豌豆花下猫
昨天
14
0
10天学Python直接做项目,我做了这5件事

初学者如何尽快上手python? 市面上关于如何学python的资料很多,但是讲的都太复杂。 我就是很简单的几句话,从小白到开发工程师,我只做了五件事。 我觉得任何商业计划书如果不能用几句话讲...

Python派森
昨天
7
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部