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