connection

type Connection struct {
	ConnectionId string //链接信息唯一ID

	Timer   *time.Timer //心跳检测超时器
	IsBreak bool        //是否活跃
	// contains filtered or unexported fields
}

type ConnectionCounts struct {
	MaxConnectionNum int64 //当前自增的通道记录

	ConnectionLinkNum      int //当前连接中的通道数量
	ConnectionWaitClearNum int //当前待清理的删除通道数量
	// contains filtered or unexported fields
}

type ConnectionInfo struct {
	Ip           string `json:"ip"`            //网关连接ip
	HttpPort     string `json:"http_port"`     //http端口
	Pid          string `json:"pid"`           //进程id
	Cid          string `json:"cid"`           //自增id
	Range        string `json:"range"`         //随机1-65535
	ConnectionId string `json:"connection_id"` //加密后的管道id
}

type ConnectionMap struct {
	ConnectionList map[string]*Connection //所有的socket通道信息记录

	TmpConnectionList map[string]*Connection //当IsClearIng为true的时候 会把链接进来的用户存到当前MAP中一份 用来异步清理MAP

	DeletedWaitReuse *ConnectionQueue //已删除可以复用的通道数

	Prefix string //前缀

	ConnectionCounts *ConnectionCounts //计数器

	IsClearIng bool //是否正在清理

	Mutex sync.Mutex //锁防止生成重复的通道key值
}

type ConnectionQueue struct {
	Header *ConnectionQueueItem //第一个元素 减少复杂度
	Tail   *ConnectionQueueItem //最后一个元素 减少复杂度
	// contains filtered or unexported fields
}

type ConnectionQueueBody struct {
	// contains filtered or unexported fields
}

type ConnectionQueueItem struct {
	ConnectionQueueBody *ConnectionQueueBody //管道的内容

	Prev *ConnectionQueueItem //链表上一个元素
	Next *ConnectionQueueItem //链表下一个元素
}