单条通道统计：ChannelStat

ChannelStat是单条TCP通道的流量统计，t-io自诩拥有最强级别的流量统计和监控，也绝不是吹吹牛

如何获取ChannelStat

org.tio.core.ChannelContext.stat

ChannelStat有哪些统计项

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

package org.tio.core.stat;

import java.util.concurrent.atomic.AtomicLong;

import org.tio.utils.SystemTimer;

/**
 * @author tanyaowu
 * 2017年4月1日 下午2:17:35
 */
public class ChannelStat implements java.io.Serializable {
    private static final long serialVersionUID = -6942731710053482089L;

    /**
     * 本次解码失败的次数
     */
    public int decodeFailCount = 0;

    /**
     * 最近一次收到业务消息包的时间(一个完整的业务消息包，一部分消息不算)
     */
    public long latestTimeOfReceivedPacket = SystemTimer.currTime;

    /**
     * 最近一次发送业务消息包的时间(一个完整的业务消息包，一部分消息不算)
     */
    public long latestTimeOfSentPacket = SystemTimer.currTime;
    
    /**
     * 最近一次收到业务消息包的时间:收到字节就算
     */
    public long latestTimeOfReceivedByte = SystemTimer.currTime;

    /**
     * 最近一次发送业务消息包的时间：发送字节就算
     */
    public long latestTimeOfSentByte = SystemTimer.currTime;

    /**
     * ChannelContext对象创建的时间
     */
    public long timeCreated = System.currentTimeMillis();

    /**
     * 第一次连接成功的时间
     */
    public Long timeFirstConnected = null;

    /**
     * 连接关闭的时间
     */
    public long timeClosed = SystemTimer.currTime;

    /**
     * 进入重连队列时间
     */
    public long timeInReconnQueue = SystemTimer.currTime;

    /**
     * 本连接已发送的字节数
     */
    public final AtomicLong sentBytes = new AtomicLong();

    /**
     * 本连接已发送的packet数
     */
    public final AtomicLong sentPackets = new AtomicLong();

    /**
     * 本连接已处理的字节数
     */
    public final AtomicLong handledBytes = new AtomicLong();

    /**
     * 本连接已处理的packet数
     */
    public final AtomicLong handledPackets = new AtomicLong();
    
    /**
     * 处理消息包耗时，单位：毫秒
     * 拿这个值除以handledPackets，就是处理每个消息包的平均耗时
     */
    public final AtomicLong handledPacketCosts = new AtomicLong();

    /**
     * 本连接已接收的字节数
     */
    public final AtomicLong receivedBytes = new AtomicLong();
    
    /**
     * 本连接已接收了多少次TCP数据包
     */
    public final AtomicLong receivedTcps = new AtomicLong();

    /**
     * 本连接已接收的packet数
     */
    public final AtomicLong receivedPackets = 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 decodeFailCount
     */
    public int getDecodeFailCount() {
        return decodeFailCount;
    }

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

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

    /**
     * @return the timeLatestReceivedMsg
     */
    public long getLatestTimeOfReceivedPacket() {
        return latestTimeOfReceivedPacket;
    }

    /**
     * @return the timeLatestSentMsg
     */
    public long getLatestTimeOfSentPacket() {
        return latestTimeOfSentPacket;
    }

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

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

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

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

    /**
     * @return the timeClosed
     */
    public long getTimeClosed() {
        return timeClosed;
    }

    /**
     * @return the timeCreated
     */
    public long getTimeCreated() {
        return timeCreated;
    }

    /**
     * @return the timeFirstConnected
     */
    public Long getTimeFirstConnected() {
        return timeFirstConnected;
    }

    /**
     * @return the timeInReconnQueue
     */
    public long getTimeInReconnQueue() {
        return timeInReconnQueue;
    }

    /**
     * @param timeLatestSentMsg the timeLatestSentMsg to set
     */
    public void setLatestTimeOfSentPacket(long latestTimeOfSentPacket) {
        this.latestTimeOfSentPacket = latestTimeOfSentPacket;
    }
    
    /**
     * @param timeClosed the timeClosed to set
     */
    public void setTimeClosed(long timeClosed) {
        this.timeClosed = timeClosed;
    }

    /**
     * @param timeFirstConnected the timeFirstConnected to set
     */
    public void setTimeFirstConnected(Long timeFirstConnected) {
        this.timeFirstConnected = timeFirstConnected;
    }

    /**
     * @param timeInReconnQueue the timeInReconnQueue to set
     */
    public void setTimeInReconnQueue(long timeInReconnQueue) {
        this.timeInReconnQueue = timeInReconnQueue;
    }

    /**
     * @return the latestTimeOfReceivedByte
     */
    public long getLatestTimeOfReceivedByte() {
        return latestTimeOfReceivedByte;
    }

    /**
     * @param latestTimeOfReceivedByte the latestTimeOfReceivedByte to set
     */
    public void setLatestTimeOfReceivedByte(long latestTimeOfReceivedByte) {
        this.latestTimeOfReceivedByte = latestTimeOfReceivedByte;
    }

    /**
     * @return the latestTimeOfSentByte
     */
    public long getLatestTimeOfSentByte() {
        return latestTimeOfSentByte;
    }

    /**
     * @param latestTimeOfSentByte the latestTimeOfSentByte to set
     */
    public void setLatestTimeOfSentByte(long latestTimeOfSentByte) {
        this.latestTimeOfSentByte = latestTimeOfSentByte;
    }

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

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