public class ChannelStat extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
int |
decodeFailCount
本次解码失败的次数
|
AtomicLong |
handledBytes
本连接已处理的字节数
|
AtomicLong |
handledPacketCosts
处理消息包耗时,单位:毫秒
拿这个值除以handledPackets,就是处理每个消息包的平均耗时
|
AtomicLong |
handledPackets
本连接已处理的packet数
|
AtomicInteger |
heartbeatTimeoutCount
心跳超时次数
|
long |
latestTimeOfReceivedByte
最近一次收到业务消息包的时间:收到字节就算
|
long |
latestTimeOfReceivedPacket
最近一次收到业务消息包的时间(一个完整的业务消息包,一部分消息不算)
|
long |
latestTimeOfSentByte
最近一次发送业务消息包的时间:发送字节就算
|
long |
latestTimeOfSentPacket
最近一次发送业务消息包的时间(一个完整的业务消息包,一部分消息不算)
|
AtomicLong |
receivedBytes
本连接已接收的字节数
|
AtomicLong |
receivedPackets
本连接已接收的packet数
|
AtomicLong |
receivedTcps
本连接已接收了多少次TCP数据包
|
AtomicLong |
sentBytes
本连接已发送的字节数
|
AtomicLong |
sentPackets
本连接已发送的packet数
|
long |
timeClosed
连接关闭的时间
|
long |
timeCreated
ChannelContext对象创建的时间
|
Long |
timeFirstConnected
第一次连接成功的时间
|
long |
timeInReconnQueue
进入重连队列时间
|
Constructor and Description |
---|
ChannelStat() |
public int decodeFailCount
public long latestTimeOfReceivedPacket
public long latestTimeOfSentPacket
public long latestTimeOfReceivedByte
public long latestTimeOfSentByte
public long timeCreated
public Long timeFirstConnected
public long timeClosed
public long timeInReconnQueue
public final AtomicLong sentBytes
public final AtomicLong sentPackets
public final AtomicLong handledBytes
public final AtomicLong handledPackets
public final AtomicLong handledPacketCosts
public final AtomicLong receivedBytes
public final AtomicLong receivedTcps
public final AtomicLong receivedPackets
public AtomicInteger heartbeatTimeoutCount
public double getBytesPerTcpReceive()
public double getPacketsPerTcpReceive()
public int getDecodeFailCount()
public AtomicLong getHandledBytes()
public AtomicLong getHandledPackets()
public long getLatestTimeOfReceivedPacket()
public long getLatestTimeOfSentPacket()
public AtomicLong getReceivedBytes()
public AtomicLong getReceivedPackets()
public AtomicLong getSentBytes()
public AtomicLong getSentPackets()
public long getTimeClosed()
public long getTimeCreated()
public Long getTimeFirstConnected()
public long getTimeInReconnQueue()
public void setLatestTimeOfSentPacket(long latestTimeOfSentPacket)
timeLatestSentMsg
- the timeLatestSentMsg to setpublic void setTimeClosed(long timeClosed)
timeClosed
- the timeClosed to setpublic void setTimeFirstConnected(Long timeFirstConnected)
timeFirstConnected
- the timeFirstConnected to setpublic void setTimeInReconnQueue(long timeInReconnQueue)
timeInReconnQueue
- the timeInReconnQueue to setpublic long getLatestTimeOfReceivedByte()
public void setLatestTimeOfReceivedByte(long latestTimeOfReceivedByte)
latestTimeOfReceivedByte
- the latestTimeOfReceivedByte to setpublic long getLatestTimeOfSentByte()
public void setLatestTimeOfSentByte(long latestTimeOfSentByte)
latestTimeOfSentByte
- the latestTimeOfSentByte to setpublic AtomicLong getReceivedTcps()
public AtomicLong getHandledPacketCosts()
public double getHandledCostsPerPacket()
Copyright © 2021. All rights reserved.