所有通道统计：GroupStat

GroupStat是ChannelStat的集合，它有俩子类ServerGroupStat和ClientGroupStat，当你用t-io做tcp服务器端时，你拿到的是ServerGroupStat，反之则是ClientGroupStat

如何获取GroupStat

org.tio.core.TioConfig.groupStat

GroupStat有哪些统计项

直接看源代码吧，这个比文档还容易理解

package org.tio.core.stat;

import java.util.concurrent.atomic.AtomicLong;

/**
 * 
 * @author tanyaowu 
 * 2017年10月19日 上午9:40:48
 */
public class GroupStat implements java.io.Serializable {
    private static final long serialVersionUID = -6988655941470121164L;
    /**
     * 关闭了多少连接
     */
    public final AtomicLong closed = new AtomicLong();
    /**
     * 接收到的消息包
     */
    public final AtomicLong receivedPackets = new AtomicLong();

    /**
     * 接收到的消息字节数
     */
    public final AtomicLong receivedBytes = new AtomicLong();

    /**
     * 处理了的消息包数
     */
    public final AtomicLong handledPackets = new AtomicLong();

    /**
     * 处理消息包耗时，单位：毫秒
     */
    public final AtomicLong handledPacketCosts = new AtomicLong();

    /**
     * 处理了多少字节
     */
    public final AtomicLong handledBytes = new AtomicLong();

    /**
     * 发送了的消息包数
     */
    public final AtomicLong sentPackets = new AtomicLong();

    /**
     * 发送了的字节数
     */
    public final AtomicLong sentBytes = new AtomicLong();

    /**
     * 本IP已接收了多少次TCP数据包
     */
    public final AtomicLong receivedTcps = new AtomicLong();

    /**
     * 平均每次TCP接收到的字节数，这个可以用来监控慢攻击，配置PacketsPerTcpReceive定位慢攻击
     */
    public double getBytesPerTcpReceive() {
        if (receivedTcps.get() == 0) {
            return 0;
        }
        double ret = (double) receivedBytes.get() / (double) receivedTcps.get();
        return ret;
    }

    /**
     * 平均每次TCP接收到的业务包数，这个可以用来监控慢攻击，此值越小越有攻击嫌疑
     */
    public double getPacketsPerTcpReceive() {
        if (receivedTcps.get() == 0) {
            return 0;
        }
        double ret = (double) receivedPackets.get() / (double) receivedTcps.get();
        return ret;
    }

    /**
     * @return the closed
     */
    public AtomicLong getClosed() {
        return closed;
    }

    /**
     * @return the handledBytes
     */
    public AtomicLong getHandledBytes() {
        return handledBytes;
    }

    /**
     * @return the handledPackets
     */
    public AtomicLong getHandledPackets() {
        return handledPackets;
    }

    /**
     * @return the receivedBytes
     */
    public AtomicLong getReceivedBytes() {
        return receivedBytes;
    }

    /**
     * @return the receivedPackets
     */
    public AtomicLong getReceivedPackets() {
        return receivedPackets;
    }

    /**
     * @return the sentBytes
     */
    public AtomicLong getSentBytes() {
        return sentBytes;
    }

    /**
     * @return the sentPacket
     */
    public AtomicLong getSentPackets() {
        return sentPackets;
    }

    /**
     * @return the receivedTcps
     */
    public AtomicLong getReceivedTcps() {
        return receivedTcps;
    }

    /**
     * 处理消息包耗时，单位：毫秒
     * @return
     */
    public AtomicLong getHandledPacketCosts() {
        return handledPacketCosts;
    }

    /**
     * 处理packet平均耗时，单位：毫秒
     * @return
     */
    public double getHandledCostsPerPacket() {
        if (handledPackets.get() > 0) {
            return handledPacketCosts.get() / handledPackets.get();
        }
        return 0;
    }
}

当然它的两个子类还会有各自的字段

package org.tio.server;

import java.util.concurrent.atomic.AtomicLong;

import org.tio.core.stat.GroupStat;

/**
 *
 * @author tanyaowu
 *
 */
public class ServerGroupStat extends GroupStat {

    private static final long serialVersionUID = -139100692961946342L;
    /**
     * 接受了多少连接
     */
    public final AtomicLong accepted = new AtomicLong();

    /**
     *
     *
     * @author tanyaowu
     * 2016年12月3日 下午2:29:28
     *
     */
    public ServerGroupStat() {
    }

    /**
     * @return the accepted
     */
    public AtomicLong getAccepted() {
        return accepted;
    }
}

package org.tio.client;

import org.tio.core.stat.GroupStat;

/**
 *
 * @author tanyaowu
 * 2017年4月1日 上午9:32:01
 */
public class ClientGroupStat extends GroupStat {

    private static final long serialVersionUID = 804270967157603097L;
}