netInterface

Documentation

Index

• type ErrLevel
• type IConnManager
• type IConnection
• type IService

Types

type ErrLevel

type ErrLevel int

错误级别

const (
	Fatal ErrLevel = 0 //致命
	Error ErrLevel = 1 //错误
	Warn  ErrLevel = 2 //警告
	Info  ErrLevel = 3 //一般信息
)

type IConnManager

type IConnManager interface {
	Add(conn IConnection)                                 //添加链接
	Remove(conn IConnection)                              //删除连接
	Get(connID uint64) (IConnection, bool)                //利用ConnID获取链接
	Count() int                                           //连接数
	Range(hFunc func(key uint64, value IConnection) bool) //遍历
	ClearConn()                                           //删除并停止所有链接
}

连接管理接口

type IConnection

type IConnection interface {
	GetNetConn() interface{}                                                                                              //获取连接
	GetConnId() uint64                                                                                                    //获取客户端ID
	GetRemoteAddr() net.Addr                                                                                              //获取远程客户端地址信息
	GetLocalAddr() net.Addr                                                                                               //获取本地地址
	GetHeartTime() time.Time                                                                                              //心跳时间
	SendData(msgType int, data []byte) error                                                                              //发送消息到客户端：消息类型 1.TextMessage（文本） 2、BinaryMessage(二进制)
	SendDataCall(msgType int, data []byte, param interface{}, callFunc func(IConnection, bool, interface{}, error)) error //发送消息到客户端带回调：消息类型 1.TextMessage（文本） 2、BinaryMessage(二进制)
	SetProperty(key string, value interface{})                                                                            //设置链接属性
	GetProperty(key string) (interface{}, error)                                                                          //获取链接属性
	RemoveProperty(key string)                                                                                            //移除链接属性
	GetRecInfo() (count, byteSize uint64)                                                                                 //上行当前处理的包总数（处理前，1开始），总大小(字节)
	GetRepInfo() (count, byteSize, errCount uint64)                                                                       //下行当前处理的包总数（处理后），总大小(字节)
	GetStartTime() time.Time                                                                                              //连接启动时间
	CallLogHandle(level ErrLevel, msgAry ...interface{})                                                                  //设置内部异常抛出处理
	Start()                                                                                                               //启动连接，让当前连接开始工作
	Stop()                                                                                                                //停止连接，结束当前连接状态
	GetIsClosed() bool                                                                                                    //获取的状态（ture:关闭状态，false:未关闭）
	GetPath() string                                                                                                      //消息来源路径
	OnReceiveCompleted(messageType int, data []byte)                                                                      //数据上传一包完成
}

连接的接口

type IService

type IService interface {
	Start()                                                                                                       //启动服务器方法
	Stop()                                                                                                        //停止服务器方法
	GetConnMgr() IConnManager                                                                                     //得到链接管理
	GetConn(connId uint64) (IConnection, bool)                                                                    //获取连接
	SetLogHandle(func(level ErrLevel, msg ...interface{}))                                                        //设置内部异常抛出处理
	SetOnConnStart(hookFunc func(IConnection))                                                                    //设置连接结束处理方法
	SetOnConnStop(hookFunc func(IConnection))                                                                     //设置连接开始处理方法
	SetOnOneReceiveCompleted(hookFunc func(IConnection, int, []byte))                                             //连接上传第一包完整数据(连接,上行数据)
	SetOnReceiveCompleted(hookFunc func(IConnection, int, []byte))                                                //连接上传一包完整数据(连接,上行数据)
	SetOnReplyCompleted(hookFunc func(IConnection, int, []byte, interface{}, bool, error))                        //设置下发回调(连接,下发数据,下发数据时带的参数,是否成功,异常信息)
	GetTotalQueueCount() (receiveCount int64, receiveTotalCount uint64, replyCount int64, replyTotalCount uint64) //获取处理队列和下发队列剩余数
	GetAcceptQueueCount() (count int64, totalCount uint64)                                                        //获取连接接入队列剩余数[TCP才有]
	GetRecInfo() (count, byteSize uint64)                                                                         //上行当前处理的包总数（处理前，1开始），总大小(字节)
	GetRepInfo() (count, byteSize, errCount uint64)                                                               //下行当前处理的包总数（处理后），总大小(字节),异常数
	GetStartTime() time.Time                                                                                      //获取连接启动时间
}

定义服务器接口