ntc

type EConnWay int //

type IClienter interface {

	// 发送消息到此socket
	SendMsg(msg IMsger, compres ...bool) error

	// 发送回应到此socket
	SendAck(req IMsger, ack IMsger, compres ...bool) error

	// 发送错误回应到此socket并返回error
	SendErr(req IMsger, ack *MsgErrAck) error

	// 是否连接着的
	Actived() bool

	// 获得此连接的唯一id
	ConnId() TConnId

	// 链接类型
	ConnType() EConnWay

	// 对端地址IP
	RemoteIP() string

	// 对端地址IP+PORT
	RemoteAddr() string

	// 连接存活的时间
	TimeLived() time.Duration

	// 开始连接的时间
	TimeStart() time.Time

	// 设置绑定数据
	SetUserData(data IUserData)

	// 获得绑定数据
	GetUserData() IUserData
	// contains filtered or unexported methods
}

type IMessageMaker interface {

	// 打包消息
	Pack(bMsg []byte, ele PackEle) ([]byte, error)

	// 解包消息
	Unpack(bPack []byte) ([]byte, PackEle, error)

	// 序列化消息
	Marshal(msg IMsger) ([]byte, error)

	// 反序列化消息
	Unmarshal(bMsg []byte, ele PackEle) (IMsger, error)

	// 解密方法
	Decrypt(src []byte) ([]byte, error)

	// 加密方法
	Encrypt(src []byte) ([]byte, error)

	// 解压方法
	Decompress(src []byte) ([]byte, error)

	// 压缩方法
	Encompress(src []byte) ([]byte, error)
}

type IMsger interface {

	// 获取消息头结构
	GetHead() *MsgHead

	// 设置消息头结构
	SetHead(head *MsgHead)

	// Pb的接口实现
	ProtoMessage()

	// 格式化字符串
	String() string

	// 重置此消息
	Reset()
}

type ITcpConner interface {
	// 继承
	mss.IDebuger

	// 开始连接[目标主机 默认参数(DEF_INFINITE_TIME,DEF_SENDER_CSIZE)]
	StartConnect(desHost string) error

	// 开始连接[目标主机 连接超时 发送缓冲]
	StartConnecT(desHost string, timeout TDurt, sendCap int) error

	// 开始连接[全参数版]
	StartConnEct(desHost string, timeout TDurt, sendCap int, crypt, order, reiss bool) error

	// 关闭连接[ShutDown]
	CloseConnect()

	// 关闭连接[ErrReason]后还可RenewConnect
	ClearConnect(reason error)

	// 断线重新连接
	RenewConnect() error

	// 是否连接着的
	Connected() bool

	// 是否关闭了的
	ShutDowned() bool

	// 目标主机信息
	ConnectHost() string

	// 异步不等发送消息
	SendMessage(msg IMsger, compres ...bool) error

	// 异步等待发送消息
	SentRequest(req IMsger, compres ...bool) error

	// 同步等待发送消息
	SendRequest(req IMsger, compres ...bool) (IMsger, error)

	// 是否开启消息加密
	IsCryptMsg() bool

	// 是否开启消息序列
	IsOrderMsg() bool

	// 是否开启补发
	IsReissMsg() bool

	// 重连补发消息
	ReissueMsgs() error

	// 设置绑定数据
	SetConnData(data interface{})

	// 获得绑定数据
	GetConnData() interface{}
}

type ITcpServer interface {
	// 继承
	mss.IDebuger

	// 初始化参数
	InitServer(maxCli, sendCap int, mustCrypt, mustOrder bool)

	// 开启监听[端口号]
	StartServe(addr string, wsAddr ...WSAddr) error

	// 关闭服务[主线程中调用]
	ShutServer()

	// 关闭监听
	StopListen()

	// 监听地址
	ListenTAddr() string
	ListenWAddr() string

	// 最大连接数
	ClientsMax() int

	// 消息的chan大小
	ClientCapy() int

	// 是否开启数据加密[同时也校验接收消息]
	IsMustCrypt() bool

	// 是否开启消息序列检测
	IsMustOrder() bool

	// 查找client
	FindClient(conId TConnId) IClienter

	// 发送消息
	SendMessage(msg IMsger, conId TConnId, compres ...bool) error

	// 关闭对端
	CloseClient(cli IClienter, remain []Packet, reason error)
}

type IUdpConner interface {

	// 开始连接
	StartConnect(desHost string) error

	// 停止连接
	CloseConnect()

	// 目标主机
	ConnectHost() string

	// 发送消息
	SendMessage(msg IMsger) error
}

type IUdpServer interface {

	// 开始监听
	StartListen(port int) error

	// 停止监听
	StopListen()

	// 端口号
	ListenPort() int

	// 发送消息
	SendMessage(msg IMsger, addr *net.UDPAddr, packFlag ...uint8) error
}

type IUserData interface {

	// 初始化数据[返回this]
	HandInit(client IClienter) interface{}

	// 获得连接ID
	ConnectId() TConnId

	// 连接类型
	TcpConned() bool
	WebConned() bool

	// 对端地址
	GetRemoteIP() string
	SetRemoteIP(addr string)

	// Ping消息
	CalPingOverDurt() time.Duration
	GetLastPingTime() time.Time
	SetLastPingTime(t time.Time)
}

type MsgErrAck struct {
	Head *MsgHead `protobuf:"bytes,1,opt,name=Head,json=head" json:"Head,omitempty"`

	T int32  `protobuf:"varint,2,opt" json:"T,omitempty"`
	V int64  `protobuf:"varint,3,opt" json:"V,omitempty"`
	E string `protobuf:"bytes,4,opt" json:"E,omitempty"`
}

type MsgHead struct {
	Types uint32   `protobuf:"varint,1,opt" json:"Types,omitempty"`
	TheId uint32   `protobuf:"varint,2,opt" json:"TheId,omitempty"`
	MFlag uint32   `protobuf:"varint,3,opt" json:"MFlag,omitempty"`
	SesId uint32   `protobuf:"varint,4,opt" json:"SesId,omitempty"`
	EffId uint32   `protobuf:"varint,5,opt" json:"EffId,omitempty"`
	Trans []*Tran_ `protobuf:"bytes,6,rep" json:"Trans,omitempty"`
	Flag_ uint32   `protobuf:"varint,7,pass" json:"-"`
	Buff_ []byte   `protobuf:"bytes,8,pass" json:"-"`
}

type MsgUnknow struct {
	Head *MsgHead `protobuf:"bytes,1,opt,name=Head,json=head" json:"Head,omitempty"`
	Body []byte   `protobuf:"bytes,2,pass" json:"-"`

} //

type NetDebug struct {
	// contains filtered or unexported fields

} //

type PackEle struct {
	TMsg        uint16
	Flag, Order uint8
}

type Packet struct {
	// contains filtered or unexported fields

} //

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

type Response struct {
	Header http.Header
	Body   []byte
}

type TClientHandler interface {
	// 继承
	mss.IDebuger

	// 所属者名称
	OnTOwnerName() string

	// 连接发生错误
	OnTClientErr(cli IClienter, remain []Packet, err error)

	// 处理消息
	OnTClientMsg(cli IClienter, msg IMsger)

	// Client上的数据是否必须要加密的[true-发送时加密,接收时检测加密]
	OnEnMustCrypt() bool

	// Client上的消息是否校验order
	OnEnMustOrder() bool
}

type TConnHandler interface {

	// 连接成功
	OnTConnectOke(conndata interface{}, reconn bool)

	// 连接发生错误[注意主动关闭和被动关闭的多线程问题]
	OnTConnectErr(conndata interface{}, err error)

	// 处理消息
	OnTConnectMsg(conndata interface{}, req, ack IMsger)

	// 发送请求超时
	OnTConnectOut(conndata interface{}, req IMsger)
}

type TConnId uint32

type TMsgMakeFunc func() IMsger

type TServerHandler interface {

	// 连接发生错误
	OnTClientErr(cli IClienter, remain []Packet, err error)

	// 处理消息
	OnTClientMsg(cli IClienter, msg IMsger)

	// 连接成功
	OnTClientAccept(cli IClienter)
}

type Tran_ struct {
	SesId uint32 `protobuf:"varint,1,opt" json:"SesId,omitempty"`
	SrcId uint32 `protobuf:"varint,2,opt" json:"SrcId,omitempty"`
}

type UConnHandler interface {

	// 处理消息
	OnUConnectMsg(msg IMsger)
}

type UMsgHandFunc func(*net.UDPAddr, IMsger) error

type UServerHandler interface {

	// 处理消息
	OnUClientMsg(addr *net.UDPAddr, msg IMsger)
}

type WSAddr struct {
	Addr              string // ip:port
	EnTLS             bool   // /ws or /wss
	CertFile, KeyFile string
}